Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This commit is contained in:
Clint Wylie 2021-05-05 02:44:04 -07:00 committed by GitHub
parent 99f39c7202
commit 6f0b4d90d8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -323,7 +323,7 @@ public class AppenderatorImpl implements Appenderator
if (bytesCurrentlyInMemory.get() >= maxBytesTuningConfig) { if (bytesCurrentlyInMemory.get() >= maxBytesTuningConfig) {
persist = true; persist = true;
persistReasons.add(StringUtils.format( persistReasons.add(StringUtils.format(
"bytesCurrentlyInMemory[%d] is greater than maxBytesInMemory[%d]", "(estimated) bytesCurrentlyInMemory[%d] is greater than maxBytesInMemory[%d]",
bytesCurrentlyInMemory.get(), bytesCurrentlyInMemory.get(),
maxBytesTuningConfig maxBytesTuningConfig
)); ));
@ -669,7 +669,7 @@ public class AppenderatorImpl implements Appenderator
rowsCurrentlyInMemory.addAndGet(-numPersistedRows); rowsCurrentlyInMemory.addAndGet(-numPersistedRows);
bytesCurrentlyInMemory.addAndGet(-bytesPersisted); 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; return future;
} }