audit message missing for autostop

call onStop when auto stopping (#43984)

fixes #43977
This commit is contained in:
Hendrik Muhs 2019-07-04 21:39:24 +02:00
parent 688bf1b388
commit 4128b9b4f7
1 changed files with 2 additions and 1 deletions

View File

@ -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