fixing getTimeToLive

masseyke · masseyke · commit 02a1e648c3df · 2025-03-25T15:26:13.000-05:00
diff --git a/x-pack/plugin/migrate/src/main/java/org/elasticsearch/xpack/migrate/task/ReindexDataStreamPersistentTaskExecutor.java b/x-pack/plugin/migrate/src/main/java/org/elasticsearch/xpack/migrate/task/ReindexDataStreamPersistentTaskExecutor.java
@@ -367,7 +367,7 @@ private TimeValue updateCompletionTimeAndGetTimeToLive(
 
     private TimeValue getTimeToLive(long completionTimeInMillis) {
         return TimeValue.timeValueMillis(
-            TASK_KEEP_ALIVE_TIME.millis() - Math.max(
+            TASK_KEEP_ALIVE_TIME.millis() - Math.min(
                 TASK_KEEP_ALIVE_TIME.millis(),
                 threadPool.absoluteTimeInMillis() - completionTimeInMillis
             )

Original file line number	Diff line number	Diff line change
`@@ -367,7 +367,7 @@ private TimeValue updateCompletionTimeAndGetTimeToLive(`
`367`	`367`
`368`	`368`	`private TimeValue getTimeToLive(long completionTimeInMillis) {`
`369`	`369`	`return TimeValue.timeValueMillis(`
`370`		`- TASK_KEEP_ALIVE_TIME.millis() - Math.max(`
	`370`	`+ TASK_KEEP_ALIVE_TIME.millis() - Math.min(`
`371`	`371`	`TASK_KEEP_ALIVE_TIME.millis(),`
`372`	`372`	`threadPool.absoluteTimeInMillis() - completionTimeInMillis`
`373`	`373`	`)`