Skip to content

Commit 73d4ca7

Browse files
committed
Minor clean ups
1 parent e180939 commit 73d4ca7

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

datafusion/core/tests/fuzz_cases/join_fuzz.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ async fn test_left_mark_join_1k() {
243243
JoinType::LeftMark,
244244
None,
245245
)
246-
.run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], true)
246+
.run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
247247
.await
248248
}
249249

@@ -255,7 +255,7 @@ async fn test_left_mark_join_1k_filtered() {
255255
JoinType::LeftMark,
256256
Some(Box::new(col_lt_col_filter)),
257257
)
258-
.run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], true)
258+
.run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
259259
.await
260260
}
261261

datafusion/expr/src/logical_plan/builder.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1333,7 +1333,7 @@ fn mark_field(schema: &DFSchema) -> (Option<TableReference>, Arc<Field>) {
13331333
.collect::<Vec<_>>();
13341334
table_references.dedup();
13351335
let table_reference = if table_references.len() == 1 {
1336-
table_references.first().cloned().cloned()
1336+
table_references.pop().cloned()
13371337
} else {
13381338
None
13391339
};

datafusion/physical-plan/src/joins/utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1264,7 +1264,7 @@ pub(crate) fn build_batch_from_indices(
12641264

12651265
for column_index in column_indices {
12661266
let array = if column_index.side == JoinSide::None {
1267-
// LeftMark join, the mark column is a boolean if the indices is not null
1267+
// LeftMark join, the mark column is a true if the indices is not null, otherwise it will be false
12681268
Arc::new(compute::is_not_null(probe_indices)?)
12691269
} else if column_index.side == build_side {
12701270
let array = build_input_buffer.column(column_index.index);

0 commit comments

Comments
 (0)