Skip to content

Commit e1ff8a0

Browse files
committed
making sure time is not negative
1 parent 1a7a56e commit e1ff8a0

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

x-pack/plugin/migrate/src/main/java/org/elasticsearch/xpack/migrate/task/ReindexDataStreamPersistentTaskExecutor.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,6 +366,11 @@ private TimeValue updateCompletionTimeAndGetTimeToLive(
366366
}
367367

368368
private TimeValue getTimeToLive(long completionTimeInMillis) {
369-
return TimeValue.timeValueMillis(TASK_KEEP_ALIVE_TIME.millis() - (threadPool.absoluteTimeInMillis() - completionTimeInMillis));
369+
return TimeValue.timeValueMillis(
370+
TASK_KEEP_ALIVE_TIME.millis() - Math.max(
371+
TASK_KEEP_ALIVE_TIME.millis(),
372+
threadPool.absoluteTimeInMillis() - completionTimeInMillis
373+
)
374+
);
370375
}
371376
}

0 commit comments

Comments
 (0)