We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dfdaa6e commit 36684dcCopy full SHA for 36684dc
fluss-server/src/test/java/com/alibaba/fluss/server/replica/CommitLakeTableSnapshotITCase.java
@@ -83,6 +83,7 @@ void testCommitDataLakeData() throws Exception {
83
int leaderServer = FLUSS_CLUSTER_EXTENSION.waitAndGetLeader(tb);
84
TabletServerGateway leaderGateWay =
85
FLUSS_CLUSTER_EXTENSION.newTabletServerClientForNode(leaderServer);
86
+ FLUSS_CLUSTER_EXTENSION.waitUtilAllReplicaReady(tb);
87
88
for (int i = 0; i < 10; i++) {
89
leaderGateWay
0 commit comments