fix ingestion pause state initialization on replica promotion

varunbharadwaj · varunbharadwaj · commit 73456b3bde11 · 2025-09-01T23:42:35.000-07:00
Signed-off-by: Varun Bharadwaj &lt;varunbharadwaj1995@gmail.com&gt;
diff --git a/server/src/main/java/org/opensearch/indices/pollingingest/DefaultStreamPoller.java b/server/src/main/java/org/opensearch/indices/pollingingest/DefaultStreamPoller.java
@@ -157,6 +157,8 @@ private DefaultStreamPoller(
         this.errorStrategy = errorStrategy;
         this.indexName = indexSettings.getIndex().getName();
 
+        // handle initial poller states
+        this.paused = initialState == State.PAUSED;
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -157,6 +157,8 @@ private DefaultStreamPoller(`
`157`	`157`	`this.errorStrategy = errorStrategy;`
`158`	`158`	`this.indexName = indexSettings.getIndex().getName();`
`159`	`159`
	`160`	`+ // handle initial poller states`
	`161`	`+ this.paused = initialState == State.PAUSED;`
`160`	`162`	`}`
`161`	`163`
`162`	`164`	`@Override`