commit 6f0b4d90d8640328daf6ed72fbc3e2d28f7e4925
author Clint Wylie <cwylie@apache.org> Wed May 05 02:44:04 2021 -0700
committer GitHub <noreply@github.com> Wed May 05 17:44:04 2021 +0800
tree 00fc60950b13ea75ec22e5573045ca59ef8a2b19
parent 99f39c720261923a4f908ad2ae33b03b372989b0

clarify that appenderator persist byte sizes are estimations (#11198)

server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java

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 6f98817..7852500 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 @@
     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 @@
     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;
   }