[
https://issues.apache.org/jira/browse/HUDI-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Sumit closed HUDI-4325.
-----------------------------
Resolution: Fixed
> spark sql procedure cause ParseException with semicolon
> -------------------------------------------------------
>
> Key: HUDI-4325
> URL: https://issues.apache.org/jira/browse/HUDI-4325
> Project: Apache Hudi
> Issue Type: Bug
> Components: spark-sql
> Reporter: KnightChess
> Assignee: KnightChess
> Priority: Minor
> Labels: pull-request-available
> Fix For: 0.12.0
>
>
> recurrent:
> spark.sql("call show_commits(table => 'delete_error_test', limit =>
> 10);").show(false)
>
> {code:java}
> Exception in thread "main"
> org.apache.spark.sql.catalyst.parser.ParseException:
> mismatched input 'call' expecting {'(', 'ADD', 'ALTER', 'ANALYZE', 'CACHE',
> 'CLEAR', 'COMMENT', 'COMMIT', 'CREATE', 'DELETE', 'DESC', 'DESCRIBE', 'DFS',
> 'DROP', 'EXPLAIN', 'EXPORT', 'FROM', 'GRANT', 'IMPORT', 'INSERT', 'LIST',
> 'LOAD', 'LOCK', 'MAP', 'MERGE', 'MSCK', 'REDUCE', 'REFRESH', 'REPLACE',
> 'RESET', 'REVOKE', 'ROLLBACK', 'SELECT', 'SET', 'SHOW', 'START', 'TABLE',
> 'TRUNCATE', 'UNCACHE', 'UNLOCK', 'UPDATE', 'USE', 'VALUES', 'WITH'}(line 1,
> pos 0)== SQL ==
> call show_commits(table => 'delete_error_test', limit => 10);
> ^^^ at
> org.apache.spark.sql.catalyst.parser.ParseException.withCommand(ParseDriver.scala:265)
> at
> org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parse(ParseDriver.scala:126)
> at
> org.apache.spark.sql.execution.SparkSqlParser.parse(SparkSqlParser.scala:51)
> at
> org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parsePlan(ParseDriver.scala:77)
> at
> org.apache.spark.sql.parser.HoodieSpark3_2ExtendedSqlParser.$anonfun$parsePlan$1(HoodieSpark3_2ExtendedSqlParser.scala:44)
> at
> org.apache.spark.sql.parser.HoodieSpark3_2ExtendedSqlParser.parse(HoodieSpark3_2ExtendedSqlParser.scala:80)
> at
> org.apache.spark.sql.parser.HoodieSpark3_2ExtendedSqlParser.parsePlan(HoodieSpark3_2ExtendedSqlParser.scala:41)
> at
> org.apache.spark.sql.parser.HoodieCommonSqlParser.$anonfun$parsePlan$1(HoodieCommonSqlParser.scala:44)
> at
> org.apache.spark.sql.parser.HoodieCommonSqlParser.parse(HoodieCommonSqlParser.scala:84)
> at
> org.apache.spark.sql.parser.HoodieCommonSqlParser.parsePlan(HoodieCommonSqlParser.scala:41)
> at
> org.apache.spark.sql.SparkSession.$anonfun$sql$2(SparkSession.scala:616)
> at
> org.apache.spark.sql.catalyst.QueryPlanningTracker.measurePhase(QueryPlanningTracker.scala:111)
> at
> org.apache.spark.sql.SparkSession.$anonfun$sql$1(SparkSession.scala:616)
> at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:775)
> at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:613)
> at org.example.HudiDeleteTest$.main(HudiDeleteTest.scala:128)
> at org.example.HudiDeleteTest.main(HudiDeleteTest.scala) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
