From da3a1f61ac1f89795ba22321a2ae77f0927941c6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Karol=20Wo=C5=BAniak?= <wozniakk@gmail.com>
Date: Sat, 11 Aug 2018 07:29:06 +0200
Subject: [PATCH] Fix appenderator_realtime creating shards bigger by 1 than
 maxRowsPerSegment (#6125)

---
 .../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 c1ee50b23e9..9a0ea65175e 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++;