This is an automated email from the ASF dual-hosted git repository.
xuyang pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 6c2c493dae0 [bug](branch-1.2) fix stream load metric error (#34013)
6c2c493dae0 is described below
commit 6c2c493dae0cf2aab8de745c4ec2e2ad25cc1b9e
Author: xy720 <22125576+xy...@users.noreply.github.com>
AuthorDate: Wed Apr 24 16:20:42 2024 +0800
[bug](branch-1.2) fix stream load metric error (#34013)
fix metric streaming_load_current_processing do not decrease.
---
be/src/http/action/stream_load.cpp | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/be/src/http/action/stream_load.cpp
b/be/src/http/action/stream_load.cpp
index b9f2700968b..f0aacf8f4d0 100644
--- a/be/src/http/action/stream_load.cpp
+++ b/be/src/http/action/stream_load.cpp
@@ -182,7 +182,6 @@ void StreamLoadAction::handle(HttpRequest* req) {
// update statistics
streaming_load_requests_total->increment(1);
streaming_load_duration_ms->increment(ctx->load_cost_millis);
- streaming_load_current_processing->increment(-1);
}
Status StreamLoadAction::_handle(StreamLoadContext* ctx) {
@@ -253,7 +252,6 @@ int StreamLoadAction::on_header(HttpRequest* req) {
// add new line at end
str = str + '\n';
HttpChannel::send_reply(req, str);
- streaming_load_current_processing->increment(-1);
#ifndef BE_TEST
if (config::enable_stream_load_record) {
str = ctx->prepare_stream_load_record(str);
@@ -379,6 +377,7 @@ void StreamLoadAction::free_handler_ctx(void* param) {
if (ctx->unref()) {
delete ctx;
}
+ streaming_load_current_processing->increment(-1);
}
Status StreamLoadAction::_process_put(HttpRequest* http_req,
StreamLoadContext* ctx) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
