diff --git a/be/src/pipeline/exec/partitioned_hash_join_probe_operator.cpp b/be/src/pipeline/exec/partitioned_hash_join_probe_operator.cpp index 0576ae91dd..628be711b4 100644 --- a/be/src/pipeline/exec/partitioned_hash_join_probe_operator.cpp +++ b/be/src/pipeline/exec/partitioned_hash_join_probe_operator.cpp @@ -437,13 +437,12 @@ Status PartitionedHashJoinProbeLocalState::recovery_build_blocks_from_disk(Runti return st; } -std::string PartitionedHashJoinProbeOperatorX::debug_string(RuntimeState* state, - int indentation_level) const { +std::string PartitionedHashJoinProbeLocalState::debug_string(int indentation_level) const { fmt::memory_buffer debug_string_buffer; - fmt::format_to(debug_string_buffer, "{}, in mem join probe: {}", - JoinProbeOperatorX::debug_string( - state, indentation_level), - _inner_probe_operator ? _inner_probe_operator->debug_string(state, 0) : "NULL"); + fmt::format_to(debug_string_buffer, "{}, short_circuit_for_probe: {}", + PipelineXSpillLocalState::debug_string( + indentation_level), + _shared_state ? std::to_string(_shared_state->short_circuit_for_probe) : "NULL"); return fmt::to_string(debug_string_buffer); } diff --git a/be/src/pipeline/exec/partitioned_hash_join_probe_operator.h b/be/src/pipeline/exec/partitioned_hash_join_probe_operator.h index d56a57ae42..6be6c5a865 100644 --- a/be/src/pipeline/exec/partitioned_hash_join_probe_operator.h +++ b/be/src/pipeline/exec/partitioned_hash_join_probe_operator.h @@ -61,6 +61,8 @@ public: void update_build_profile(RuntimeProfile* child_profile); void update_probe_profile(RuntimeProfile* child_profile); + std::string debug_string(int indentation_level = 0) const override; + friend class PartitionedHashJoinProbeOperatorX; private: @@ -155,8 +157,6 @@ public: Status pull(doris::RuntimeState* state, vectorized::Block* output_block, bool* eos) const override; - std::string debug_string(RuntimeState* state, int indentation_level = 0) const override; - bool need_more_input_data(RuntimeState* state) const override; DataDistribution required_data_distribution() const override { if (_join_op == TJoinOp::NULL_AWARE_LEFT_ANTI_JOIN) {