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

Logger.error介绍

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

代码示例

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

@Override
public void onException(Exception ex)
{
 log.error(ex, "Got exception");
}

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

@Override
 public void exceptionCaught(ClientResponse<StatusResponseHolder> clientResponse, Throwable e)
 {
  // Its safe to Ignore as the ClientResponse returned in handleChunk were unfinished
  log.error(e, "exceptionCaught in CommonCacheNotifier ResponseHandler.");
 }
}

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

@Override
 public void handle(Exception exception)
 {
  if (exceptionCount % 1000 == 0) {
   log.error(exception, "Error sending metric to StatsD.");
  }
  exceptionCount += 1;
 }
}

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

@Override
public void lifeCycleFailure(LifeCycle event, Throwable cause)
{
 log.error(cause, "Jetty lifecycle event failed [%s]", event.getClass());
}

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

private void safeSchedule(Runnable runnable, String errMsgFormat, Object... args)
{
 listenerExecutor.submit(() -> {
  try {
   runnable.run();
  }
  catch (Exception ex) {
   log.error(errMsgFormat, args);
  }
 });
}

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

public void enqueue(OpentsdbEvent event)
{
 if (!eventQueue.offer(event)) {
  if (countLostEvents.getAndIncrement() % 1000 == 0) {
   log.error(
     "Lost total of [%s] events because of emitter queue is full. Please increase the capacity.",
     countLostEvents.get()
   );
  }
 }
}

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

public void write(Map<String, TaskReport> reports)
{
 try {
  final File reportsFileParent = reportsFile.getParentFile();
  if (reportsFileParent != null) {
   FileUtils.forceMkdir(reportsFileParent);
  }
  objectMapper.writeValue(reportsFile, reports);
 }
 catch (Exception e) {
  log.error(e, "Encountered exception in write().");
 }
}

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

@Override
 public void onFailure(Throwable t)
 {
  // this callback is called only when there were some problems in TaskMonitor.
  log.error(t, "Error while running a task for subTaskSpec[%s]", spec);
  taskCompleteEvents.offer(SubTaskCompleteEvent.fail(spec, t));
 }
}

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

public void stop()
 {
  try {
   cache.close();
   cacheExecutor.shutdownNow();
  }
  catch (Exception ex) {
   log.error(ex, "Failed to stop node watcher for type [%s].", nodeType);
  }
 }
}

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

@Override
 public void stop()
 {
  log.info("Closing object[%s]", o);
  try {
   o.close();
  }
  catch (Exception e) {
   log.error(e, "Exception when closing object [%s]", o);
  }
 }
}

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

private void deleteWithRetriesSilent(final String s3Bucket, final String s3Path)
{
 try {
  deleteWithRetries(s3Bucket, s3Path);
 }
 catch (Exception e) {
  log.error(e, "Failed to delete file [s3://%s/%s], giving up", s3Bucket, s3Path);
 }
}

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

@Override
 public void stop()
 {
  log.info("Stopping object[%s]", o);
  try {
   stopMethod.invoke(o);
  }
  catch (Exception e) {
   log.error(e, "Unable to invoke stopMethod() on %s", o.getClass());
  }
 }
}

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

@Override
 public MemcachedClientIF get()
 {
  try {
   return new MemcachedClient(connectionFactory, hosts);
  }
  catch (IOException e) {
   log.error(e, "Unable to create memcached client");
   throw Throwables.propagate(e);
  }
 }
}

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

@GET
@Produces({MediaType.APPLICATION_JSON, SmileMediaTypes.APPLICATION_JACKSON_SMILE})
public Response getAll()
{
 try {
  return handler.handleGETAll();
 }
 catch (Exception e) {
  LOG.error(e, "Exception in handling GETAll request");
  return Response.serverError().entity(ServletResourceUtils.sanitizeException(e)).build();
 }
}

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

private void limitFailedBuffersSize()
{
 if (failedBuffers.size() >= config.getBatchQueueSizeLimit()) {
  failedBuffers.removeFirst();
  approximateFailedBuffersCount.decrementAndGet();
  droppedBuffers.incrementAndGet();
  log.error(
    "failedBuffers queue size reached the limit [%d], dropping the oldest failed buffer",
    config.getBatchQueueSizeLimit()
  );
 }
}

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

@Override
public void close()
{
 if (!doClose(true)) {
  log.error("Cache for %s has already been closed", this);
 }
 // This Cleaner.clean() call effectively just removes the Cleaner from the internal linked list of all cleaners.
 // It will delegate to closeFromCleaner() which will be a no-op because cacheStateHolder is already set to
 // ENTRY_CLOSED.
 entryCleaner.clean();
}

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

@Override
public <T> QueryRunner<T> getQueryRunner(DruidServer server)
{
 synchronized (lock) {
  QueryableDruidServer queryableDruidServer = clients.get(server.getName());
  if (queryableDruidServer == null) {
   log.error("WTF?! No QueryableDruidServer found for %s", server.getName());
   return null;
  }
  return queryableDruidServer.getClient();
 }
}

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

private SwapStats()
{
 try {
  Swap swap = sigar.getSwap();
  this.prevPageIn = swap.getPageIn();
  this.prevPageOut = swap.getPageOut();
 }
 catch (SigarException e) {
  log.error(e, "Failed to get Swap");
 }
}

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

@Provides
@Processing
@ManageLifecycle
public ExecutorService getProcessingExecutorService(DruidProcessingConfig config)
{
 if (config.getNumThreadsConfigured() != ExecutorServiceConfig.DEFAULT_NUM_THREADS) {
  log.error("numThreads[%d] configured, that is ignored on Router", config.getNumThreadsConfigured());
 }
 return Execs.dummy();
}

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

@SuppressWarnings("MalformedFormatString")
 @Test
 public void testLegacyLogging()
 {
  final Logger log = new Logger(LoggerTest.class);
  final Throwable throwable = new Throwable();
  // These should show up in an IDE as deprecated, but shouldn't actually fail.
  log.error("foo", throwable);
  log.warn("foo", throwable);
 }
}