test

apache · Dec 12, 2024 · f335848 · f335848
1 parent ab47ba3
commit f335848
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp b/be/src/pipeline/exec/exchange_sink_operator.cpp
@@ -591,7 +591,10 @@ std::shared_ptr<ExchangeSinkBuffer> ExchangeSinkOperatorX::get_sink_buffer(
     if (std::dynamic_pointer_cast<SortSourceOperatorX>(_child) ||
         std::dynamic_pointer_cast<LocalExchangeSourceOperatorX>(_child) ||
         std::dynamic_pointer_cast<SpillSortSourceOperatorX>(_child)) {
-        DCHECK_EQ(_dest_is_merge, true);
+        if (!_dest_is_merge) {
+            throw doris::Exception(ErrorCode::INTERNAL_ERROR, "_dest_is_merge {}.   child name {}",
+                                   _dest_is_merge, _child->get_name());
+        }
         return _create_buffer({sender_ins_id});
     }
     if (_dest_is_merge) {