Skip to content

Commit

Permalink
[fix](pipeline) fix check failed in StatefulOperator
Browse files Browse the repository at this point in the history
  • Loading branch information
Mryange authored Mar 25, 2024
1 parent 645a4c4 commit 69821c0
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 2 deletions.
7 changes: 6 additions & 1 deletion be/src/pipeline/exec/join_probe_operator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,12 @@ Status JoinProbeLocalState<SharedStateArg, Derived>::_build_output_block(
// In previous versions, the join node had a separate set of project structures,
// and you could see a 'todo' in the Thrift definition.
// Here, we have refactored it, but considering upgrade compatibility, we still need to retain the old code.
*output_block = *origin_block;
if (!output_block->mem_reuse()) {
vectorized::MutableBlock tmp(
vectorized::VectorizedUtils::create_columns_with_type_and_name(p.row_desc()));
output_block->swap(tmp.to_block());
}
output_block->swap(*origin_block);
return Status::OK();
}
SCOPED_TIMER(_build_output_block_timer);
Expand Down
6 changes: 5 additions & 1 deletion be/src/vec/exec/join/vjoin_node_base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,11 @@ Status VJoinNodeBase::_build_output_block(Block* origin_block, Block* output_blo
// In previous versions, the join node had a separate set of project structures,
// and you could see a 'todo' in the Thrift definition.
// Here, we have refactored it, but considering upgrade compatibility, we still need to retain the old code.
*output_block = *origin_block;
if (!output_block->mem_reuse()) {
MutableBlock tmp(VectorizedUtils::create_columns_with_type_and_name(row_desc()));
output_block->swap(tmp.to_block());
}
output_block->swap(*origin_block);
return Status::OK();
}
auto is_mem_reuse = output_block->mem_reuse();
Expand Down

0 comments on commit 69821c0

Please sign in to comment.