Skip to content

Commit 7370d1b

Browse files
authored
Do not wait for the transform persistent task to disappear (#96060)
1 parent f1c94af commit 7370d1b

File tree

1 file changed

+0
-13
lines changed
  • x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/transforms

1 file changed

+0
-13
lines changed

x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/transforms/TransformTask.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import org.elasticsearch.common.Strings;
2020
import org.elasticsearch.common.regex.Regex;
2121
import org.elasticsearch.persistent.AllocatedPersistentTask;
22-
import org.elasticsearch.persistent.PersistentTaskParams;
2322
import org.elasticsearch.persistent.PersistentTasksCustomMetadata;
2423
import org.elasticsearch.persistent.PersistentTasksCustomMetadata.PersistentTask;
2524
import org.elasticsearch.persistent.PersistentTasksService;
@@ -48,7 +47,6 @@
4847
import java.util.Collection;
4948
import java.util.Collections;
5049
import java.util.Map;
51-
import java.util.Objects;
5250
import java.util.Set;
5351
import java.util.function.Predicate;
5452

@@ -466,17 +464,6 @@ public void shutdown() {
466464
logger.debug("[{}] shutdown of transform requested", transform.getId());
467465
transformScheduler.deregisterTransform(getTransformId());
468466
markAsCompleted();
469-
waitForPersistentTask(Objects::isNull, null, new PersistentTasksService.WaitForPersistentTaskListener<>() {
470-
@Override
471-
public void onResponse(PersistentTask<PersistentTaskParams> persistentTask) {
472-
logger.trace("[{}] successfully finished waiting for persistent task to disappear.", transform.getId());
473-
}
474-
475-
@Override
476-
public void onFailure(Exception e) {
477-
logger.error(() -> "[" + transform.getId() + "] failure while waiting for persistent task to disappear.", e);
478-
}
479-
});
480467
}
481468

482469
void persistStateToClusterState(TransformState state, ActionListener<PersistentTask<?>> listener) {

0 commit comments

Comments
 (0)