Skip to content

Commit

Permalink
[bug](branch-1.2) fix stream load metric error (#34013)
Browse files Browse the repository at this point in the history
fix metric streaming_load_current_processing do not decrease.
  • Loading branch information
xy720 authored Apr 24, 2024
1 parent 76e4c00 commit 6c2c493
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions be/src/http/action/stream_load.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down Expand Up @@ -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);
Expand Down Expand Up @@ -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) {
Expand Down

0 comments on commit 6c2c493

Please sign in to comment.