[incubator-druid] branch master updated: Fix appenderator_realtime creating shards bigger by 1 than maxRowsPerSegment (#6125)

[jihoonson]

This is an automated email from the ASF dual-hosted git repository.

jihoonson pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git


The following commit(s) were added to refs/heads/master by this push:
     new da3a1f6  Fix appenderator_realtime creating shards bigger by 1 than 
maxRowsPerSegment (#6125)
da3a1f6 is described below

commit da3a1f61ac1f89795ba22321a2ae77f0927941c6
Author: Karol Woźniak <wozni...@gmail.com>
AuthorDate: Sat Aug 11 07:29:06 2018 +0200

    Fix appenderator_realtime creating shards bigger by 1 than 
maxRowsPerSegment (#6125)
---
 .../druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/indexing-service/src/main/java/io/druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java
 
b/indexing-service/src/main/java/io/druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java
index c1ee50b..9a0ea65 100644
--- 
a/indexing-service/src/main/java/io/druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java
+++ 
b/indexing-service/src/main/java/io/druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java
@@ -322,7 +322,7 @@ public class AppenderatorDriverRealtimeIndexTask extends 
AbstractTask implements
             AppenderatorDriverAddResult addResult = driver.add(inputRow, 
sequenceName, committerSupplier);
 
             if (addResult.isOk()) {
-              if (addResult.getNumRowsInSegment() > 
tuningConfig.getMaxRowsPerSegment()) {
+              if (addResult.getNumRowsInSegment() >= 
tuningConfig.getMaxRowsPerSegment()) {
                 publishSegments(driver, publisher, committerSupplier, 
sequenceName);
 
                 sequenceNumber++;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org