This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 2f699e27a63 [log](pipeline)add more log in scan localstate #33062
#33063
2f699e27a63 is described below
commit 2f699e27a639fd9dee71813d212eaaf37117fd61
Author: Mryange <[email protected]>
AuthorDate: Sat Mar 30 12:22:50 2024 +0800
[log](pipeline)add more log in scan localstate #33062 #33063
---
be/src/pipeline/exec/scan_operator.cpp | 11 ++++++++---
be/src/pipeline/exec/scan_operator.h | 2 +-
2 files changed, 9 insertions(+), 4 deletions(-)
diff --git a/be/src/pipeline/exec/scan_operator.cpp
b/be/src/pipeline/exec/scan_operator.cpp
index 8870ba619cb..3af8aa1b3a4 100644
--- a/be/src/pipeline/exec/scan_operator.cpp
+++ b/be/src/pipeline/exec/scan_operator.cpp
@@ -160,6 +160,7 @@ Status ScanLocalState<Derived>::open(RuntimeState* state) {
RETURN_IF_ERROR(_process_conjuncts());
auto status = _eos ? Status::OK() : _prepare_scanners();
+ RETURN_IF_ERROR(status);
if (_scanner_ctx) {
DCHECK(!_eos && _num_scanners->value() > 0);
RETURN_IF_ERROR(_scanner_ctx->init());
@@ -546,11 +547,15 @@ bool
ScanLocalState<Derived>::_is_predicate_acting_on_slot(
template <typename Derived>
std::string ScanLocalState<Derived>::debug_string(int indentation_level) const
{
fmt::memory_buffer debug_string_buffer;
- fmt::format_to(debug_string_buffer, "{}, _eos = {}",
- PipelineXLocalState<>::debug_string(indentation_level),
_eos.load());
+ fmt::format_to(debug_string_buffer, "{}, _eos = {} , _opened = {}",
+ PipelineXLocalState<>::debug_string(indentation_level),
_eos.load(),
+ _opened.load());
if (_scanner_ctx) {
fmt::format_to(debug_string_buffer, "");
fmt::format_to(debug_string_buffer, ", Scanner Context: {}",
_scanner_ctx->debug_string());
+ } else {
+ fmt::format_to(debug_string_buffer, "");
+ fmt::format_to(debug_string_buffer, ", Scanner Context: NULL");
}
return fmt::to_string(debug_string_buffer);
@@ -1202,7 +1207,7 @@ Status ScanLocalState<Derived>::_prepare_scanners() {
}
if (scanners.empty()) {
_eos = true;
- _scan_dependency->set_ready();
+ _scan_dependency->set_always_ready();
} else {
for (auto& scanner : scanners) {
scanner->set_query_statistics(_query_statistics.get());
diff --git a/be/src/pipeline/exec/scan_operator.h
b/be/src/pipeline/exec/scan_operator.h
index 7cb7b01a9a4..a22a00da529 100644
--- a/be/src/pipeline/exec/scan_operator.h
+++ b/be/src/pipeline/exec/scan_operator.h
@@ -140,7 +140,7 @@ class ScanLocalState : public ScanLocalStateBase {
Status init(RuntimeState* state, LocalStateInfo& info) override;
Status open(RuntimeState* state) override;
Status close(RuntimeState* state) override;
- std::string debug_string(int indentation_level) const override;
+ std::string debug_string(int indentation_level) const final;
bool ready_to_read() override;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
