Make it work in the cloud

Author: mzitnik

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

@@ -103,7 +103,7 @@ public static int countRows(String table) throws ExecutionException, Interrupted
     }
 
     public static String extractProductName() {
-        String extractProductName = "SELECT http_user_agent FROM system.query_log WHERE type = 'QueryStart' and query_kind = 'Insert' LIMIT 10";
+        String extractProductName = "SELECT http_user_agent FROM clusterAllReplicas('default', system.query_log) WHERE type = 'QueryStart' and query_kind = 'Insert' LIMIT 10";
         Client client = ClickHouseTestHelpers.getClient(host, port, isSSL, username, password);
         List<GenericRecord> userAgentResult = client.queryAll(extractProductName);
         return userAgentResult.get(0).getString(1);