Skip to content

Commit 2719a17

Browse files
committed
Formatting
1 parent 7788e38 commit 2719a17

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3354,10 +3354,10 @@ private void checkTaskDuration() throws ExecutionException, InterruptedException
33543354
// Sort task groups by start time to prioritize early termination of earlier groups, then iterate for processing
33553355
// Sort task groups by start time to prioritize early termination of earlier groups, then iterate for processing
33563356
activelyReadingTaskGroups.entrySet().stream().sorted(
3357-
Comparator.comparingLong(
3358-
taskGroupEntry -> computeEarliestTaskStartTime(taskGroupEntry.getValue()).getMillis()
3359-
)
3360-
)
3357+
Comparator.comparingLong(
3358+
taskGroupEntry -> computeEarliestTaskStartTime(taskGroupEntry.getValue()).getMillis()
3359+
)
3360+
)
33613361
.forEach(entry -> {
33623362
Integer groupId = entry.getKey();
33633363
TaskGroup group = entry.getValue();

0 commit comments

Comments
 (0)