SPARK-51439

pan3793 · pan3793 · commit d65638d2201b · 2025-05-16T14:58:05.000+08:00
diff --git a/extensions/spark/kyuubi-extension-spark-4-0/src/main/scala/org/apache/kyuubi/sql/KyuubiSparkSQLParser.scala b/extensions/spark/kyuubi-extension-spark-4-0/src/main/scala/org/apache/kyuubi/sql/KyuubiSparkSQLParser.scala
@@ -110,13 +110,15 @@ abstract class KyuubiSparkSQLParserBase extends ParserInterface with SQLConfHelp
     delegate.parseDataType(sqlText)
   }
 
-  /**
-   * This functions was introduced since spark-3.3, for more details, please see
-   * https://github.com/apache/spark/pull/34543
-   */
+  // SPARK-37266 (3.3.0)
   override def parseQuery(sqlText: String): LogicalPlan = {
     delegate.parseQuery(sqlText)
   }
+
+  // SPARK-51439 (4.0.0)
+  override def parseRoutineParam(sqlText: String): StructType = {
+    delegate.parseRoutineParam(sqlText)
+  }
 }
 
 class SparkKyuubiSparkSQLParser(

Original file line number	Diff line number	Diff line change
`@@ -110,13 +110,15 @@ abstract class KyuubiSparkSQLParserBase extends ParserInterface with SQLConfHelp`
`110`	`110`	`delegate.parseDataType(sqlText)`
`111`	`111`	`}`
`112`	`112`
`113`		`- /**`
`114`		`- * This functions was introduced since spark-3.3, for more details, please see`
`115`		`- * https://github.com/apache/spark/pull/34543`
`116`		`- */`
	`113`	`+ // SPARK-37266 (3.3.0)`
`117`	`114`	`override def parseQuery(sqlText: String): LogicalPlan = {`
`118`	`115`	`delegate.parseQuery(sqlText)`
`119`	`116`	`}`
	`117`	`+`
	`118`	`+ // SPARK-51439 (4.0.0)`
	`119`	`+ override def parseRoutineParam(sqlText: String): StructType = {`
	`120`	`+ delegate.parseRoutineParam(sqlText)`
	`121`	`+ }`
`120`	`122`	`}`
`121`	`123`
`122`	`124`	`class SparkKyuubiSparkSQLParser(`