try {
result = monitor.get();
} catch (InterruptedException | ExecutionException e) {
+ LOG.warn("Failed to monitor {}", dbSchema, e);
return null;
}
return transformingCallback(result, dbSchema);
try {
result = monitor.get();
} catch (InterruptedException | ExecutionException e) {
+ LOG.warn("Failed to monitor {}", dbSchema, e);
return null;
}
return transformingCallback(result, dbSchema);
try {
result = cancelMonitor.get();
} catch (InterruptedException | ExecutionException e) {
- LOG.error("Exception when canceling monitor handler {}", handler.getId());
+ LOG.error("Exception when canceling monitor handler {}", handler.getId(), e);
}
if (result == null) {
sfuture.set(schema);
}
} catch (Exception e) {
+ LOG.warn("Failed to populate schema {}:{}", dbNames, schema, e);
sfuture.setException(e);
}
return null;