test

apache · Aug 13, 2024 · 719bb3a · 719bb3a
1 parent 921f430
commit 719bb3a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 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
@@ -105,8 +105,8 @@ case class CHShuffledHashJoinExecTransformer(
   override protected lazy val substraitJoinType: JoinRel.JoinType =
     JoinTypeTransform.toSubstraitType(joinType)
 
-  def genJoinParameters1(): Any = {
-    val (isBHJ, isNullAwareAntiJoin, buildHashTableId) = genJoinParametersInternal()
+  override def genJoinParameters(): Any = {
+    val (isBHJ, isNullAwareAntiJoin, buildHashTableId): (Int, Int, String) = (0, 0, "")
 
     // Don't use lef/right directly, they may be reordered in `HashJoinLikeExecTransformer`
     val leftStats = getShuffleStageStatistics(streamedPlan)
@@ -157,12 +157,15 @@ case class CHShuffledHashJoinExecTransformer(
   private def getShuffleStageStatistics(plan: SparkPlan): ShuffleStageStaticstics = {
     plan match {
       case queryStage: ShuffleQueryStageExec =>
+        /*
         ShuffleStageStaticstics(
           queryStage.shuffle.numPartitions,
           queryStage.shuffle.numMappers,
           queryStage.getRuntimeStatistics.rowCount)
+         */
+        ShuffleStageStaticstics(-1, -1, None)
       case shuffle: ColumnarShuffleExchangeExec =>
-        ShuffleStageStaticstics(shuffle.numPartitions, shuffle.numMappers, None)
+        ShuffleStageStaticstics(-1, -1, None)
       case _ =>
         if (plan.children.length == 1) {
           getShuffleStageStatistics(plan.children.head)

diff --git a/cpp-ch/local-engine/Parser/JoinRelParser.cpp b/cpp-ch/local-engine/Parser/JoinRelParser.cpp
@@ -310,6 +310,7 @@ DB::QueryPlanPtr JoinRelParser::parseJoin(const substrait::JoinRel & join, DB::Q
     }
     else
     {
+#if 0
         std::vector<DB::TableJoin::JoinOnClause> join_on_clauses;
         bool is_multi_join_on_clauses
             = isJoinWithMultiJoinOnClauses(table_join->getOnlyClause(), join_on_clauses, join, left_header, right_header);
@@ -321,6 +322,7 @@ DB::QueryPlanPtr JoinRelParser::parseJoin(const substrait::JoinRel & join, DB::Q
             query_plan = buildMultiOnClauseHashJoin(table_join, std::move(left), std::move(right), join_on_clauses);
         }
         else
+#endif
         {
             query_plan = buildSingleOnClauseHashJoin(join, table_join, std::move(left), std::move(right));
         }