Skip to content

Commit ac91f06

Browse files
committed
add log
1 parent c591505 commit ac91f06

File tree

1 file changed

+3
-0
lines changed
  • src/query/service/src/pipelines/processors/transforms/hash_join/runtime_filter

1 file changed

+3
-0
lines changed

src/query/service/src/pipelines/processors/transforms/hash_join/runtime_filter/builder.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,9 @@ impl<'a> JoinRuntimeFilterPacketBuilder<'a> {
112112
) -> Result<Column> {
113113
let mut columns = Vec::with_capacity(data_blocks.len());
114114
for block in data_blocks.iter() {
115+
if block.columns().is_empty() {
116+
log::info!("block.columns().len() == 0");
117+
}
115118
let evaluator = Evaluator::new(block, func_ctx, &BUILTIN_FUNCTIONS);
116119
let column = evaluator
117120
.run(build_key)?

0 commit comments

Comments
 (0)