File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
server/src/main/java/org/opensearch/index/seqno Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -1254,8 +1254,9 @@ public ReplicationCheckpoint getLatestReplicationCheckpoint() {
12541254
12551255 // skip any shard that is a relocating primary or search only replica (not tracked by primary)
12561256 private boolean shouldSkipReplicationTimer (String allocationId ) {
1257- Optional <ShardRouting > shardRouting = routingTable .shards ()
1257+ Optional <ShardRouting > shardRouting = routingTable .assignedShards ()
12581258 .stream ()
1259+ .filter (routing -> Objects .nonNull (routing .allocationId ()))
12591260 .filter (routing -> routing .allocationId ().getId ().equals (allocationId ))
12601261 .findAny ();
12611262 return shardRouting .isPresent () && (shardRouting .get ().primary () || shardRouting .get ().isSearchOnly ());
You can’t perform that action at this time.
0 commit comments