fix

apache · Aug 31, 2024 · 7025f24 · 7025f24
1 parent c065b18
commit 7025f24
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/...nds-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala b/...nds-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala
@@ -231,9 +231,6 @@ case class CHBroadcastHashJoinExecTransformer(
     if (shouldFallback) {
       return ValidationResult.failed("ch join validate fail")
     }
-    /* if (isNullAwareAntiJoin) {
-      return ValidationResult.failed("ch does not support NAAJ")
-    } */
     super.doValidateInternal()
   }
 

diff --git a/...est/scala/org/apache/gluten/execution/tpch/GlutenClickHouseTPCHSaltNullParquetSuite.scala b/...est/scala/org/apache/gluten/execution/tpch/GlutenClickHouseTPCHSaltNullParquetSuite.scala
@@ -72,7 +72,7 @@ class GlutenClickHouseTPCHSaltNullParquetSuite extends GlutenClickHouseTPCHAbstr
               salted_df = Some((salted_df match {
                 case Some(x) => x
                 case None => df
-              }).withColumn(c.name, when(rand() < 0.5, null).otherwise(col(c.name))))
+              }).withColumn(c.name, when(rand() < 0.01, null).otherwise(col(c.name))))
             }
 
             val currentSaltedTablePath = saltedTablesPath + "/" + tableName