Skip to content

Commit 39edb73

Browse files
committed
Update product name test to wait 10s
1 parent 9225473 commit 39edb73

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-connector-clickhouse-1.17/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -312,7 +312,7 @@ void ProductNameTest() throws Exception {
312312
Assertions.assertEquals(EXPECTED_ROWS, rows);
313313
ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
314314
if (ClickHouseServerForTests.isCloud())
315-
Thread.sleep(5000);
315+
Thread.sleep(10000);
316316
// let's wait until data will be available in query log
317317
String startWith = String.format("Flink-ClickHouse-Sink/%s", ClickHouseSinkVersion.getVersion());
318318
String productName = ClickHouseServerForTests.extractProductName(ClickHouseServerForTests.getDatabase(), tableName, startWith);

flink-connector-clickhouse-2.0.0/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ void ProductNameTest() throws Exception {
306306
Assertions.assertEquals(EXPECTED_ROWS, rows);
307307
ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
308308
if (ClickHouseServerForTests.isCloud())
309-
Thread.sleep(5000);
309+
Thread.sleep(10000);
310310
// let's wait until data will be available in query log
311311
String startWith = String.format("Flink-ClickHouse-Sink/%s", ClickHouseSinkVersion.getVersion());
312312
String productName = ClickHouseServerForTests.extractProductName(ClickHouseServerForTests.getDatabase(), tableName, startWith);

0 commit comments

Comments
 (0)