Skip to content

Commit 806d5af

Browse files
committed
corrected v1 tests and config to match v2
1 parent 1e26fbb commit 806d5af

File tree

4 files changed

+4
-2
lines changed

4 files changed

+4
-2
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@ public static void main(String[] args) throws Exception {
4545
.jvmArgs("-Xms8g", "-Xmx8g")
4646
.measurementTime(TimeValue.seconds(isCloud() ? 30 : 10))
4747
.resultFormat(ResultFormatType.JSON)
48+
.output(String.format("jmh-results-%s-%s.out", isCloud() ? "cloud" : "local", System.currentTimeMillis()))
4849
.result(String.format("jmh-results-%s-%s.json", isCloud() ? "cloud" : "local", System.currentTimeMillis()))
4950
.build();
5051

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import com.clickhouse.client.api.Client;
1313
import com.clickhouse.client.api.enums.Protocol;
1414
import com.clickhouse.client.api.insert.InsertResponse;
15+
import com.clickhouse.client.config.ClickHouseClientOption;
1516
import com.clickhouse.data.ClickHouseDataProcessor;
1617
import com.clickhouse.client.api.query.GenericRecord;
1718
import com.clickhouse.data.ClickHouseFormat;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public void insertV1(DataState dataState) {
4242
try (ClickHouseResponse response = clientV1.read(getServer())
4343
.write()
4444
.option(ClickHouseClientOption.ASYNC, false)
45-
.option(ClickHouseClientOption.COMPRESS, dataState.useClientCompression)
45+
.option(ClickHouseClientOption.DECOMPRESS, dataState.useClientCompression)
4646
.format(format)
4747
.query(BenchmarkRunner.getInsertQuery(dataState.tableNameEmpty))
4848
.data(out -> {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public void queryV1(DataState dataState) {
2929
.executeAndWait()) {
3030
for (ClickHouseRecord record: response.records()) {//Compiler optimization avoidance
3131
for (int i = 0; i < dataState.dataSet.getSchema().getColumns().size(); i++) {
32-
isNotNull(record.getValue(i), false);
32+
isNotNull(record.getValue(i).asObject(), false);
3333
}
3434
}
3535
}

0 commit comments

Comments
 (0)