Flink CDC导入最新的2.4.0 报出如上错误在sql 中可以看到 设置tableau 之前的2.3.0 schema-name支持啊 ? 我不想打jar包 想在flink sql实现 ,把schema-name取消 出现这个错误
如果您想在Flink SQL中使用最新的Flink CDC 2.4.0,可以按照以下步骤进行配置:
1. 下载Flink CDC 2.4.0的依赖包并解压。 2. 将解压后的依赖包中的flink-sql-connector-cdc-2.4.0.jar
文件拷贝到Flink的lib
目录中。 3. 在Flink SQL中使用Flink CDC,可以使用以下语句进行导入:
CREATE TABLE my_table (
id INT,
name STRING,
age INT
) WITH (
'connector' = 'cdc',
'database-name' = 'my_database',
'table-name' = 'my_table',
'scan.startup.mode' = 'earliest-offset',
'debezium-json.schema-include' = 'true',
'debezium-json.timestamp-format.standard' = 'ISO-8601'
);
其中,'database-name'
和'table-name'
分别指定要同步的数据库和表名,其他参数根据实际情况进行配置。
需要注意的是,Flink CDC 2.4.0目前可能不支持所有的数据库和数据源。如果您使用的数据库或数据源不在支持列表中,可能需要自行编写Flink CDC的connector,或者等待Flink CDC的后续版本提供支持。建议查阅官方文档和相关资源,以获取更多详细信息和示例
如果您想在 Flink SQL 中使用 Flink CDC 2.4.0,可以按照以下步骤进行配置:
下载 Flink CDC 2.4.0 的依赖包并解压。
将解压后的依赖包中的 flink-sql-connector-cdc-2.4.0.jar 文件拷贝到 Flink 的 lib 目录中。
在 Flink SQL 中使用 Flink CDC,可以使用以下语句进行导入:
sql
Copy
CREATE TABLE my_table (
id INT,
name STRING,
age INT
) WITH (
'connector' = 'cdc',
'database-name' = 'my_database',
'table-name' = 'my_table',
'scan.startup.mode' = 'earliest-offset',
'debezium-json.schema-include' = 'true',
'debezium-json.timestamp-format.standard' = 'ISO-8601'
);
其中,'database-name' 和 'table-name' 分别指定要同步的数据库和表名,其他参数根据实际情况进行配置。
需要注意的是,Flink CDC 2.4.0 目前还不支持所有的数据库和数据源,如果您使用的数据库或数据源不在支持列表中,可能需要自行编写 Flink CDC 的 connector,或者等待 Flink CDC 的后续版本提供支持。
看看官方文档呢,2.4的参数文档:https://github.com/ververica/flink-cdc-connectors/blob/release-2.4/docs/content/connectors/sqlserver-cdc.md,description是关键字吧,先把这一列去掉试试,https://github.com/ververica/flink-cdc-connectors/releases这里下载的,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。