Add ON CLUSTER to flush logs

Author: mzitnik

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

@@ -310,7 +310,11 @@ void ProductNameTest() throws Exception {
         lines.sinkTo(csvSink);
         int rows = executeAsyncJob(env, tableName, 10, EXPECTED_ROWS);
         Assertions.assertEquals(EXPECTED_ROWS, rows);
-        ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
+        if (ClickHouseServerForTests.isCloud())
+            ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS ON CLUSTER 'default'");
+        else
+            ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
+
         if (ClickHouseServerForTests.isCloud())
             Thread.sleep(10000);
         // let's wait until data will be available in query log

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

@@ -304,7 +304,11 @@ void ProductNameTest() throws Exception {
         lines.sinkTo(csvSink);
         int rows = executeAsyncJob(env, tableName, 10, EXPECTED_ROWS);
         Assertions.assertEquals(EXPECTED_ROWS, rows);
-        ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
+        if (ClickHouseServerForTests.isCloud())
+            ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS ON CLUSTER 'default'");
+        else
+            ClickHouseServerForTests.executeSql("SYSTEM FLUSH LOGS");
+
         if (ClickHouseServerForTests.isCloud())
             Thread.sleep(10000);
         // let's wait until data will be available in query log