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

yiguolei pushed a commit to branch spill_repartition
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/spill_repartition by this push:
     new 87cbf878412 fix compile
87cbf878412 is described below

commit 87cbf878412b397a890d2b64f95c177cd5c8693d
Author: yiguolei <[email protected]>
AuthorDate: Fri Feb 27 18:22:15 2026 +0800

    fix compile
---
 be/src/pipeline/exec/partitioned_hash_join_sink_operator.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/be/src/pipeline/exec/partitioned_hash_join_sink_operator.cpp 
b/be/src/pipeline/exec/partitioned_hash_join_sink_operator.cpp
index ed8b77be341..87678027661 100644
--- a/be/src/pipeline/exec/partitioned_hash_join_sink_operator.cpp
+++ b/be/src/pipeline/exec/partitioned_hash_join_sink_operator.cpp
@@ -63,6 +63,7 @@ Status PartitionedHashJoinSinkLocalState::open(RuntimeState* 
state) {
     SCOPED_TIMER(exec_time_counter());
     SCOPED_TIMER(_open_timer);
     RETURN_IF_ERROR(PipelineXSpillSinkLocalState::open(state));
+    auto& p = _parent->cast<PartitionedHashJoinSinkOperatorX>();
     return p._partitioner->clone(state, _partitioner);
 }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to