Skip to content

Commit 55bb52b

Browse files
authored
release: v0.14.6 (#87)
1 parent 4662bf7 commit 55bb52b

File tree

14 files changed

+15
-14
lines changed

14 files changed

+15
-14
lines changed

ingester-all/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-all</artifactId>

ingester-bulk-protocol/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-bulk-protocol</artifactId>

ingester-common/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-common</artifactId>

ingester-example/README.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,9 @@ This API is particularly well-suited for:
8181

8282
The Bulk Write API provides a high-performance, memory-efficient mechanism for ingesting large volumes of time-series data into GreptimeDB. It leverages Apache Arrow's Flight protocol and off-heap memory management to achieve optimal throughput when writing batches of data.
8383

84-
Unlike regular streaming, this API allows continuous writing to only one table per stream, but can handle very large data volumes (up to 200MB per write). It features sophisticated adaptive flow control mechanisms that automatically adjust to your data throughput requirements.
84+
**Important Note**:
85+
- This API is designed around streaming connections, which means each stream establishes a connection to only one database node. Unlike the regular write API, it lacks automatic load balancing for individual requests. However, if your use case involves multiple clients establishing multiple streams to the database, this limitation is not a concern.
86+
- Unlike regular streaming, this API allows continuous writing to only one table per stream, but can handle very large data volumes (up to 200MB per write). It features sophisticated adaptive flow control mechanisms that automatically adjust to your data throughput requirements.
8587

8688
The Bulk Write API achieves superior performance compared to the Regular Write API through:
8789
- Off-heap memory management using Arrow buffers

ingester-example/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-example</artifactId>

ingester-example/src/main/java/io/greptime/bench/DBConnector.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public static GreptimeDB connect() {
4444
GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database)
4545
.writeMaxRetries(0)
4646
.defaultStreamMaxWritePointsPerSecond(Integer.MAX_VALUE)
47+
.maxInFlightWritePoints(Integer.MAX_VALUE)
4748
.useZeroCopyWriteInBulkWrite(true)
4849
.build();
4950
LOG.info("Connect to db: {}, endpoint: {}", database, endpointsStr);

ingester-example/src/main/java/io/greptime/bench/benchmark/BatchingWriteBenchmark.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,11 +53,9 @@ public class BatchingWriteBenchmark {
5353
public static void main(String[] args) throws Exception {
5454
boolean zstdCompression = SystemPropertyUtil.getBool("zstd_compression", true);
5555
int batchSize = SystemPropertyUtil.getInt("batch_size_per_request", 64 * 1024);
56-
int maxPointsPerSecond = SystemPropertyUtil.getInt("max_points_per_second", Integer.MAX_VALUE);
5756

5857
LOG.info("Using zstd compression: {}", zstdCompression);
5958
LOG.info("Batch size: {}", batchSize);
60-
LOG.info("Max points per second: {}", maxPointsPerSecond);
6159

6260
// Start a metrics exporter
6361
MetricsExporter metricsExporter = new MetricsExporter(MetricsUtil.metricRegistry());

ingester-grpc/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-grpc</artifactId>

ingester-prometheus-metrics/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626
<artifactId>ingester-prometheus-metrics</artifactId>
2727

ingester-protocol/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>io.greptime</groupId>
2323
<artifactId>greptimedb-ingester</artifactId>
24-
<version>0.14.5</version>
24+
<version>0.14.6</version>
2525
</parent>
2626

2727
<artifactId>ingester-protocol</artifactId>

0 commit comments

Comments
 (0)