This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 6a1a2a2 [fix](query) Add init function for result_file_sink (#7927)
6a1a2a2 is described below
commit 6a1a2a2ed5b7550500508199c93bb7e920799c4c
Author: qiye <[email protected]>
AuthorDate: Sat Jan 29 10:08:57 2022 +0800
[fix](query) Add init function for result_file_sink (#7927)
Add init function in `result_file_sink` to fix the error "Empty partition
info",
which is occasional reported when using SELECT INFO OUTFILE.
---
be/src/runtime/result_file_sink.cpp | 4 ++++
be/src/runtime/result_file_sink.h | 1 +
2 files changed, 5 insertions(+)
diff --git a/be/src/runtime/result_file_sink.cpp
b/be/src/runtime/result_file_sink.cpp
index 697a452..974825b 100644
--- a/be/src/runtime/result_file_sink.cpp
+++ b/be/src/runtime/result_file_sink.cpp
@@ -70,6 +70,10 @@ ResultFileSink::~ResultFileSink() {
}
}
+Status ResultFileSink::init(const TDataSink& tsink) {
+ return Status::OK();
+}
+
Status ResultFileSink::prepare_exprs(RuntimeState* state) {
// From the thrift expressions create the real exprs.
RETURN_IF_ERROR(Expr::create_expr_trees(state->obj_pool(), _t_output_expr,
&_output_expr_ctxs));
diff --git a/be/src/runtime/result_file_sink.h
b/be/src/runtime/result_file_sink.h
index f6d60ac..5ff64bc 100644
--- a/be/src/runtime/result_file_sink.h
+++ b/be/src/runtime/result_file_sink.h
@@ -49,6 +49,7 @@ public:
const std::vector<TPlanFragmentDestination>& destinations,
ObjectPool* pool,
int sender_id, DescriptorTbl& descs);
virtual ~ResultFileSink();
+ virtual Status init(const TDataSink& thrift_sink);
virtual Status prepare(RuntimeState* state);
virtual Status open(RuntimeState* state);
// send data in 'batch' to this backend stream mgr
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
