This is an automated email from the ASF dual-hosted git repository.
xuyang pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 54902f3e47a [bug](branch-2.0) fix stream load metric error (#34012)
54902f3e47a is described below
commit 54902f3e47ac92e63617e157868eebf4a650ccd8
Author: xy720 <[email protected]>
AuthorDate: Wed Apr 24 16:21:09 2024 +0800
[bug](branch-2.0) fix stream load metric error (#34012)
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 d7ca82f8b21..d5fb13da79c 100644
--- a/be/src/http/action/stream_load.cpp
+++ b/be/src/http/action/stream_load.cpp
@@ -134,7 +134,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(std::shared_ptr<StreamLoadContext> ctx) {
@@ -204,7 +203,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);
@@ -356,6 +354,7 @@ void
StreamLoadAction::free_handler_ctx(std::shared_ptr<void> param) {
}
// remove stream load context from stream load manager and the resource
will be released
ctx->exec_env()->new_load_stream_mgr()->remove(ctx->id);
+ streaming_load_current_processing->increment(-1);
}
Status StreamLoadAction::_process_put(HttpRequest* http_req,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
