Skip to content

Commit c80833b

Browse files
committed
Some cleanup
1 parent 3779705 commit c80833b

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

flink-connector-clickhouse-base/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
@@ -294,7 +294,7 @@ void ProductNameTest() throws Exception {
294294
Assertions.assertEquals(EXPECTED_ROWS, rows);
295295
ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
296296
if (ClickHouseServerForTests.isCloud())
297-
Thread.sleep(2000);
297+
Thread.sleep(5000);
298298
// let's wait until data will be available in query log
299299
String productName = ClickHouseServerForTests.extractProductName(ClickHouseServerForTests.getDatabase(), tableName);
300300
String compareString = String.format("Flink-ClickHouse-Sink/%s (fv:flink/2.0.0, lv:scala/2.12)", ClickHouseSinkVersion.getVersion());

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/test/embedded/clickhouse/ClickHouseServerForTests.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,6 @@ public static String extractProductName(String databaseName, String tableName) {
109109
Client client = ClickHouseTestHelpers.getClient(host, port, isSSL, username, password);
110110
List<GenericRecord> userAgentResult = client.queryAll(extractProductName);
111111
if (!userAgentResult.isEmpty()) {
112-
System.out.println(databaseName + " " + tableName);
113-
System.out.println("http_user_agent" + userAgentResult.get(0).getString("http_user_agent"));
114-
System.out.println("tables" + userAgentResult.get(0).getString("tables"));
115112
return userAgentResult.get(0).getString(1);
116113
}
117114
throw new RuntimeException("Query is returning empty result.");

0 commit comments

Comments
 (0)