testing primary first

Signed-off-by: Joshua Palis <[email protected]>
opensearch-project · Sep 5, 2023 · 01e8dec · 01e8dec
1 parent 19b777a
commit 01e8dec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java b/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java
@@ -389,7 +389,7 @@ private void sweepShard(ShardId shardId, ShardNodes shardNodes, String startAfte
         String searchAfter = startAfter == null ? "" : startAfter;
         while (searchAfter != null) {
             SearchRequest jobSearchRequest = new SearchRequest().indices(shardId.getIndexName())
-                .preference("_shards:" + shardId.id() + "|_primary")
+                .preference("_shards:" + shardId.id() + "|_primary_first")
                 .source(
                     new SearchSourceBuilder().version(true)
                         .seqNoAndPrimaryTerm(true)