update

apache · Aug 1, 2024 · c075984 · c075984
1 parent 248cd9c
commit c075984
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...park-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala b/...park-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala
@@ -89,7 +89,8 @@ class PaimonAnalysis(session: SparkSession) extends Rule[LogicalPlan] {
         val outputAttr = output
           .find(t => session.sessionState.conf.resolver(t.name, attr.name))
           .getOrElse {
-            throw new RuntimeException("xxx")
+            throw new RuntimeException(
+              s"Cannot find ${attr.name} in data columns: ${output.map(_.name).mkString(", ")}")
           }
         addCastToColumn(outputAttr, attr)
     }