diff --git a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java index 6f98817030e..7852500c7b8 100644 --- a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java +++ b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java @@ -323,7 +323,7 @@ public class AppenderatorImpl implements Appenderator if (bytesCurrentlyInMemory.get() >= maxBytesTuningConfig) { persist = true; persistReasons.add(StringUtils.format( - "bytesCurrentlyInMemory[%d] is greater than maxBytesInMemory[%d]", + "(estimated) bytesCurrentlyInMemory[%d] is greater than maxBytesInMemory[%d]", bytesCurrentlyInMemory.get(), maxBytesTuningConfig )); @@ -669,7 +669,7 @@ public class AppenderatorImpl implements Appenderator rowsCurrentlyInMemory.addAndGet(-numPersistedRows); bytesCurrentlyInMemory.addAndGet(-bytesPersisted); - log.info("Persisted rows[%,d] and bytes[%,d]", numPersistedRows, bytesPersisted); + log.info("Persisted rows[%,d] and (estimated) bytes[%,d]", numPersistedRows, bytesPersisted); return future; }