From 642d9f5afdddb5b9ccb1fa89e9c239909074d5bf Mon Sep 17 00:00:00 2001
From: Hongze Zhang <hongze.zhang@intel.com>
Date: Fri, 19 Jan 2024 16:45:11 +0800
Subject: [PATCH] fixup

---
 .../glutenproject/execution/HashJoinExecTransformer.scala  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/gluten-core/src/main/scala/io/glutenproject/execution/HashJoinExecTransformer.scala b/gluten-core/src/main/scala/io/glutenproject/execution/HashJoinExecTransformer.scala
index 046ccfb3cd9..8fbaa89ca96 100644
--- a/gluten-core/src/main/scala/io/glutenproject/execution/HashJoinExecTransformer.scala
+++ b/gluten-core/src/main/scala/io/glutenproject/execution/HashJoinExecTransformer.scala
@@ -171,7 +171,8 @@ trait HashJoinLikeExecTransformer
   override def outputPartitioning: Partitioning = joinBuildSide match {
     case BuildLeft =>
       joinType match {
-        case _: InnerLike | RightOuter => expandPartitioning(right.outputPartitioning)
+        case _: InnerLike => expandPartitioning(right.outputPartitioning)
+        case RightOuter => right.outputPartitioning
         case LeftOuter => left.outputPartitioning
         case FullOuter => UnknownPartitioning(left.outputPartitioning.numPartitions)
         case x =>
@@ -180,8 +181,8 @@ trait HashJoinLikeExecTransformer
       }
     case BuildRight =>
       joinType match {
-        case _: InnerLike | LeftOuter | LeftSemi | LeftAnti | _: ExistenceJoin =>
-          expandPartitioning(left.outputPartitioning)
+        case _: InnerLike => expandPartitioning(left.outputPartitioning)
+        case LeftOuter | LeftSemi | LeftAnti | _: ExistenceJoin => left.outputPartitioning
         case RightOuter => right.outputPartitioning
         case FullOuter => UnknownPartitioning(right.outputPartitioning.numPartitions)
         case x =>