Skip to content

Commit a8152e4

Browse files
committed
fix
1 parent 3b1dd10 commit a8152e4

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

flink-doris-connector/flink-doris-connector-it/src/test/java/org/apache/doris/flink/sink/DorisSinkMultiTblFailoverITCase.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -167,6 +167,9 @@ public void cancel() {}
167167
"select id,task_id from %s.%s ", DATABASE, TABLE_MULTI_CSV_NO_EXIST_TBL);
168168
List<String> expected = Arrays.asList("1,3");
169169

170+
// wait data VISIBLE
171+
Thread.sleep(5000);
172+
170173
if (!batchMode) {
171174
ContainerUtils.checkResult(
172175
getDorisQueryConnection(), LOG, expected, queryRes, 2, false);

0 commit comments

Comments
 (0)