我试图使用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
字符串
1条答案
按热度按时间rslzwgfq1#
使用模式是这样的:
字符串