Skip to content

Commit 70baf0d

Browse files
[ML] Remove timeout on waiting for DF analytics result processor to complete (#45724)
We cannot know how long the analysis will take to complete thus we should not have a timeout. Note that if the process crashes, the result processor will pick the exception due to the stream closing. Closes #45723
1 parent 1930267 commit 70baf0d

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/dataframe/process/AnalyticsResultProcessor.java

+2-5
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
import java.util.Iterator;
1616
import java.util.Objects;
1717
import java.util.concurrent.CountDownLatch;
18-
import java.util.concurrent.TimeUnit;
1918
import java.util.function.Consumer;
2019
import java.util.function.Supplier;
2120

@@ -45,12 +44,10 @@ public String getFailure() {
4544

4645
public void awaitForCompletion() {
4746
try {
48-
if (completionLatch.await(30, TimeUnit.MINUTES) == false) {
49-
LOGGER.warn("[{}] Timeout waiting for results processor to complete", dataFrameAnalyticsId);
50-
}
47+
completionLatch.await();
5148
} catch (InterruptedException e) {
5249
Thread.currentThread().interrupt();
53-
LOGGER.info("[{}] Interrupted waiting for results processor to complete", dataFrameAnalyticsId);
50+
LOGGER.error(new ParameterizedMessage("[{}] Interrupted waiting for results processor to complete", dataFrameAnalyticsId), e);
5451
}
5552
}
5653

0 commit comments

Comments
 (0)