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

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

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

Logger.warn介绍

[英]Log a message with the WARN 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.
[中]使用WARN级别记录消息，并根据messagePattern和arg参数的值设置消息格式。
这种形式避免了超级参数构造。只要有可能，您应该使用此表单，而不是使用字符串连接构造消息参数。

代码示例

代码示例来源：origin: apache/storm

  1. public MetricsCollectorConfig(String topoName, Map<String, Object> topoConfig) {
  2.     this.topoConfig = topoConfig;
  3.     String labelStr = (String) topoConfig.get("benchmark.label");
  4.     this.name = topoName;
  5.     if (labelStr == null) {
  6.       LOG.warn("'benchmark.label' not found in config. Defaulting to topology name");
  7.       labelStr = this.name;
  8.     }
  9.     this.label = labelStr;
  10.   }
  11. } // MetricsCollectorConfig

代码示例来源：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: 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: marytts/marytts

  1. logger.debug(String.format("Reading lexicon from '%s'", lexiconFilename));
  2. String line;
  3. Map<String, List<String>> fLexicon = new HashMap<String, List<String>>();
  4.     phonStr = lineParts[1];
  5.   } catch (ArrayIndexOutOfBoundsException e) {
  6.     logger.warn(String.format("Lexicon '%s': missing transcription for '%s'", lexiconFilename, graphStr));
  7.     continue;
  8.     allophoneSet.splitIntoAllophones(phonStr);
  9.   } catch (IllegalArgumentException e) {
  10.     logger.warn(String.format("Lexicon '%s': invalid entry for '%s': %s", lexiconFilename, graphStr, e.getMessage()));
  11.     continue;
  12.   List<String> transcriptions = fLexicon.get(graphStr);
  13.   if (null == transcriptions) {
  14.     transcriptions = new ArrayList<String>();
  15.     fLexicon.put(graphStr, transcriptions);
  16.   transcriptions.add(phonPosStr);

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

  1. adminClients = new ArrayList<AdminClient>(urls.size());
  2. Map<String, Cluster> clusterMap = new HashMap<String, Cluster>(urls.size());
  3. Map<String, StoreDefinition> storeDefinitionMap = new HashMap<String, StoreDefinition>(urls.size());
  4.     logger.info("Connecting to bootstrap server: " + url);
  5.   adminClients.add(adminClient);
  6.   clusterMap.put(url, cluster);
  7.   StoreDefinition storeDefinition = StoreDefinitionUtils.getStoreDefinitionWithName(storeDefinitions.getValue(),
  8.       storeName);
  9.   storeDefinitionMap.put(url, storeDefinition);
  10.     logger.error("Partition count of different clusters is not the same: "
  11.         + partitionCount + " vs " + currentPartitionCount);
  12.     throw new VoldemortException("Will not connect because partition counts differ among clusters.");
  13.   StoreDefinition storeDefinition = storeDefinitionMap.get(url);
  14.   Cluster cluster = clusterMap.get(url);
  15.   Map<Integer, Integer> partitionToNodeMap = cluster.getPartitionIdToNodeIdMap();
  16.     logger.info(line);
  17.       retentionDays = storeRetentionDays;
  18.     logger.warn("Retention-days is not consistent between clusters by urls. Will use the shorter.");

代码示例来源：origin: tjake/Solandra

  1. Document doc = documentCache.get(docNum);
  2.   if (logger.isDebugEnabled())
  3.     logger.debug("Found doc in cache");
  4. keyMap.put(docNum, CassandraUtils.hashKeyBytes(indexName.getBytes("UTF-8"), CassandraUtils.delimeterBytes, Integer
  5.     .toHexString(docNum).getBytes("UTF-8")));
  6.   fieldNames = ((SolandraFieldSelector) selector).getFieldNames();
  7.       continue;
  8.     if (fieldNames == null || fieldNames.size() == 0)
  9.           .add(new SliceByNamesReadCommand(CassandraUtils.keySpace, key, columnParent, fieldNames));
  10.   for (Row row : rows)
  11.     rowMap.put(row.key.key, row);
  12.     Row row = rowMap.get(key.getValue());
  13.       logger.warn("Missing document in multiget_slice for: "
  14.           + ByteBufferUtil.string(key.getValue(), CassandraUtils.UTF_8) + " " + rowMap);
  15.           logger.warn("Filtering out __META__ key");
  16.           continue;

代码示例来源：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: voldemort/voldemort

  1. logger.warn("Get operation timed out after " + timeoutMs + " ms.");
  2.     continue;
  3.         throw (VoldemortException) getResult.exception;
  4.       failures.add(getResult.exception);
  5.       continue;
  6.     retrieved.add(getResult);
  7.   } catch(InterruptedException e) {
  8.     throw new InsufficientOperationalNodesException("Get operation interrupted!", e);
  9.       throw (Error) e.getCause();
  10.     else
  11.       logger.error(e.getMessage(), e);
  12. while(successes < this.storeDef.getPreferredReads() && nodeIndex < nodes.size()) {
  13.   Node node = nodes.get(nodeIndex);
  14.   long startNs = System.nanoTime();
  15.                     fetcher.execute(innerStores.get(node.getId()),
  16.                             key,
  17.                             transforms), null));
  18.     throw e;
  19.   } catch(Exception e) {
  20.     logger.warn("Error in GET on node " + node.getId() + "(" + node.getHost() + ")", e);

代码示例来源：origin: apache/incubator-gobblin

  1. if (null == queries || queries.size() == 0) {
  2.  log.warn("No queries specified to be executed");
  3.  return Collections.emptyList();
  4.   log.info("Executing query: " + query);
  5.   boolean result = statement.execute(query);
  6.   if (result) {
  7.    ResultSet resultSet = statement.getResultSet();
  8.    if (resultSet.next()) {
  9.     rowCounts.add(resultSet.getLong(1));
  10.    log.warn("Query output for: " + query + " : " + result);
  11.   closer.close();
  12.  } catch (Exception e) {
  13.   log.warn("Could not close HiveJdbcConnector", e);
  14.    statement.close();
  15.   } catch (SQLException e) {
  16.    log.warn("Could not close Hive statement", e);

代码示例来源：origin: marytts/marytts

  1. Element t;
  2. while ((t = (Element) tokenIt.nextNode()) != null) {
  3.   tokens.add(MaryDomUtils.tokenText(t));
  4. if (tokens.size() == 1) {
  5.   tokens.add(".");
  6.     String gpos = posMapper.get(pos);
  7.     if (gpos == null)
  8.       logger.warn("POS map file incomplete: do not know how to map '" + pos + "'");
  9.     else
  10.       pos = gpos;

代码示例来源：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.   attemptedByNode.put(node.getId(), 0L);
  5.   succeededByNode.put(node.getId(), 0L);
  6.         logger.info("Attempted pushing " + attemptedPushes + " slops");
  7.   logger.warn("Interrupted exception", e);
  8.   terminatedEarly = true;
  9. } catch(Exception e) {
  10.   logger.error(e, e);
  11.   terminatedEarly = true;
  12. } finally {
  13.       iterator.close();
  14.   } catch(Exception e) {
  15.     logger.warn("Failed to close iterator cleanly as database might be closed", e);
  16.       slopQueue.put(END);
  17.     } catch(InterruptedException e) {
  18.       logger.warn("Error putting poison pill", e);
  19.       result.get();
  20.     } catch(Exception e) {
  21.       logger.warn("Exception in consumer", e);

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

  1. public Map<Integer, Long> byZone() {
  2.   Map<Integer, Long> map = Maps.newHashMapWithExpectedSize(cluster.getNumberOfNodes());
  3.   for(Map.Entry<Integer, AtomicLong> entry: values.entrySet()) {
  4.     try {
  5.       Node node = cluster.getNodeById(entry.getKey());
  6.       int zoneId = node.getZoneId();
  7.       Long count = map.get(zoneId);
  8.       if(count == null)
  9.         count = 0L;
  10.       count += entry.getValue().get();
  11.       map.put(zoneId, count);
  12.     } catch(VoldemortException e) {
  13.       logger.warn("Can't get zone information for node id " + entry.getKey(), e);
  14.     }
  15.   }
  16.   return Collections.unmodifiableMap(map);
  17. }

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

  1. @Override
  2.   public void run() {
  3.     long startNs = System.nanoTime();
  4.     try {
  5.       boolean deleted = innerStores.get(node.getId()).delete(key, version);
  6.       successes.incrementAndGet();
  7.       deletedSomething.compareAndSet(false, deleted);
  8.       recordSuccess(node, startNs);
  9.     } catch(UnreachableStoreException e) {
  10.       failures.add(e);
  11.       recordException(node, startNs, e);
  12.     } catch(VoldemortApplicationException e) {
  13.       throw e;
  14.     } catch(Exception e) {
  15.       failures.add(e);
  16.       logger.warn("Error in DELETE on node " + node.getId() + "("
  17.                 + node.getHost() + ")",
  18.             e);
  19.     } finally {
  20.       // signal that the operation is complete
  21.       semaphore.release();
  22.     }
  23.   }
  24. });

代码示例来源：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.     if(logger.isDebugEnabled()) {
  17.       logger.debug("Commit successful");
  18.       logger.debug("calling checkpoint callback");
  19.       logger.warn("Checkpoint callback failed!", e1);
  20.     } catch(ExecutionException e1) {
  21.       logger.warn("Checkpoint callback failed during execution!", e1);

代码示例来源：origin: alibaba/mdrill

  1. @Override
  2. public void report_task_error(String stormId, int taskId, Throwable error) {
  3.   // add by ourself
  4.   LOG.warn(StormUtils.stringify_error(error));
  5.   String path = Cluster.taskerror_path(stormId, taskId);
  6.   cluster_state.mkdirs(path);
  7.   List<Integer> children = new ArrayList<Integer>();
  8.   for (String str : cluster_state.get_children(path, false)) {
  9.     children.add(Integer.parseInt(str));
  10.   }
  11.   Collections.sort(children);
  12.   while (children.size() >= 10) {
  13.     cluster_state.delete_node(path + "/" + children.remove(0));
  14.   }
  15.   String timestampPath = path + "/" + TimeUtils.current_time_secs();
  16.   byte[] errorData = new String(StormUtils.stringify_error(error))
  17.       .getBytes();
  18.   cluster_state.set_data(timestampPath, errorData);
  19. }

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

  1. VectorClock clock = new VectorClock();
  2. if(metadataCache.containsKey(ROUTING_STRATEGY_KEY))
  3.   clock = (VectorClock) metadataCache.get(ROUTING_STRATEGY_KEY).getVersion();
  4. logger.info("Updating routing strategy for all stores");
  5. HashMap<String, StoreDefinition> storeDefMap = makeStoreDefinitionMap(storeDefs);
  6. HashMap<String, RoutingStrategy> routingStrategyMap = createRoutingStrategyMap(cluster,
  7.                                         storeDefMap);
  8. this.metadataCache.put(ROUTING_STRATEGY_KEY,
  9.             new Versioned<Object>(routingStrategyMap,
  10.                        clock.incremented(getNodeId(),
  11.   if(updatedRoutingStrategy != null) {
  12.     try {
  13.       for(MetadataStoreListener listener: storeNameTolisteners.get(storeName)) {
  14.         listener.updateRoutingStrategy(updatedRoutingStrategy);
  15.         listener.updateStoreDefinition(storeDefMap.get(storeName));
  16.         logger.warn(e, e);

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

  1. fileSet.getIndexFileSize(chunk));
  2.   if(valueLocation >= 0)
  3.     keysAndValueLocations.add(new KeyValueLocation(chunk, key, valueLocation));
  4. } catch (IllegalStateException e) {
  5.   logger.warn("ChunkedFileSet.getChunkForKey() did not execute successfully for store '" +
  6.         getName() + "'. Skipping key in getAll: " + ByteUtils.toHexString(key.get()), e);
  7.   continue;
  8.                  keyVal.getValueLocation());
  9. if(value.length > 0)
  10.   results.put(keyVal.getKey(), Collections.singletonList(Versioned.value(value)));

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

  1. logger.error("Cannot stream more entries since Recovery Callback Failed!");
  2. throw new VoldemortException("Cannot stream more entries since Recovery Callback Failed! You Need to restart the session");
  3. if(blackListedNodes != null && blackListedNodes.size() > 0) {
  4.   if(blackListedNodes.contains(node.getId()))
  5.     continue;
  6.   nodesWithException++;
  7.   if(!faultyNodes.contains(node.getId()))
  8.     faultyNodes.add(node.getId());
  9. logger.warn("Invoking the Recovery Callback");
  10. Future future = streamingresults.submit(recoveryCallback);
  11. try {
  12.   logger.error("Recovery Callback failed", e1);
  13.   throw new VoldemortException("Recovery Callback failed");
  14. } catch(ExecutionException e1) {
  15.   MARKED_BAD = true;
  16.   logger.error("Recovery Callback failed during execution", e1);
  17.   throw new VoldemortException("Recovery Callback failed during execution");

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

  1. @Override
  2. public List<String> getURLsFromPage(Document doc) {
  3.   List<String> imageURLs = new ArrayList<>();
  4.   for (Element thumb : doc.select("div#gallery > div > a")) {
  5.     String imageURL = thumb.attr("href");
  6.     try {
  7.       Document imagedoc = new Http("http://imagearn.com/" + imageURL).get();
  8.       String image = imagedoc.select("a.thickbox").first().attr("href");
  9.       imageURLs.add(image);
  10.     } catch (IOException e) {
  11.       LOGGER.warn("Was unable to download page: " + imageURL);
  12.     }
  13.   }
  14.   return imageURLs;
  15. }

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com