Remove unneeded supportedDataType guard

apache · Aug 13, 2024 · ae9c6ca · ae9c6ca
1 parent 7fac289
commit ae9c6ca
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -2724,12 +2724,6 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
           return None
         }
 
-        val keyTypes = (join.leftKeys ++ join.rightKeys).map(_.dataType)
-        if (keyTypes.exists(!supportedDataType(_, allowStruct = true))) {
-          withInfo(join, "Unsupported data type in join keys")
-          return None
-        }
-
         if (join.buildSide == BuildRight && join.joinType == LeftAnti) {
           withInfo(join, "BuildRight with LeftAnti is not supported")
           return None