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

Logger.warn介绍

[英]Protect against assuming slf4j convention. use warn(Throwable t, String message, Object... formatArgs) instead
[中]防止采用slf4j公约。使用“warn（Throwable t，String message，Object…formatArgs）”代替

代码示例

代码示例来源：origin: io.druid/druid-indexing-hadoop

@Override
 public void abortTask(TaskAttemptContext taskContext) throws IOException
 {
  log.warn("Aborting task. Nothing to clean up.");
 }
};

代码示例来源：origin: io.druid.extensions/druid-examples

@Override
 public void onStallWarning(StallWarning warning)
 {
  log.warn("Got stall warning: %s", warning);
 }
};

代码示例来源：origin: io.druid.extensions/druid-examples

@Override
public void onTrackLimitationNotice(int numberOfLimitedStatuses)
{
 // This notice will be sent each time a limited stream becomes unlimited.
 // If this number is high and or rapidly increasing, it is an indication that your predicate is too broad, and you should consider a predicate with higher selectivity.
 log.warn("Got track limitation notice:" + numberOfLimitedStatuses);
}

代码示例来源：origin: io.druid/druid-server

@Override
 public void run()
 {
  final int shouldBeZero = count.get();
  if (shouldBeZero != 0) {
   leakedClients.incrementAndGet();
   log.warn("Expected 0 resource count, got [%d]! Object was[%s].", shouldBeZero, clientIF);
  }
 }
}

代码示例来源：origin: io.druid/druid-processing

public void delete(final File file)
{
 synchronized (files) {
  if (files.contains(file)) {
   try {
    Files.delete(file.toPath());
   }
   catch (IOException e) {
    log.warn(e, "Cannot delete file: %s", file);
   }
   files.remove(file);
  }
 }
}

代码示例来源：origin: io.druid/java-util

@Override
 public InputStream nextElement()
 {
  try {
   return queue.take();
  }
  catch (InterruptedException e) {
   log.warn(e, "Thread interrupted while taking from queue");
   Thread.currentThread().interrupt();
   throw Throwables.propagate(e);
  }
 }
}

代码示例来源：origin: io.druid/druid-server

public void unregister(String serviceName)
 {
  log.info("Unregistering EventReceiverFirehoseMetric for service [%s]", serviceName);
  if (metrics.remove(serviceName) == null) {
   log.warn("Unregistering a non-exist service. Service [%s] never exists.", serviceName);
  }
 }
}

代码示例来源：origin: io.druid/druid-server

@Override
 public void stop()
 {
  try {
   log.info("Stopping Jetty Server...");
   server.stop();
  }
  catch (Exception e) {
   log.warn(e, "Unable to stop Jetty server.");
  }
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
public void close()
{
 for (BufferAggregator aggregator : aggregators) {
  try {
   aggregator.close();
  }
  catch (Exception e) {
   log.warn(e, "Could not close aggregator [%s], skipping.", aggregator);
  }
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
public void close()
{
 for (BufferAggregator aggregator : aggregators) {
  try {
   aggregator.close();
  }
  catch (Exception e) {
   LOG.warn(e, "Could not close aggregator [%s], skipping.", aggregator);
  }
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
public void close()
{
 for (BufferAggregator aggregator : aggregators) {
  try {
   aggregator.close();
  }
  catch (Exception e) {
   LOG.warn(e, "Could not close aggregator [%s], skipping.", aggregator);
  }
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public void close()
 {
  if (mergeBuffersHolder != null) {
   if (mergeBuffers.size() != mergeBuffersHolder.get().size()) {
    log.warn("%d resources are not returned yet", mergeBuffersHolder.get().size() - mergeBuffers.size());
   }
   mergeBuffersHolder.close();
  }
 }
}

代码示例来源：origin: io.druid/druid-server

private byte[] getZkDataForNode(String path)
{
 try {
  return curatorFramework.getData().decompressed().forPath(path);
 }
 catch (Exception ex) {
  log.warn(ex, "Exception while getting data for node %s", path);
  return null;
 }
}

代码示例来源：origin: io.druid/druid-processing

static List<String> getMergedDimensions(List<IndexableAdapter> indexes)
{
 if (indexes.size() == 0) {
  return ImmutableList.of();
 }
 List<String> commonDimOrder = getLongestSharedDimOrder(indexes);
 if (commonDimOrder == null) {
  log.warn("Indexes have incompatible dimension orders, using lexicographic order.");
  return getLexicographicMergedDimensions(indexes);
 } else {
  return commonDimOrder;
 }
}

代码示例来源：origin: io.druid/java-util

private static void awaitNextRetry(final Throwable e, final int nTry, final boolean quiet) throws InterruptedException
{
 final long sleepMillis = nextRetrySleepMillis(nTry);
 if (quiet) {
  log.debug(e, "Failed on try %d, retrying in %,dms.", nTry, sleepMillis);
 } else {
  log.warn(e, "Failed on try %d, retrying in %,dms.", nTry, sleepMillis);
 }
 Thread.sleep(sleepMillis);
}

代码示例来源：origin: io.druid/java-util

@Override
public void returnResource()
{
 if (returned.getAndSet(true)) {
  log.warn(StringUtils.format("Resource at key[%s] was returned multiple times?", key));
 } else {
  holder.giveBack(value);
 }
}

代码示例来源：origin: io.druid/druid-server

private QueryableDruidServer addServer(DruidServer server)
{
 QueryableDruidServer retVal = new QueryableDruidServer(server, makeDirectClient(server));
 QueryableDruidServer exists = clients.put(server.getName(), retVal);
 if (exists != null) {
  log.warn("QueryRunner for server[%s] already existed!? Well it's getting replaced", server);
 }
 return retVal;
}

代码示例来源：origin: io.druid/druid-indexing-service

public void removeTaskRunZnode(String taskId) throws Exception
{
 try {
  curatorFramework.delete().guaranteed().forPath(getTaskPathForId(taskId));
 }
 catch (KeeperException e) {
  log.warn(e, "Could not delete task path for task[%s]", taskId);
 }
}

代码示例来源：origin: io.druid/druid-indexing-hadoop

private static String getType(String metric, AggregatorFactory[] aggs, int i)
{
 if (aggs[i].getName().equals(metric)) {
  return aggs[i].getTypeName();
 }
 log.warn("Aggs disordered, fall backs to loop.");
 for (AggregatorFactory agg : aggs) {
  if (agg.getName().equals(metric)) {
   return agg.getTypeName();
  }
 }
 return null;
}

代码示例来源：origin: io.druid/druid-server

@LifecycleStop
 public void stop()
 {
  if (log4jShutdown != null) {
   log.debug("Shutting down log4j");
   log4jShutdown.stop();
  } else {
   log.warn("Log4j shutdown was registered in lifecycle but no shutdown object exists!");
  }
 }
}