Could not execute CreateTable in path `en_catalog`.`flinkdb`.`en_trans` java.lang.UnsupportedOperationException

by

I am trying to use JDBCCatalog for durable catalog, but i’ve gotten error while creating table.

I am just trying to have durable table whenever login to sql client session, it’s link to my previous issue which advised by them


CREATE CATALOG tadika_catalog WITH(
    'type' = 'jdbc',
    'default-database' = 'flinkdb',
    'username' = 'flink',
    'password' = 'flink',
    'base-url' = 'jdbc:mysql://....:3306'
);


Flink SQL> CREATE TABLE en_trans (
>   `ID` INTEGER,
>   `purchaseId` INTEGER
> ) WITH (
>   'connector' = 'kafka',
>   'topic' = 'en_trans',
>   'properties.bootstrap.servers' = 'kafka-netlex-cp-kafka:9092,....',
>   'properties.group.id' = 'en_group_test',
>   'key.format' = 'avro-confluent',
>   'value.format' = 'avro-confluent',
>   'key.avro-confluent.url' = 'http://kafka-netlex-cp-schema-registry:8081',
>   'value.avro-confluent.url' = 'http://kafka-netlex-cp-schema-registry:8081'
> );


.....
.....
caused by: org.apache.flink.table.api.TableException: Could not execute CreateTable in path `en_catalog`.`flinkdb`.`en_trans`

...
...
...


[ERROR] Could not execute SQL statement. Reason:
java.lang.UnsupportedOperationException

The usage pattern is this:

CREATE CATALOG MyCatalog WITH (...);

USE CATALOG MyCatalog;

CREATE DATABASE MyDatabase;

USE MyDatabase;

CREATE TABLE MyTable ...;

Leave a Comment