问答 2024-02-26 来自:开发者社区

Flink CDC里flink-hudi-bundle的hudi sink好像不是继承这个吧?

Flink CDC里flink-hudi-bundle的hudi sink好像不是继承Sink接口的,flink cdc的pipeline配置方式好像只适配继承Sink接口的sink,有没简单一点的改造方法?能让flink cdc 3.0用pipeline配置文件方式配置source和hudi sink去跑?我看doris的flink的connector都是继承Sink接口的,hudi却不是。

问答 2024-02-06 来自:开发者社区

flink cdc pipeline配置文件那种sink支持MySQL吗?

flink cdc pipeline配置文件那种sink支持MySQL吗?就是想从一个mysql 同步到另一个mysql 。一直报这个错怎么解决?

问答 2024-02-06 来自:开发者社区

Flink CDC里sink到kafka出现的报错怎么办?

Flink CDC里sink到kafka出现的报错怎么办?启动的时候应该是创建了topic

问答 2024-02-06 来自:开发者社区

Flink CDC里如果上游没办法限制数据流量 sink doris有办法限制写入流量吗 ?

Flink CDC里如果上游没办法限制数据流量 sink doris有办法限制写入流量吗 ?现在遇到情况 sink doris Records Sent几百万了 但是doris里一条数据没有 怎么办?

问答 2024-02-06 来自:开发者社区

Flink CDC支持这种写法吗?将kafka的数据sink到postgresql和kafka行吗?

INSERT INTO my_postgres_sink, my_kafka_sink SELECT * FROM kafka_table;Flink CDC里支持这种写法吗?将kafka的数据sink到postgresql和kafka可以不?

问答 2024-02-06 来自:开发者社区

flink cdc 3.0 cli 必须指定sink 表名吗?

flink cdc 3.0 cli 必须指定sink 表名吗, route 中的 sink-table 不能使用正则吗?其实就是想把目标库的名称变一下,比如: source-table: test.. , sink-table : ods_test..。

问答 2024-02-06 来自:开发者社区

Flink CDC里tidb 同步数据自定义sink 老是出现这两个报错 是怎么回事呢?

Flink CDC里tidb 同步数据自定义sink 老是出现这两个报错 是怎么回事呢?连接是用的 flink sql 写是自定义sink。这个是偶尔出现 我看源码那儿 我按理说数据是有的 任务不会一会儿正常一会空指针吧?

问答 2024-02-01 来自:开发者社区

Flink CDC里MySQL CDC Pipeline 连接器 支持配置sink到mysql吗?

Flink CDC里MySQL CDC Pipeline 连接器 支持配置sink到mysql吗?

文章 2024-01-28 来自:开发者社区

Flink CDC 中,Sink: clean_commits 步骤的并行度

Flink CDC 中,Sink: clean_commits 步骤的并行度是由 Hudi 控制台配置决定的。您可以通过以下方式修改 Hudi 控制台的配置: 打开 Hudi 控制台,找到 "hive-site.xml" 文件。在文件中添加以下配置项: <property> <name>hoodi...

问答 2024-01-18 来自:开发者社区

flink cdc支持sink到mongo吗?

flink cdc支持sink到mongo吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注