KnightChess created HUDI-4325:
---------------------------------
Summary: saprk 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
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.7#820007)
