Fix timer doesn't finish (#92)

wu-sheng · web-flow · commit 0a6fa2823965 · 2025-08-27T07:45:42.000+08:00
* Add write obs for client.
diff --git a/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java b/src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java
@@ -170,6 +170,7 @@ protected CompletableFuture<Void> doFlush(final List<Holder> data, Histogram.Tim
             writeRequestStreamObserver.onCompleted();
         }
         batch.whenComplete((ignored, exp) -> {
+            timer.observeDuration();
             if (exp != null) {
                 log.error("Failed to execute requests in bulk", exp);
             }

Original file line number	Diff line number	Diff line change
`@@ -170,6 +170,7 @@ protected CompletableFuture<Void> doFlush(final List<Holder> data, Histogram.Tim`
`170`	`170`	`writeRequestStreamObserver.onCompleted();`
`171`	`171`	`}`
`172`	`172`	`batch.whenComplete((ignored, exp) -> {`
	`173`	`+ timer.observeDuration();`
`173`	`174`	`if (exp != null) {`
`174`	`175`	`log.error("Failed to execute requests in bulk", exp);`
`175`	`176`	`}`