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

Fix appenderator_realtime creating shards bigger by 1 than maxRowsPerSegment (#6125)

This commit is contained in:
Karol Woźniak 2018-08-11 07:29:06 +02:00 committed by Jihoon Son
parent ecee3e0a24
commit da3a1f61ac
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
indexing-service/src/main/java/io/druid/indexing/common/task/AppenderatorDriverRealtimeIndexTask.java
View File

@ -322,7 +322,7 @@ public class AppenderatorDriverRealtimeIndexTask extends AbstractTask implements
AppenderatorDriverAddResult addResult = driver.add(inputRow, sequenceName, committerSupplier); AppenderatorDriverAddResult addResult = driver.add(inputRow, sequenceName, committerSupplier);
if (addResult.isOk()) { if (addResult.isOk()) {
if (addResult.getNumRowsInSegment() > tuningConfig.getMaxRowsPerSegment()) { if (addResult.getNumRowsInSegment() >= tuningConfig.getMaxRowsPerSegment()) {
publishSegments(driver, publisher, committerSupplier, sequenceName); publishSegments(driver, publisher, committerSupplier, sequenceName);
sequenceNumber++; sequenceNumber++;