Setting JobSweeper search preference against primary shard (#483)

* Setting sweepShard search request against primary shard Signed-off-by: Joshua Palis <[email protected]> * testing primary first Signed-off-by: Joshua Palis <[email protected]> * reverting back to primary Signed-off-by: Joshua Palis <[email protected]> * setting fail fast to false Signed-off-by: Joshua Palis <[email protected]> --------- Signed-off-by: Joshua Palis <[email protected]>
opensearch-project · Sep 6, 2023 · c1e2569 · c1e2569
1 parent 886fa11
commit c1e2569
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -10,6 +10,7 @@ on:
 jobs:
   build:
     strategy:
+      fail-fast: false
       matrix:
         os: [ubuntu-latest, windows-latest, macos-latest]
         java: [11, 17]

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() + "|_only_local")
+                .preference("_shards:" + shardId.id() + "|_primary")
                 .source(
                     new SearchSourceBuilder().version(true)
                         .seqNoAndPrimaryTerm(true)