Skip to content

Commit 4e45573

Browse files
committed
nit: make test more robust by adding retryable timeout
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
1 parent b0ecb20 commit 4e45573

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -472,9 +472,11 @@ public void testDorisTruncateTable() throws Exception {
472472
DataChangeEvent.insertEvent(tableId, generate(schema, 3, 4.5, "Cecily")),
473473
DataChangeEvent.insertEvent(tableId, generate(schema, 4, 5.6, "Derrida")));
474474
runJobWithEvents(truncateTestingEvents);
475-
assertEqualsInAnyOrder(
475+
waitAndVerify(
476+
tableId,
477+
3,
476478
Arrays.asList("3 | 4.5 | Cecily", "4 | 5.6 | Derrida"),
477-
fetchTableContent(tableId, 3));
479+
DATABASE_OPERATION_TIMEOUT_SECONDS * 1000L);
478480
}
479481

480482
@Test

0 commit comments

Comments
 (0)