Skip to content

Commit

Permalink
Fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
Kirill Sizov committed Nov 12, 2024
1 parent a2cf97e commit ebed46c
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -572,10 +572,9 @@ public void testIncompleteRebalanceBeforeAutomaticResetPartitions() throws Excep
node0.disasterRecoveryManager().resetAllPartitions(zoneName, QUALIFIED_TABLE_NAME, false);
assertThat(resetFuture, willCompleteSuccessfully());

Assignments assignmentForced13 = Assignments.forced(Set.of(Assignment.forPeer(node(1).name()),
Assignment.forPeer(node(3).name())), timestamp);
Assignments assignmentForced1 = Assignments.forced(Set.of(Assignment.forPeer(node(1).name())), timestamp);

assertPendingAssignments(node0, partId, assignmentForced13);
assertPendingAssignments(node0, partId, assignmentForced1);
}

/**
Expand Down

0 comments on commit ebed46c

Please sign in to comment.