Skip to content

Commit 2d8ba11

Browse files
committed
Use the existing method to cleanup allocation info to force partition re-assignment during the rollover
1 parent d6894c7 commit 2d8ba11

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3443,9 +3443,7 @@ private void checkTaskDuration() throws ExecutionException, InterruptedException
34433443
changeTaskCountInIOConfig(rolloverTaskCount);
34443444
// Here force reset the supervisor state to be re-calculated on the next iteration of runInternal() call.
34453445
// This seems the best way to inject task amount recalculation during the rollover.
3446-
partitionGroups.clear();
3447-
partitionOffsets.clear();
3448-
partitionIds.clear();
3446+
clearAllocationInfo();
34493447
}
34503448
}
34513449
}

0 commit comments

Comments
 (0)