[
https://issues.apache.org/jira/browse/FLINK-29680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-29680:
----------------------------------
Summary: Create Database with DatabaseName "default" fails (was:
Create/Use Database with DatabaseName "default" fails)
> Create Database with DatabaseName "default" fails
> -------------------------------------------------
>
> Key: FLINK-29680
> URL: https://issues.apache.org/jira/browse/FLINK-29680
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Affects Versions: 1.15.1
> Reporter: Prabhu Joseph
> Priority: Minor
>
> Create/Use Database with DatabaseName "default" fails in both Default and
> Hive Dialect.
> *Default Dialect:*
> {code:java}
> Flink SQL> create database default;
> #fails{code}
> *Hive Dialect:*
> {code:java}
> Flink SQL> create catalog myhive with ('type' = 'hive', 'hive-conf-dir' =
> '/etc/hive/conf');
> Flink SQL> use catalog myhive;
> Flink SQL> show databases;
> +---------------+
> | database name |
> +---------------+
> | default |
> | emr |
> +---------------+
> 2 rows in set
> Flink SQL> use emr;
> #works
> Flink SQL> use default;
> #fails
> {code}
>
> *Exception:*
> {code:java}
> Caused by: org.apache.flink.sql.parser.impl.ParseException: Encountered
> "default" at line 1, column 17.
> Was expecting one of:
> <BRACKET_QUOTED_IDENTIFIER> ...
> <QUOTED_IDENTIFIER> ...
> <BACK_QUOTED_IDENTIFIER> ...
> <HYPHENATED_IDENTIFIER> ...
> <IDENTIFIER> ...
> <UNICODE_QUOTED_IDENTIFIER> ...
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParserImpl.java:42459)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.jj_consume_token(FlinkSqlParserImpl.java:42270)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.IdentifierSegment(FlinkSqlParserImpl.java:26389)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.CompoundIdentifier(FlinkSqlParserImpl.java:26869)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreateDatabase(FlinkSqlParserImpl.java:4188)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreateExtended(FlinkSqlParserImpl.java:6583)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreate(FlinkSqlParserImpl.java:23158)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmt(FlinkSqlParserImpl.java:3507)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmtList(FlinkSqlParserImpl.java:2911)
> ~[?:?]
> at
> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.parseSqlStmtList(FlinkSqlParserImpl.java:287)
> ~[?:?]
> at org.apache.calcite.sql.parser.SqlParser.parseStmtList(SqlParser.java:193)
> ~[?:?]
> at
> org.apache.flink.table.planner.parse.CalciteParser.parseSqlList(CalciteParser.java:77)
> ~[?:?]
> at
> org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101)
> ~[?:?]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$parseStatement$1(LocalExecutor.java:172)
> ~[flink-sql-client-1.15.1.jar:1.15.1]
> at
> org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
> ~[flink-sql-client-1.15.1.jar:1.15.1]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.parseStatement(LocalExecutor.java:172)
> ~[flink-sql-client-1.15.1.jar:1.15.1]
> ... 11 more
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
