[ML-DataFrame] reduce log spam: do not trigger indexer if state is in…

…dexing or stopping (#42849) reduce log spam: do not trigger indexer if state is indexing or stopping
elastic · Jun 7, 2019 · 4383704 · 4383704
1 parent baf90ba
commit 4383704
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...me/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java b/...me/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java
@@ -517,6 +517,13 @@ public synchronized boolean maybeTriggerAsyncJob(long now) {
                 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);
         }