From 24fedf77e7a7a9bce5db1df3dd7d7bed4f95b29c Mon Sep 17 00:00:00 2001 From: xuzifu666 <1206332514@qq.com> Date: Thu, 15 Aug 2024 17:04:41 +0800 Subject: [PATCH] [spark] Fix Compatibility in getting NamedReference of spark320 (#3968) --- .../src/main/scala/org/apache/spark/sql/PaimonUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala index 658d43848f45..f4e551d836f0 100644 --- a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala +++ b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala @@ -65,7 +65,7 @@ object PaimonUtils { } def fieldReference(name: String): NamedReference = { - FieldReference.column(name) + FieldReference(name) } def bytesToString(size: Long): String = {