Remove redundant code

Author: mzitnik

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

@@ -57,7 +57,7 @@ public static void setUp() throws InterruptedException, ExecutionException {
         boolean isLive = false;
         int counter = 0;
         while (counter < 5) {
-            isLive = ClickHouseTestHelpers.ping(isCloud, host, port, isSSL, username, password);
+            isLive = ClickHouseTestHelpers.ping(host, port, isSSL, username, password);
             if (isLive) {
                 String createDatabase = String.format("CREATE DATABASE IF NOT EXISTS `%s`", database);
                 executeSql(createDatabase);
@@ -78,13 +78,13 @@ public static void tearDown() {
     public static String getDataBase() { return database; }
 
     public static void executeSql(String sql) throws ExecutionException, InterruptedException {
-        Client client = ClickHouseTestHelpers.getClient(isCloud, host, port, isSSL, username, password);
+        Client client = ClickHouseTestHelpers.getClient(host, port, isSSL, username, password);
         client.execute(sql).get();
     }
 
     public static int countRows(String table) throws ExecutionException, InterruptedException {
         String countSql = String.format("SELECT COUNT(*) FROM `%s`.`%s`", database, table);
-        Client client = ClickHouseTestHelpers.getClient(isCloud, host, port, isSSL, username, password);
+        Client client = ClickHouseTestHelpers.getClient(host, port, isSSL, username, password);
         List<GenericRecord> countResult = client.queryAll(countSql);
         return countResult.get(0).getInteger(1);
     }

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

@@ -35,16 +35,16 @@ public static boolean isCloud() {
         return clickHouseVersion != null && clickHouseVersion.equalsIgnoreCase("cloud");
     }
 
-    public static Client getClient(boolean isCloud, String host, int port, boolean ssl, String username, String password) {
+    public static Client getClient(String host, int port, boolean ssl, String username, String password) {
         return new Client.Builder().addEndpoint(Protocol.HTTP, host, port, ssl)
                                    .setUsername(username)
                                    .setPassword(password)
                                    .setConnectTimeout(TIMEOUT_VALUE, TIMEOUT_UNIT.toChronoUnit())
                                    .build();
     }
 
-    public static boolean ping(boolean isCloud, String host, int port, boolean ssl, String username, String password) {
-        Client client = getClient(isCloud(), host, port, ssl, username, password);
+    public static boolean ping(String host, int port, boolean ssl, String username, String password) {
+        Client client = getClient(host, port, ssl, username, password);
         return client.ping();
     }