Skip to content

Commit 640287c

Browse files
committed
Revert "Formattin"
This reverts commit 5936fd0.
1 parent 5936fd0 commit 640287c

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

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

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -3354,17 +3354,17 @@ 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-
)
3361-
.forEach(entry -> {
3362-
Integer groupId = entry.getKey();
3363-
TaskGroup group = entry.getValue();
3364-
3365-
final DateTime earliestTaskStart = computeEarliestTaskStartTime(group);
3366-
final Duration runDuration = Duration.millis(DateTimes.nowUtc().getMillis() - earliestTaskStart.getMillis());
3367-
if (stopTasksEarly || group.getHandoffEarly()) {
3357+
Comparator.comparingLong(
3358+
taskGroupEntry -> computeEarliestTaskStartTime(taskGroupEntry.getValue()).getMillis()
3359+
)
3360+
)
3361+
.forEach(entry -> {
3362+
Integer groupId = entry.getKey();
3363+
TaskGroup group = entry.getValue();
3364+
3365+
final DateTime earliestTaskStart = computeEarliestTaskStartTime(group);
3366+
final Duration runDuration = Duration.millis(DateTimes.nowUtc().getMillis() - earliestTaskStart.getMillis());
3367+
if (stopTasksEarly || group.getHandoffEarly()) {
33683368
// If handoffEarly has been set, stop tasks irrespective of stopTaskCount
33693369
log.info(
33703370
"Stopping taskGroup[%d] early after running for duration[%s].",

0 commit comments

Comments
 (0)