本文整理了Java中io.airlift.log.Logger.error()
方法的一些代码示例,展示了Logger.error()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.error()
方法的具体详情如下:
包路径:io.airlift.log.Logger
类名称:Logger
方法名:error
[英]Logs a message at ERROR level.
[中]在错误级别记录消息。
代码示例来源:origin: prestodb/presto
public void cleanup()
{
int leakedSplits = localPartitionedSplitCount.getAndSet(0);
if (leakedSplits == 0) {
return;
}
log.error("BUG! %s for %s leaked with %s partitioned splits. Cleaning up so server can continue to function.",
getClass().getName(),
taskId,
leakedSplits);
nodeTotalPartitionedSplitCount.addAndGet(-leakedSplits);
}
代码示例来源:origin: prestodb/presto
private void scheduleRevoking()
{
taskManagementExecutor.execute(() -> {
try {
runMemoryRevoking();
}
catch (Throwable e) {
log.error(e, "Error requesting memory revoking");
}
});
}
代码示例来源:origin: prestodb/presto
private void cleanupQueryQuietly()
{
try {
metadata.cleanupQuery(session);
}
catch (Throwable t) {
QUERY_STATE_LOG.error("Error cleaning up query: %s", t);
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
static void logError(Throwable t, String format, Object... args)
{
if (isExpectedError(t)) {
log.error(format + ": %s", ObjectArrays.concat(args, t));
}
else {
log.error(t, format, args);
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
LOG.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
private void fireStateChangedListener(T newState, StateChangeListener<T> stateChangeListener)
{
try {
stateChangeListener.stateChanged(newState);
}
catch (Throwable e) {
log.error(e, "Error notifying state change listener for %s", name);
}
}
代码示例来源:origin: prestodb/presto
private static void safeAbort(ConnectorTransactionMetadata connection)
{
try {
connection.abort();
}
catch (Exception e) {
log.error(e, "Connector threw exception on abort");
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
private void registerPeriodicCheck()
{
this.scheduledFuture = taskManagementExecutor.scheduleWithFixedDelay(() -> {
try {
requestMemoryRevokingIfNeeded();
}
catch (Throwable e) {
log.error(e, "Error requesting system memory revoking");
}
}, 1, 1, SECONDS);
}
代码示例来源:origin: prestodb/presto
@Override
public void shutdown()
{
try {
jmxPeriodicSampler.shutdown();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public void run()
{
try {
runUnsafe();
}
catch (Exception exception) {
// Do not swallow even weirdest exceptions
log.error(exception, "This should never happen, JmxPeriodicSampler will not be scheduled again.");
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
@Override
public final void shutdown()
{
try {
lifeCycleManager.stop();
}
catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}
}
代码示例来源:origin: prestodb/presto
public void destroy()
{
destroyed.set(true);
try {
split.close();
}
catch (RuntimeException e) {
log.error(e, "Error closing split for task %s", taskHandle.getTaskId());
}
}
代码示例来源:origin: prestodb/presto
private void scheduleIdleChecks(Duration idleCheckInterval, ScheduledExecutorService idleCheckExecutor)
{
idleCheckExecutor.scheduleWithFixedDelay(() -> {
try {
cleanUpExpiredTransactions();
}
catch (Throwable t) {
log.error(t, "Unexpected exception while cleaning up expired transactions");
}
}, idleCheckInterval.toMillis(), idleCheckInterval.toMillis(), MILLISECONDS);
}
内容来源于网络,如有侵权,请联系作者删除!