From f9d2a907f48cffdb1bf2d6ba601f8104d0dd8eeb Mon Sep 17 00:00:00 2001
From: Eduard Karacharov <eduard.karacharov@gmail.com>
Date: Fri, 6 Sep 2024 20:44:50 +0300
Subject: [PATCH] tests: disable flaky tests for SortMergeJoin

---
 datafusion/core/tests/fuzz_cases/join_fuzz.rs | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/datafusion/core/tests/fuzz_cases/join_fuzz.rs b/datafusion/core/tests/fuzz_cases/join_fuzz.rs
index 6a4e5d0cb303..20c329915254 100644
--- a/datafusion/core/tests/fuzz_cases/join_fuzz.rs
+++ b/datafusion/core/tests/fuzz_cases/join_fuzz.rs
@@ -125,6 +125,8 @@ async fn test_left_join_1k() {
 }
 
 #[tokio::test]
+// flaky for HjSmj case
+// https://github.com/apache/datafusion/issues/12359
 async fn test_left_join_1k_filtered() {
     JoinFuzzTestCase::new(
         make_staggered_batches(1000),
@@ -132,7 +134,7 @@ async fn test_left_join_1k_filtered() {
         JoinType::Left,
         Some(Box::new(col_lt_col_filter)),
     )
-    .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
+    .run_test(&[JoinTestType::NljHj], false)
     .await
 }
 
@@ -149,6 +151,8 @@ async fn test_right_join_1k() {
 }
 
 #[tokio::test]
+// flaky for HjSmj case
+// https://github.com/apache/datafusion/issues/12359
 async fn test_right_join_1k_filtered() {
     JoinFuzzTestCase::new(
         make_staggered_batches(1000),
@@ -156,7 +160,7 @@ async fn test_right_join_1k_filtered() {
         JoinType::Right,
         Some(Box::new(col_lt_col_filter)),
     )
-    .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
+    .run_test(&[JoinTestType::NljHj], false)
     .await
 }
 
@@ -173,6 +177,8 @@ async fn test_full_join_1k() {
 }
 
 #[tokio::test]
+// flaky for HjSmj case
+// https://github.com/apache/datafusion/issues/12359
 async fn test_full_join_1k_filtered() {
     JoinFuzzTestCase::new(
         make_staggered_batches(1000),
@@ -180,7 +186,7 @@ async fn test_full_join_1k_filtered() {
         JoinType::Full,
         Some(Box::new(col_lt_col_filter)),
     )
-    .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
+    .run_test(&[JoinTestType::NljHj], false)
     .await
 }