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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
