This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 901344a8803 [chore](log) Log written rows when result sink close
#39647 (#40011)
901344a8803 is described below
commit 901344a880346bf794b06a39035e74c551818a21
Author: zhiqiang <[email protected]>
AuthorDate: Thu Aug 29 16:49:44 2024 +0800
[chore](log) Log written rows when result sink close #39647 (#40011)
cherry pick from #39647
---
be/src/pipeline/exec/result_sink_operator.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/pipeline/exec/result_sink_operator.cpp
b/be/src/pipeline/exec/result_sink_operator.cpp
index 1aa7f37c1fe..1114bdd312f 100644
--- a/be/src/pipeline/exec/result_sink_operator.cpp
+++ b/be/src/pipeline/exec/result_sink_operator.cpp
@@ -198,6 +198,10 @@ Status ResultSinkLocalState::close(RuntimeState* state,
Status exec_status) {
// close file writer failed, should return this error to client
final_status = st;
}
+
+ LOG_INFO("Query {} result sink closed with status {} and has written
{} rows",
+ print_id(state->query_id()),
final_status.to_string_no_stack(),
+ _writer->get_written_rows());
}
// close sender, this is normal path end
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
