问答 2023-09-27 来自:开发者社区

Flink CDC作业连接配置没问题,总报不能初始化,一直重启?

Flink CDC作业连接配置没问题,总报不能初始化,一直重启?

问答 2023-09-20 来自:开发者社区

Flink CDC这个参数设置了好像也没生效,是还需要配置其他数据吗?

Flink CDC这个参数设置了好像也没生效,是还需要配置其他数据吗?第一次全量读取的时候, 只能通过featch_size 和chunk size 来控制哈, 主要是数据量太大, chunk size的时候容易OOM. 这个还有其他方式来设置一下不?

问答 2023-09-20 来自:开发者社区

flink oracle cdc一定要配置checkpoint吗?

flink oracle cdc一定要配置checkpoint吗?

问答 2023-09-20 来自:开发者社区

Flink CDC这个错误怎么解,总是链接不上,配置都是对的?

Flink CDC这个错误怎么解,总是链接不上,配置都是对的?

问答 2023-09-19 来自:开发者社区

Flink CDC请问是我哪里配置的不对吗?

Flink CDC中我从ververica.github.io官方文档上查询到MongoDB CDC Conenctor:2.4版本MongoDBSource api中可以【通过startupOptions接口来设置启动模式,比如 .startupOptions(StartupOptions.timestamp(1667232000000L) // Start from timestamp】,【....

问答 2023-09-13 来自:开发者社区

Flink CDC这个扫库扫表的动作可以通过什么配置避吗?

Flink CDC这个扫库扫表的动作可以通过什么配置避吗。 我这边有一个库里好多零时表 4万多,把我这个任务卡死了?

问答 2023-09-13 来自:开发者社区

flink cdc 不需要依赖kafka啊, 即使配置了ha, 不就能恢复了吗?

flink cdc 不需要依赖kafka啊, 即使配置了ha, jobmanager读取checkpoint不就能恢复了吗?

问答 2023-09-13 来自:开发者社区

Flink CDC有人配置 debezium.database.history.这个参数吗?

Flink CDC有人配置 debezium.database.history.kafka.topic 这个参数吗?我现在不需要把数据序列化到kafka,之前用2.3.1没有配置该topic, 一样正常的导入数据

问答 2023-09-12 来自:开发者社区

Flink CDC 监控mysql多张表,使用的dataStream写的,配置的表名怎么写?

Flink CDC 监控mysql多张表,使用的dataStream写的,比如数据库名:account, 表名以madia开头的,配置的表名怎么写呀?我设置的:account.media. 不行,然后用的正则:account\.^(media_).* 也不行呢?

问答 2023-09-12 来自:开发者社区

Flink CDC如何配置,只传输新增操作的数据,删除操作的不传输?

问题1:Flink CDC如何配置,只传输新增操作的数据,删除操作的不传输?问题2:可以直接在flink sql里写吗?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注