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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
