[FLINK-18059] Can not execute create/drop catalog statement in sql client

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Table SQL / Client
• Labels: pull-request-available
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 02/Jun/20 06:34
• Updated: 05/Jun/20 07:14
• Resolved: 05/Jun/20 07:14

Description

when executing create catalog statement (e.g. create CATALOG c1 with('type'='generic_in_memory') in sql client, the following exception will occur:

Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unsupported command: CREATE CATALOG
at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:355)
at java.util.Optional.ifPresent(Optional.java:159)
at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:213)
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:142)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:114)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)

Similar case for drop catalog.

The reason is CliClient class does not handle CREATE_CATALOG command and DROP_CATALOG command.

Issue Links

• links to: GitHub Pull Request #12435