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 859cb13be..6b0b10d80 100644 --- a/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala +++ b/spark/src/main/scala/org/apache/comet/expressions/CometCast.scala @@ -204,7 +204,6 @@ object CometCast { Compatible() case DataTypes.StringType => Compatible() case DataTypes.DateType => Compatible() - case _: DecimalType => Compatible() case _ => Unsupported } } diff --git a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala index f8c1a8b09..27d8e2357 100644 --- a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala +++ b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala @@ -838,8 +838,10 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper { castTest(generateTimestamps(), DataTypes.DoubleType) } - test("cast TimestampType to DecimalType(10,2)") { - castTest(generateTimestamps(), DataTypes.TimestampType) + ignore("cast TimestampType to DecimalType(10,2)") { + // https://github.com/apache/datafusion-comet/issues/1280 + // Native cast invoked for unsupported cast from Timestamp(Microsecond, Some("Etc/UTC")) to Decimal128(10, 2) + castTest(generateTimestamps(), DataTypes.createDecimalType(10, 2)) } test("cast TimestampType to StringType") {