updated runner config

Author: chernser

performance/src/test/com/clickhouse/benchmark/BenchmarkRunner.java

@@ -36,19 +36,19 @@ public static void main(String[] args) throws Exception {
 
         Options opt = new OptionsBuilder()
                 .include(QueryClient.class.getSimpleName())
-//                .include(InsertClient.class.getSimpleName())
-//                .include(Compression.class.getSimpleName())
-//                .include(Serializers.class.getSimpleName())
-//                .include(Deserializers.class.getSimpleName())
-//                .include(MixedWorkload.class.getSimpleName())
+                .include(InsertClient.class.getSimpleName())
+                .include(Compression.class.getSimpleName())
+                .include(Serializers.class.getSimpleName())
+                .include(Deserializers.class.getSimpleName())
+                .include(MixedWorkload.class.getSimpleName())
                 .forks(1) // must be a fork. No fork only for debugging
                 .mode(Mode.SampleTime)
                 .timeUnit(TimeUnit.MILLISECONDS)
                 .addProfiler(GCProfiler.class)
                 .addProfiler(MemPoolProfiler.class)
-                .warmupIterations(1)
+                .warmupIterations(3)
                 .warmupTime(TimeValue.seconds(10))
-                .measurementIterations(5)
+                .measurementIterations(10)
                 .jvmArgs("-Xms8g", "-Xmx8g")
                 .measurementTime(TimeValue.seconds(isCloud() ? 30 : 10))
                 .resultFormat(ResultFormatType.JSON)

performance/src/test/com/clickhouse/benchmark/clients/BenchmarkBase.java

@@ -12,6 +12,7 @@
 import com.clickhouse.client.ClickHouseProtocol;
 import com.clickhouse.client.ClickHouseResponse;
 import com.clickhouse.client.api.Client;
+import com.clickhouse.client.api.ConnectionReuseStrategy;
 import com.clickhouse.client.api.enums.Protocol;
 import com.clickhouse.client.api.insert.InsertResponse;
 import com.clickhouse.client.api.query.GenericRecord;
@@ -208,8 +209,11 @@ public static boolean verifyCount(String tableName, long expectedCount) {
     }
 
     protected static ClickHouseClient getClientV1() {
-        //We get a new client so that closing won't affect other subsequent calls
-        return ClickHouseClient.newInstance(ClickHouseCredentials.fromUserAndPassword(getUsername(), getPassword()), ClickHouseProtocol.HTTP);
+        // We get a new client so that closing won't affect other subsequent calls
+        return ClickHouseClient.builder()
+                .defaultCredentials(ClickHouseCredentials.fromUserAndPassword(getUsername(), getPassword()))
+                .nodeSelector(ClickHouseNodeSelector.of(ClickHouseProtocol.HTTP))
+                .build();
     }
     protected static Client getClientV2() {
         return getClientV2(true);