Prabhu Joseph created FLINK-29680:
-------------------------------------
Summary: Create/Use 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
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)
