We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2f96e97 commit 37a020cCopy full SHA for 37a020c
1 file changed
spark/src/main/scala/org/apache/spark/sql/comet/execution/shuffle/CometShuffleExchangeExec.scala
@@ -266,7 +266,7 @@ object CometShuffleExchangeExec
266
def supportedHashPartitioningDataType(dt: DataType): Boolean = dt match {
267
case _: BooleanType | _: ByteType | _: ShortType | _: IntegerType | _: LongType |
268
_: FloatType | _: DoubleType | _: StringType | _: BinaryType | _: TimestampType |
269
- _: TimestampNTZType | _: DateType =>
+ _: TimestampNTZType | _: DecimalType | _: DateType =>
270
true
271
case StructType(fields) =>
272
fields.nonEmpty && fields.forall(f => supportedHashPartitioningDataType(f.dataType))
0 commit comments