org.apache.log4j.Logger.error()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(15.3k)|赞(0)|评价(0)|浏览(270)

本文整理了Java中org.apache.log4j.Logger.error()方法的一些代码示例,展示了Logger.error()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.error()方法的具体详情如下:
包路径:org.apache.log4j.Logger
类名称:Logger
方法名:error

Logger.error介绍

[英]Log a message with the ERROR level with message formatting done according to the value of messagePattern and arg parameters.

This form avoids superflous parameter construction. Whenever possible, you should use this form instead of constructing the message parameter using string concatenation.
[中]使用ERROR级别记录消息,并根据messagePatternarg参数的值设置消息格式。
这种形式避免了超级参数构造。只要有可能,您应该使用此表单,而不是使用字符串连接构造消息参数。

代码示例

代码示例来源:origin: log4j/log4j

  1. static
  2. void roll() {
  3. try {
  4. Socket socket = new Socket(host, port);
  5. DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
  6. DataInputStream dis = new DataInputStream(socket.getInputStream());
  7. dos.writeUTF(ExternallyRolledFileAppender.ROLL_OVER);
  8. String rc = dis.readUTF();
  9. if(ExternallyRolledFileAppender.OK.equals(rc)) {
  10. cat.info("Roll over signal acknowledged by remote appender.");
  11. } else {
  12. cat.warn("Unexpected return code "+rc+" from remote entity.");
  13. System.exit(2);
  14. }
  15. } catch(IOException e) {
  16. cat.error("Could not send roll signal on host "+host+" port "+port+" .",
  17. e);
  18. System.exit(2);
  19. }
  20. System.exit(0);
  21. }
  22. }

代码示例来源:origin: voldemort/voldemort

  1. private void logFailureAndWait(String action, String cause, int attempt, Exception e) throws InterruptedException {
  2. String retryMessage;
  3. if (attempt < maxAttempts) {
  4. retryMessage = ", will wait " + waitBetweenRetries + " ms until next retry.";
  5. } else {
  6. retryMessage = ", no further attempts will be performed.";
  7. }
  8. String fullMessage = "Failed to " + action + " because " + cause + ". Attempt #" +
  9. attempt + "/" + maxAttempts + retryMessage;
  10. if (e == null) {
  11. logger.warn(fullMessage);
  12. } else {
  13. logger.error(fullMessage, e);
  14. }
  15. Thread.sleep(waitBetweenRetries);
  16. }

代码示例来源:origin: azkaban/azkaban

  1. private void registerMbean(final String name, final Object mbean) {
  2. final Class<?> mbeanClass = mbean.getClass();
  3. final ObjectName mbeanName;
  4. try {
  5. mbeanName = new ObjectName(mbeanClass.getName() + ":name=" + name);
  6. this.mbeanServer.registerMBean(mbean, mbeanName);
  7. logger.info("Bean " + mbeanClass.getCanonicalName() + " registered.");
  8. this.registeredMBeans.add(mbeanName);
  9. } catch (final Exception e) {
  10. logger.error("Error registering mbean " + mbeanClass.getCanonicalName(),
  11. e);
  12. }
  13. }

代码示例来源:origin: voldemort/voldemort

  1. public void run() {
  2. try {
  3. DataSetStats totals = new DataSetStats();
  4. List<String> names = new ArrayList<String>();
  5. List<DataSetStats> stats = new ArrayList<DataSetStats>();
  6. for(StorageEngine<ByteArray, byte[], byte[]> store: storeRepository.getAllStorageEngines()) {
  7. if(store instanceof ReadOnlyStorageEngine
  8. || store instanceof ViewStorageEngine || store instanceof MetadataStore)
  9. continue;
  10. logger.info(store.getClass());
  11. logger.info("Calculating stats for '" + store.getName() + "'...");
  12. DataSetStats curr = calculateStats(store);
  13. names.add(store.getName());
  14. stats.add(curr);
  15. totals.add(curr);
  16. }
  17. for(int i = 0; i < names.size(); i++)
  18. logger.info("\n\nData statistics for store '" + names.get(i) + "':\n"
  19. + stats.get(i) + "\n\n");
  20. logger.info("Totals: \n " + totals + "\n\n");
  21. } catch(Exception e) {
  22. logger.error("Error in thread: ", e);
  23. }
  24. }
  25. });

