Spark SQL 语法错误:ALTER TABLE 语句缺少引号
lave2:36135 with 413.9 MiB RAM,BlockManagerId(2,slave2,36135,None) Exception in thread 'main'org.apache.spark.sql.catalystparserParseException: extraneous input 'BY expecting'((line 1,pos 71) == SQL == ALTER TABLE ods1.user info ADD PARTITION(fen_qu=20230727') PARTITION BY(fen_qu string) -------^^^
at org.apache.spark.sqlcatalyst.parser.ParseException.withCommand(ParseDriver.scala
报错的原因是在SQL语句中有语法错误。具体错误是在ALTER TABLE语句中,缺少了一个引号,导致解析器无法正确解析语句。
为了解决这个问题,您需要将SQL语句中的错误进行修正。在fen_qu=20230727'后面添加一个缺少的引号,使得SQL语句变为:
ALTER TABLE ods1.user_info ADD PARTITION (fen_qu='20230727') PARTITIONED BY (fen_qu string);
修正后的SQL语句中,我们添加了一个引号将fen_qu=20230727'包裹起来,并将PARTITION BY改为PARTITIONED BY,这是正确的语法。
修正后的SQL语句应该可以正确执行。
原文地址: https://www.cveoy.top/t/topic/p4Pe 著作权归作者所有。请勿转载和采集!