This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch jdk11-build
in repository 
https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git

commit 09c22a294cc8034e249b52c00f4209a49fd0d87a
Author: Wu Sheng <wu.sh...@foxmail.com>
AuthorDate: Fri Mar 1 09:37:38 2024 +0800

    * Fix the number of channel and the channel size in the BulkWriteProcessor.
    * Support JDK21 build. Upgrade lombok version to 1.18.30.
---
 CHANGES.md                                                   | 12 ++++++++++++
 pom.xml                                                      |  2 +-
 .../skywalking/banyandb/v1/client/BulkWriteProcessor.java    |  2 +-
 3 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/CHANGES.md b/CHANGES.md
index f17ab8f..e0880fc 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -2,6 +2,18 @@ Changes by Version
 ==================
 Release Notes.
 
+0.6.0
+------------------
+
+### Features
+
+* Support JDK21 build. Upgrade lombok version to 1.18.30.
+
+### Bugs
+
+* Fix the number of channel and the channel size in the BulkWriteProcessor.
+
+
 0.5.0
 ------------------
 
diff --git a/pom.xml b/pom.xml
index 617252e..1f1d3bb 100644
--- a/pom.xml
+++ b/pom.xml
@@ -77,7 +77,7 @@
         <checkstyle.version>6.18</checkstyle.version>
         <junit.version>4.13.2</junit.version>
         <mockito-core.version>4.8.0</mockito-core.version>
-        <lombok.version>1.18.22</lombok.version>
+        <lombok.version>1.18.30</lombok.version>
 
         <!-- core lib dependency -->
         <bytebuddy.version>1.10.19</bytebuddy.version>
diff --git 
a/src/main/java/org/apache/skywalking/banyandb/v1/client/BulkWriteProcessor.java
 
b/src/main/java/org/apache/skywalking/banyandb/v1/client/BulkWriteProcessor.java
index 2fda151..1bbc1eb 100644
--- 
a/src/main/java/org/apache/skywalking/banyandb/v1/client/BulkWriteProcessor.java
+++ 
b/src/main/java/org/apache/skywalking/banyandb/v1/client/BulkWriteProcessor.java
@@ -47,7 +47,7 @@ public abstract class BulkWriteProcessor implements Closeable 
{
      */
     protected BulkWriteProcessor(String processorName, int maxBulkSize, int 
flushInterval, int concurrency) {
         this.flushInterval = flushInterval;
-        this.buffer = new DataCarrier(processorName, maxBulkSize, concurrency);
+        this.buffer = new DataCarrier(processorName, concurrency, maxBulkSize);
         Properties properties = new Properties();
         properties.put("maxBulkSize", maxBulkSize);
         properties.put("flushInterval", flushInterval);

Reply via email to