You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2022/12/06 17:04:00 UTC

[jira] [Created] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException

Alex Sorokoumov created FLINK-30317:
---------------------------------------

             Summary: Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException
                 Key: FLINK-30317
                 URL: https://issues.apache.org/jira/browse/FLINK-30317
             Project: Flink
          Issue Type: Bug
          Components: Table Store
            Reporter: Alex Sorokoumov


{noformat}
Flink SQL> CREATE CATALOG my_catalog WITH (
>   'type'='table-store',
>   'warehouse'='s3://bucket/my-tablestore'
> );
[INFO] Execute statement succeed.

Flink SQL> USE CATALOG my_catalog;
[INFO] Execute statement succeed.

Flink SQL> CREATE TABLE word_count (
>     word STRING PRIMARY KEY NOT ENFORCED,
>     cnt BIGINT
> );
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException: Database default does not exist in Catalog my_catalog. {noformat}

Creating the table in the default catalog works though:

{noformat}
Flink SQL> use catalog default_catalog;
[INFO] Execute statement succeed.

Flink SQL> CREATE TABLE word_count (
>       word STRING PRIMARY KEY NOT ENFORCED,
>       cnt BIGINT
>  ) WITH (
>    'connector'='table-store',
>    'path'='s3://bucket/my-tablestore',
>    'auto-create'='true'
> );
[INFO] Execute statement succeed.
{noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)