[spark] Fix compatibility with spark3.3

Zouxxyy · Nov 15, 2023 · 0cdf0d7 · 0cdf0d7
1 parent bb2f7d8
commit 0cdf0d7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 deletions.
diff --git a/...spark-common/src/main/java/org/apache/paimon/spark/analysis/NoSuchProcedureException.java b/...spark-common/src/main/java/org/apache/paimon/spark/analysis/NoSuchProcedureException.java
@@ -18,17 +18,12 @@
 
 package org.apache.paimon.spark.analysis;
 
-import org.apache.spark.SparkThrowableHelper;
 import org.apache.spark.sql.connector.catalog.Identifier;
 
-import java.util.Collections;
-
 /** Thrown by a catalog when a stored procedure cannot be found. */
 public class NoSuchProcedureException extends RuntimeException {
 
     public NoSuchProcedureException(Identifier identifier) {
-        super(
-                SparkThrowableHelper.getMessage(
-                        "Procedure " + identifier + " is not found", Collections.emptyMap()));
+        super("Procedure " + identifier + " is not found");
     }
 }
diff --git a/.../org/apache/spark/sql/catalyst/plans/logical/PaimonDynamicPartitionOverwriteCommand.scala b/.../org/apache/spark/sql/catalyst/plans/logical/PaimonDynamicPartitionOverwriteCommand.scala
@@ -67,5 +67,6 @@ case class PaimonDynamicPartitionOverwriteCommand(
     ).run(sparkSession)
   }
 
-  override def storeAnalyzedQuery(): Command = copy(query = query)
+  // Do not annotate with override here to maintain compatibility with Spark 3.3-.
+  def storeAnalyzedQuery(): Command = copy(query = query)
 }