SMJ: fix streaming row concurrency issue for LEFT SEMI filtered join

comphead · Jun 21, 2024 · 64f0b3d · 64f0b3d
1 parent b1f55fb
commit 64f0b3d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datafusion/core/tests/fuzz_cases/join_fuzz.rs b/datafusion/core/tests/fuzz_cases/join_fuzz.rs
@@ -271,7 +271,7 @@ impl JoinFuzzTestCase {
         join_filter_builder: Option<JoinFilterBuilder>,
     ) -> Self {
         Self {
-            batch_sizes: &[2],
+            batch_sizes: &[1, 2, 7, 49, 50, 51, 100],
             input1,
             input2,
             join_type,