代码示例来源:origin: azkaban/azkaban

  1. for (final File f : validatorDir.listFiles()) {
  2. if (f.getName().endsWith(".jar")) {
  3. resources.add(f.toURI().toURL());
  4. if (resourceTimestamps.get(f.getName()) == null
  5. || resourceTimestamps.get(f.getName()) != f.lastModified()) {
  6. reloadResources = true;
  7. logger.info("Resource " + f.getName() + " is updated. Reload the classloader.");
  8. resourceTimestamps.put(f.getName(), f.lastModified());
  9. logger.error("Cannot reload validator classloader because failure "
  10. + "to close the validator classloader.", e);
  11. validatorLoader = new ValidatorClassLoader(resources.toArray(new URL[resources.size()]));

代码示例来源:origin: voldemort/voldemort

  1. @Override
  2. protected void stopInner() throws VoldemortException {
  3. List<VoldemortException> exceptions = new ArrayList<VoldemortException>();
  4. /* Stop in reverse order */
  5. for(VoldemortService service: Utils.reversed(services)) {
  6. try {
  7. service.stop();
  8. } catch(VoldemortException e) {
  9. exceptions.add(e);
  10. logger.error(e);
  11. }
  12. }
  13. if(exceptions.size() > 0) {
  14. throw exceptions.get(0);
  15. }
  16. }

代码示例来源:origin: azkaban/azkaban

  1. public static Condition fromJson(final Object obj) throws Exception {
  2. if (checkerLoader == null) {
  3. throw new Exception("Condition Checker loader not initialized!");
  4. }
  5. final Map<String, Object> jsonObj = (HashMap<String, Object>) obj;
  6. Condition cond = null;
  7. try {
  8. final Map<String, ConditionChecker> checkers =
  9. new HashMap<>();
  10. final List<Object> checkersJson = (List<Object>) jsonObj.get("checkers");
  11. for (final Object oneCheckerJson : checkersJson) {
  12. final Map<String, Object> oneChecker =
  13. (HashMap<String, Object>) oneCheckerJson;
  14. final String type = (String) oneChecker.get("type");
  15. final ConditionChecker ck =
  16. checkerLoader.createCheckerFromJson(type,
  17. oneChecker.get("checkerJson"));
  18. checkers.put(ck.getId(), ck);
  19. }
  20. final String expr = (String) jsonObj.get("expression");
  21. final Long nextCheckTime = Long.valueOf((String) jsonObj.get("nextCheckTime"));
  22. cond = new Condition(checkers, expr, nextCheckTime);
  23. } catch (final Exception e) {
  24. e.printStackTrace();
  25. logger.error("Failed to recreate condition from json.", e);
  26. throw new Exception("Failed to recreate condition from json.", e);
  27. }
  28. return cond;
  29. }

代码示例来源:origin: voldemort/voldemort

  1. logger.error("Cannot run slop pusher job since Voldemort server is rebalancing");
  2. return;
  3. logger.info("Started streaming slop pusher job at " + startTime);
  4. if(zoneMapping.get(zone.getId()) == null
  5. || zoneMapping.get(zone.getId()).size() == 0)
  6. zonesDown++;
  7. logger.info("Completed streaming slop pusher job at " + startTime
  8. + " early because " + zonesDown + " zones are down");
  9. stopAdminClient();
  10. attemptedByNode.put(node.getId(), 0L);
  11. succeededByNode.put(node.getId(), 0L);
  12. logger.info("Attempted pushing " + attemptedPushes + " slops");
  13. consumerResults.add(consumerExecutor.submit(new SlopConsumer(nodeId,
  14. slopQueue,
  15. slopStorageEngine)));
  16. logger.warn("Interrupted exception", e);
  17. terminatedEarly = true;
  18. } catch(Exception e) {
  19. logger.error(e, e);
  20. terminatedEarly = true;
  21. } finally {

代码示例来源:origin: voldemort/voldemort

  1. Map<String, Long> storeToMaxVersion = Maps.newHashMapWithExpectedSize(storeNames.size());
  2. for(String storeName: storeNames) {
  3. storeToMaxVersion.put(storeName, 0L);
  4. Map<String, Long> currentNodeVersions = getROMaxVersion(node.getId(), storeNames);
  5. for(String storeName: currentNodeVersions.keySet()) {
  6. Long maxVersion = storeToMaxVersion.get(storeName);
  7. if(maxVersion != null && maxVersion < currentNodeVersions.get(storeName)) {
  8. storeToMaxVersion.put(storeName, currentNodeVersions.get(storeName));
  9. nodeFailures++;
  10. if (nodeFailures > maxNodeFailures) {
  11. logger.error("Got an exception while trying to reach node " + node.getId() + ". " +
  12. nodeFailures + " node failure(s) so far; maxNodeFailures exceeded, rethrowing.");
  13. throw e;
  14. } else {
  15. logger.warn("Got an exception while trying to reach node " + node.getId() + ". " +
  16. nodeFailures + " node failure(s) so far; continuing.", e);

代码示例来源:origin: azkaban/azkaban

  1. final SlaOption sla;
  2. try {
  3. sla = parseSlaSetting(settings.get(set));
  4. } catch (final Exception e) {
  5. throw new ServletException(e);
  6. sla.getInfo().put(SlaOption.INFO_FLOW_NAME, sched.getFlowName());
  7. sla.getInfo().put(SlaOption.INFO_EMAIL_LIST, slaEmails);
  8. slaOptions.add(sla);
  9. ret.put("error", e.getMessage());
  10. } catch (final ScheduleManagerException e) {
  11. logger.error(e.getMessage(), e);
  12. ret.put("error", e.getMessage());

代码示例来源:origin: azkaban/azkaban

  1. private List<String> fetchResourceIdOrderedList(final int projectId) {
  2. try {
  3. return this.databaseOperator.query(SQL_FETCH_PVR,
  4. rs -> {
  5. final List<String> results = new ArrayList<>();
  6. while (rs.next()) {
  7. results.add(rs.getString(1));
  8. }
  9. return results;
  10. }, projectId);
  11. } catch (final SQLException e) {
  12. log.error("Error performing cleanup of Project: " + projectId, e);
  13. }
  14. return Collections.emptyList();
  15. }
  16. }

代码示例来源:origin: voldemort/voldemort

  1. if(logger.isDebugEnabled()) {
  2. logger.debug("GET Metadata request received.");
  3. true,
  4. this.requestObject.getRequestOriginTimeInMs());
  5. if(logger.isDebugEnabled()) {
  6. logger.debug("GET Metadata successful !");
  7. if(logger.isDebugEnabled()) {
  8. logger.debug("GET request received.");
  9. boolean keyExists = false;
  10. List<Versioned<byte[]>> versionedValues = this.storeClient.getWithCustomTimeout(this.requestObject);
  11. if(versionedValues == null || versionedValues.size() == 0) {
  12. if(this.requestObject.getValue() != null) {
  13. if(versionedValues == null) {
  14. versionedValues = new ArrayList<Versioned<byte[]>>();
  15. versionedValues.add(this.requestObject.getValue());
  16. keyExists = true;
  17. if(versionedResponses == null
  18. || versionedResponses.values().size() == 0) {
  19. logger.error("Error when doing getall. Keys do not exist.");
  20. logger.error("Requested Key with the specified version does not exist");
  21. RestErrorHandler.writeErrorResponse(this.messageEvent,
  22. NOT_FOUND,

代码示例来源:origin: voldemort/voldemort

  1. String dir = response.getResponse();
  2. try {
  3. logger.info("Attempting swap for " + node.briefToString() + ", dir = " + dir);
  4. previousDirs.put(node, adminClient.readonlyOps.swapStore(nodeId, storeName, dir));
  5. logger.info("Swap succeeded for " + node.briefToString());
  6. } catch(Exception e) {
  7. exceptions.put(node, e);
  8. try {
  9. int successfulNodeId = node.getId();
  10. logger.info("Rolling back data on successful " + node.briefToString());
  11. adminClient.readonlyOps.rollbackStore(successfulNodeId,
  12. storeName,
  13. ReadOnlyUtils.getVersionId(new File(previousDirs.get(node))));
  14. logger.info("Rollback succeeded for " + node.briefToString());
  15. } catch(Exception e) {
  16. logger.error("Exception thrown during rollback ( after swap ) operation on "
  17. + node.briefToString() + ": ",
  18. e);
  19. logger.error("Error on " + node.briefToString() + " during swap : ",
  20. exceptions.get(node));

代码示例来源:origin: voldemort/voldemort

  1. if(logger.isDebugEnabled())
  2. logger.debug("Trying to send hint to " + nodeId + " for key " + slop.getKey());
  3. Store<ByteArray, Slop, byte[]> slopStore = slopStores.get(nodeId);
  4. Utils.notNull(slopStore);
  5. long startNs = System.nanoTime();
  6. if(logger.isDebugEnabled())
  7. logger.debug("Slop attempt to write " + slop.getKey() + " (keyRef: "
  8. + System.identityHashCode(slop.getKey()) + ") for "
  9. + failedNode + " to node " + node);
  10. failureDetector.recordException(node, (System.nanoTime() - startNs)
  11. / Time.NS_PER_MS, e);
  12. logger.warn("Error during hinted handoff. Will try another node", e);
  13. } catch(IllegalStateException e) {
  14. logger.warn("Error during hinted handoff. Will try another node", e);
  15. } catch(ObsoleteVersionException e) {
  16. logger.debug(e, e);
  17. } catch(Exception e) {
  18. logger.error("Unknown exception. Will try another node" + e);
  19. if(logger.isDebugEnabled())
  20. logger.debug("Slop write of key " + slop.getKey() + " (keyRef: "
  21. + System.identityHashCode(slop.getKey()) + ") for " + failedNode
  22. logger.error("Slop write of key " + slop.getKey() + " (keyRef: "
  23. + System.identityHashCode(slop.getKey()) + ") for " + failedNode
  24. + " was not written.");

代码示例来源:origin: voldemort/voldemort

  1. private void commitToVoldemort(List<String> storeNamesToCommit) {
  2. if(logger.isDebugEnabled()) {
  3. logger.debug("Trying to commit to Voldemort");
  4. if(nodesToStream == null || nodesToStream.size() == 0) {
  5. if(logger.isDebugEnabled()) {
  6. logger.debug("No nodes to stream to. Returning.");
  7. logger.error("Exception during commit", e);
  8. hasError = true;
  9. if(!faultyNodes.contains(node.getId()))
  10. faultyNodes.add(node.getId());
  11. logger.warn("StreamingSession may not have been initialized since Variable streamingresults is null. Skipping callback ");
  12. return;
  13. logger.info("Invoking the Recovery Callback");
  14. Future future = streamingresults.submit(recoveryCallback);
  15. try {
  16. logger.error("Recovery Callback failed", e1);
  17. throw new VoldemortException("Recovery Callback failed");
  18. } catch(ExecutionException e1) {
  19. MARKED_BAD = true;
  20. logger.error("Recovery Callback failed during execution", e1);
  21. throw new VoldemortException("Recovery Callback failed during execution");

代码示例来源:origin: voldemort/voldemort

  1. private synchronized void flushData() {
  2. BufferedWriter writer = null;
  3. try {
  4. writer = new BufferedWriter(new FileWriter(new File(this.inputPath)));
  5. for(String key: this.metadataMap.keySet()) {
  6. writer.write(NEW_PROPERTY_SEPARATOR + key.toString() + "]" + NEW_LINE);
  7. writer.write(this.metadataMap.get(key).toString());
  8. writer.write("" + NEW_LINE + "" + NEW_LINE);
  9. }
  10. writer.flush();
  11. } catch(IOException e) {
  12. logger.error("IO exception while flushing data to file backed storage: "
  13. + e.getMessage());
  14. }
  15. try {
  16. if(writer != null)
  17. writer.close();
  18. } catch(Exception e) {
  19. logger.error("Error while flushing data to file backed storage: " + e.getMessage());
  20. }
  21. }

代码示例来源:origin: brianfrankcooper/YCSB

  1. logger.debug("Built lookup request as: " + lookupRequest.toString());
  2. logger.error(
  3. String.format("Datastore Exception when reading (%s): %s %s",
  4. exception.getMessage(),
  5. logger.debug("Read entity: " + entity.toString());
  6. result.put(name, new StringByteIterator(properties.get(name)
  7. .getStringValue()));

代码示例来源:origin: RipMeApp/ripme

  1. public static List<URL> getFilesFromURL(URL url) {
  2. List<URL> result = new ArrayList<>();
  3. logger.debug("Checking " + url);
  4. logger.error("[!] Exception while loading album " + url, e);
  5. result.add(imgurImage.url);
  6. logger.error("[!] Exception while loading album " + url, e);
  7. } catch (IOException e) {
  8. logger.warn("Exception while retrieving gfycat page:", e);
  9. logger.warn("Exception while retrieving vidble page:", e);
  10. logger.warn("Exception while retrieving eroshare page:", e);
  11. return result;
  12. } catch (MalformedURLException e) {
  13. logger.error("[!] Not a valid URL: '" + url + "'", e);
  14. logger.error("[!] Error", ex);
  15. logger.error("[!] Unable to rip URL: " + url);
  16. return result;

代码示例来源:origin: azkaban/azkaban

  1. @Override
  2. public void doAction() throws Exception {
  3. logger.info("Alerting on sla failure.");
  4. final Map<String, Object> alert = this.slaOption.getInfo();
  5. if (alert.containsKey(SlaOption.ALERT_TYPE)) {
  6. final String alertType = (String) alert.get(SlaOption.ALERT_TYPE);
  7. final Alerter alerter = this.alerters.get(alertType);
  8. if (alerter != null) {
  9. try {
  10. final ExecutableFlow flow = this.executorLoader.fetchExecutableFlow(this.execId);
  11. alerter.alertOnSla(this.slaOption, SlaOption.createSlaMessage(this.slaOption, flow));
  12. } catch (final Exception e) {
  13. e.printStackTrace();
  14. logger.error("Failed to alert by " + alertType);
  15. }
  16. } else {
  17. logger.error("Alerter type " + alertType
  18. + " doesn't exist. Failed to alert.");
  19. }
  20. }
  21. }

代码示例来源:origin: brianfrankcooper/YCSB

  1. @Override
  2. public Status insert(String table, String key, Map<String, ByteIterator> values) {
  3. if (LOGGER.isDebugEnabled()) {
  4. LOGGER.debug("insertkey: " + primaryKeyName + "-" + key + " from table: " + table);
  5. }
  6. Map<String, AttributeValue> attributes = createAttributes(values);
  7. // adding primary key
  8. attributes.put(primaryKeyName, new AttributeValue(key));
  9. if (primaryKeyType == PrimaryKeyType.HASH_AND_RANGE) {
  10. // If the primary key type is HASH_AND_RANGE, then what has been put
  11. // into the attributes map above is the range key part of the primary
  12. // key, we still need to put in the hash key part here.
  13. attributes.put(hashKeyName, new AttributeValue(hashKeyValue));
  14. }
  15. PutItemRequest putItemRequest = new PutItemRequest(table, attributes);
  16. try {
  17. dynamoDB.putItem(putItemRequest);
  18. } catch (AmazonServiceException ex) {
  19. LOGGER.error(ex);
  20. return Status.ERROR;
  21. } catch (AmazonClientException ex) {
  22. LOGGER.error(ex);
  23. return CLIENT_ERROR;
  24. }
  25. return Status.OK;
  26. }

相关文章