From 280a2c940127fc50885defce2aaf2403b753774c Mon Sep 17 00:00:00 2001
From: Hendrik Muhs <hendrik.muhs@elastic.co>
Date: Thu, 6 Jun 2019 07:45:36 +0200
Subject: [PATCH] [ML-DataFrame] reduce log spam: do not trigger indexer if
 state is indexing or stopping (#42849)

reduce log spam: do not trigger indexer if state is indexing or stopping
---
 .../xpack/dataframe/transforms/DataFrameTransformTask.java | 7 +++++++
 1 file changed, 7 insertions(+)

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 512f3613e90..b3464b72471 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
@@ -517,6 +517,13 @@ public class DataFrameTransformTask extends AllocatedPersistentTask implements S
                 return false;
             }
 
+            // ignore trigger if indexer is running, prevents log spam in A2P indexer
+            IndexerState indexerState = getState();
+            if (IndexerState.INDEXING.equals(indexerState) || IndexerState.STOPPING.equals(indexerState)) {
+                logger.debug("Indexer for transform [{}] has state [{}], ignoring trigger", getJobId(), indexerState);
+                return false;
+            }
+
             return super.maybeTriggerAsyncJob(now);
         }