fixed reallocation buffer in LZ4 stream

Author: chernser

client-v2/src/main/java/com/clickhouse/client/api/data_formats/internal/AbstractBinaryFormatReader.java

@@ -73,7 +73,7 @@ protected AbstractBinaryFormatReader(InputStream inputStream, QuerySettings quer
     protected Map<String, Object> currentRecord = new ConcurrentHashMap<>();
     protected Map<String, Object> nextRecord = new ConcurrentHashMap<>();
 
-    protected AtomicBoolean nextRecordEmpty = new AtomicBoolean(true);
+    protected volatile boolean nextRecordEmpty = true;
 
     /**
      * Reads next record into POJO object using set of serializers.
@@ -170,11 +170,11 @@ public boolean hasNext() {
     protected void readNextRecord() {
         initialState = false;
         try {
-            nextRecordEmpty.set(true);
+            nextRecordEmpty = true;
             if (!readRecord(nextRecord)) {
                 endReached();
             } else {
-                nextRecordEmpty.compareAndSet(true, false);
+                nextRecordEmpty = false;
             }
         } catch (IOException e) {
             endReached();
@@ -188,7 +188,7 @@ public Map<String, Object> next() {
             return null;
         }
 
-        if (!nextRecordEmpty.get()) {
+        if (!nextRecordEmpty) {
             Map<String, Object> tmp = currentRecord;
             currentRecord = nextRecord;
             nextRecord = tmp;

examples/demo-service/src/main/java/com/clickhouse/demo_service/DatasetController.java

@@ -107,8 +107,8 @@ public List<VirtualDatasetRecord> directDatasetFetch(@RequestParam(name = "limit
             long duration = System.nanoTime() - start;
 
             // report metrics (only for demonstration purposes)
-            log.info(String.format("records: %d, read time: %d ms (%d bytes), client time: %d ms, server time: %d ms",
-                    result.size(), TimeUnit.NANOSECONDS.toMillis(duration), response.getReadBytes(),
+            log.info(String.format("records: %d, read time: %d ms, client time: %d ms, server time: %d ms",
+                    result.size(), TimeUnit.NANOSECONDS.toMillis(duration),
                     response.getMetrics().getMetric(ClientMetrics.OP_DURATION).getLong(),
                     TimeUnit.NANOSECONDS.toMillis(response.getServerTime())));
 

examples/demo-service/src/main/java/com/clickhouse/demo_service/DbConfiguration.java

@@ -21,9 +21,8 @@ public Client chDirectClient(@Value("${db.url}") String dbUrl, @Value("${db.user
                 // sets the maximum number of connections to the server at a time
                 // this is important for services handling many concurrent requests to ClickHouse
                 .setMaxConnections(100)
-                .setSocketTcpNodelay(true)
-                .setLZ4UncompressedBufferSize(1 * 1024 * 1024) // 1MB buffer size
-                .setClientNetworkBufferSize(1 * 1024 * 1024) // 1MB buffer size
+                .setLZ4UncompressedBufferSize(10 * 1024 * 1024) // 10MB buffer size
+                .setClientNetworkBufferSize(10 * 1024 * 1024) // 10MB buffer size
                 .allowBinaryReaderToReuseBuffers(true) // using buffer pool for binary reader
                 .build();
     }