diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/disruptor/TaskDisruptor.java b/fe/fe-core/src/main/java/org/apache/doris/job/disruptor/TaskDisruptor.java index a4855465f27a16..7a67e37485b41d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/disruptor/TaskDisruptor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/disruptor/TaskDisruptor.java @@ -100,7 +100,8 @@ public boolean publishEvent(Object... args) { // Timeout reached without publishing the event LOG.warn("Failed to publish event within the specified timeout (1 second)." - + "Queue may be full. size is {}", disruptor.getRingBuffer().remainingCapacity()); + + "Queue may be full. the remaining buffer size is {}", + disruptor.getRingBuffer().remainingCapacity()); } catch (Exception e) { // Catching general exceptions to handle unexpected errors LOG.warn("Failed to publish event due to an unexpected error", e);