[doris] branch master updated: [pipelineX](fix) Fix concurrent bug in schema scanner (#25655)

[gabriellee]

This is an automated email from the ASF dual-hosted git repository.

gabriellee 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 925233a2710 [pipelineX](fix) Fix concurrent bug in schema scanner 
(#25655)
925233a2710 is described below

commit 925233a2710f5c94a2783c1e673a410a2a00b117
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Fri Oct 20 14:29:42 2023 +0800

    [pipelineX](fix) Fix concurrent bug in schema scanner (#25655)
---
 be/src/pipeline/exec/schema_scan_operator.cpp | 5 ++++-
 be/src/pipeline/exec/schema_scan_operator.h   | 2 ++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/be/src/pipeline/exec/schema_scan_operator.cpp 
b/be/src/pipeline/exec/schema_scan_operator.cpp
index 4c98c422728..a406f8ae2cc 100644
--- a/be/src/pipeline/exec/schema_scan_operator.cpp
+++ b/be/src/pipeline/exec/schema_scan_operator.cpp
@@ -65,7 +65,10 @@ Status SchemaScanLocalState::init(RuntimeState* state, 
LocalStateInfo& info) {
         return Status::InternalError("schema scanner get nullptr pointer.");
     }
 
-    RETURN_IF_ERROR(_schema_scanner->init(&_scanner_param, state->obj_pool()));
+    return _schema_scanner->init(&_scanner_param, state->obj_pool());
+}
+
+Status SchemaScanLocalState::open(RuntimeState* state) {
     return _schema_scanner->start(state);
 }
 
diff --git a/be/src/pipeline/exec/schema_scan_operator.h 
b/be/src/pipeline/exec/schema_scan_operator.h
index 8feabd2e2f4..03238947e88 100644
--- a/be/src/pipeline/exec/schema_scan_operator.h
+++ b/be/src/pipeline/exec/schema_scan_operator.h
@@ -60,6 +60,8 @@ public:
 
     Status init(RuntimeState* state, LocalStateInfo& info) override;
 
+    Status open(RuntimeState* state) override;
+
 private:
     friend class SchemaScanOperatorX;
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org