[incubator-doris] branch master updated: [fix](query) Add init function for result_file_sink (#7927)

[morningman]

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 <jianliang5...@gmail.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org