From 4128b9b4f795b0fe30a2b74ab32311607a8c10d7 Mon Sep 17 00:00:00 2001 From: Hendrik Muhs Date: Thu, 4 Jul 2019 21:39:24 +0200 Subject: [PATCH] audit message missing for autostop call onStop when auto stopping (#43984) fixes #43977 --- .../xpack/dataframe/transforms/DataFrameTransformTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/x-pack/plugin/data-frame/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java b/x-pack/plugin/data-frame/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java index a30b726b3d2..ea67da79620 100644 --- a/x-pack/plugin/data-frame/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java +++ b/x-pack/plugin/data-frame/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java @@ -657,6 +657,7 @@ public class DataFrameTransformTask extends AllocatedPersistentTask implements S r -> { // for auto stop shutdown the task if (state.getTaskState().equals(DataFrameTransformTaskState.STOPPED)) { + onStop(); transformTask.shutdown(); } next.run(); @@ -715,7 +716,7 @@ public class DataFrameTransformTask extends AllocatedPersistentTask implements S @Override protected void onStop() { auditor.info(transformConfig.getId(), "Data frame transform has stopped."); - logger.info("Data frame transform [{}] indexer has stopped", transformConfig.getId()); + logger.info("Data frame transform [{}] has stopped", transformConfig.getId()); } @Override