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);