Segment handoffs should use the allocated partition number

apache · Sep 27, 2017 · 5ef8fa5 · 5ef8fa5
1 parent 1205217
commit 5ef8fa5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
@@ -492,7 +492,7 @@ public void doRun()
         }
     );
     handoffNotifier.registerSegmentHandoffCallback(
-        new SegmentDescriptor(sink.getInterval(), sink.getVersion(), config.getShardSpec().getPartitionNum()),
+        new SegmentDescriptor(sink.getInterval(), sink.getVersion(), identifier.getShardSpec().getPartitionNum()),
         mergeExecutor, new Runnable()
         {
           @Override