Skip to content

Commit

Permalink
Fixed flaky integration test
Browse files Browse the repository at this point in the history
  • Loading branch information
gaojieliu committed Sep 29, 2024
1 parent e5c7449 commit 269912a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -775,7 +775,7 @@ public void testHybridStore() throws Exception {
// Isolated clients should not be able to unsubscribe partitions of other clients.
client3.unsubscribeAll();

client3.subscribe(Collections.singleton(partition)).get(0, TimeUnit.SECONDS);
client3.subscribe(Collections.singleton(partition)).get(10, TimeUnit.SECONDS);
for (int i = 0; i < KEY_COUNT; i++) {
final int key = i;
// Both client2 & client4 are not subscribed to any partition. But client2 is not-isolated so it can
Expand Down

0 comments on commit 269912a

Please sign in to comment.