This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 748103a402d [chore](log) Log written rows when result sink close
(#39647)
748103a402d is described below
commit 748103a402d0de267010b2fcccd7e84807b5a578
Author: zhiqiang <[email protected]>
AuthorDate: Tue Aug 27 15:11:02 2024 +0800
[chore](log) Log written rows when result sink close (#39647)
In some cases, audit log in fe says a query did not return any rows. So
we log the information when result sink close to help us do check.
---
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 73d0bea8f99..2a32e24bf68 100644
--- a/be/src/pipeline/exec/result_sink_operator.cpp
+++ b/be/src/pipeline/exec/result_sink_operator.cpp
@@ -190,6 +190,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]
