Skip to content

Commit dbcdae3

Browse files
committed
Fix IT failures
Signed-off-by: Ashish Singh <ssashish@amazon.com>
1 parent 46903d5 commit dbcdae3

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ public ReplicationGroup(
6868
boolean remoteTranslogEnabled
6969
) {
7070
if (!remoteTranslogEnabled) {
71-
assert trackedAllocationIds.equals(localTranslogAllocationIds)
71+
assert localTranslogAllocationIds.containsAll(trackedAllocationIds)
7272
: "In absence of remote translog store, all tracked shards must have local translog store";
7373
}
7474
this.routingTable = routingTable;
@@ -125,7 +125,7 @@ public ReplicationGroup(
125125
Set<String> trackedAllocationIds,
126126
long version
127127
) {
128-
this(routingTable, inSyncAllocationIds, trackedAllocationIds, Collections.emptySet(), version, false);
128+
this(routingTable, inSyncAllocationIds, trackedAllocationIds, trackedAllocationIds, version, false);
129129
}
130130

131131
public long getVersion() {

0 commit comments

Comments
 (0)