diff --git a/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala b/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala index 8ecfdfe49c..3ec7d068aa 100644 --- a/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala +++ b/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala @@ -151,8 +151,6 @@ object CometCast extends CometExpressionSerde[Cast] with CometExprShim { case (ArrayType(DataTypes.DateType, _), ArrayType(toElementType, _)) if toElementType != DataTypes.IntegerType && toElementType != DataTypes.StringType => unsupported(fromType, toType) - case (dt: ArrayType, DataTypes.StringType) if dt.elementType == DataTypes.BinaryType => - Incompatible() case (dt: ArrayType, DataTypes.StringType) => isSupported(dt.elementType, DataTypes.StringType, timeZoneId, evalMode) case (dt: ArrayType, dt1: ArrayType) => diff --git a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala index 4968809c29..972e4188f0 100644 --- a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala +++ b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala @@ -1555,9 +1555,9 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper { IntegerType, LongType, ShortType, - // FloatType, - // DoubleType, - // BinaryType + FloatType, + DoubleType, + BinaryType, DecimalType(10, 2), DecimalType(38, 18)).foreach { dt => val input = generateArrays(100, dt)