无法执行路径“en_catalog”.“flinkdb”.“en_transm”java.lang.“UncertedOperationException”中的数据表

von4xj4u  于 2023-11-15  发布在  Apache
关注(0)|答案(1)|浏览(142)

我试图使用JDBCCatalog的持久目录,但我得到了错误,而创建表。
我只是想有持久表每当登录到SQL客户端会话,它的链接到我以前的issue,其中建议他们

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

字符串

rslzwgfq

rslzwgfq1#

使用模式是这样的:

CREATE CATALOG MyCatalog WITH (...);

USE CATALOG MyCatalog;

CREATE DATABASE MyDatabase;

USE MyDatabase;

CREATE TABLE MyTable ...;

字符串

相关问题