fix

Author: andygrove

native/core/src/execution/columnar_to_row.rs

@@ -138,9 +138,10 @@ impl<'a> TypedArray<'a> {
                     .as_any()
                     .downcast_ref::<TimestampMicrosecondArray>()
                     .ok_or_else(|| {
-                        CometError::Internal(
-                            "Failed to downcast to TimestampMicrosecondArray".to_string(),
-                        )
+                        CometError::Internal(format!(
+                            "Failed to downcast to TimestampMicrosecondArray, actual type: {:?}",
+                            array.data_type()
+                        ))
                     })?,
             )),
             DataType::Decimal128(p, _) => Ok(TypedArray::Decimal128(

spark/src/main/scala/org/apache/spark/sql/comet/CometNativeColumnarToRowExec.scala

@@ -53,6 +53,9 @@ case class CometNativeColumnarToRowExec(child: SparkPlan)
   // supportsColumnar requires to be only called on driver side, see also SPARK-37779.
   assert(Utils.isInRunningSparkTask || child.supportsColumnar)
 
+  // Use the same display name as CometColumnarToRowExec for plan compatibility
+  override def nodeName: String = "CometColumnarToRow"
+
   override def output: Seq[Attribute] = child.output
 
   override def outputPartitioning: Partitioning = child.outputPartitioning