问答 2023-07-24 来自:开发者社区

Flink CDC中停任务新加表,只能从全量阶段开始嘛,能不能跳过全量,直接进增量呀?

Flink CDC中停任务新加表,只能从全量阶段开始嘛,能不能跳过全量,直接进增量呀?我重启任务 start mode用的latest-offset,它也是从全量阶段开始,scan.incremental.snapshot.enabled把这个参数改成false能行不?

问答 2023-07-24 来自:开发者社区

Flink CDC中datastream模式同步完后能自动停止任务吗?

Flink CDC中datastream模式同步完后能自动停止任务吗?我想基于flinkcdc做数据加载,加载完成后做一些表关联结算计算判断是否符合数据归档条件。

问答 2023-07-24 来自:开发者社区

Flink CDC中都是怎么接的呀?一张表一个任务吗?

Flink CDC中都是怎么接的呀?一张表一个任务吗?我们考虑是通过cdc整库接入Kafka,小表写入相同的topic,大表单独topic,再通过flink 消费分流进行分流。

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

请问flink CDC中flink on K8s flink任务状态实时监控 有什么好的方式吗?

请问flink CDC中flink on K8s flink任务状态实时监控 有什么好的方式吗?

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

请问那个checkpoint,是不是代码设置了然后flink平台也设置了,如果任务中途死了,还存在?

请问那个checkpoint,是不是代码设置了然后flink平台也设置了,然后如果任务中途死了,checkpoint还会存在对吧,任务回复时候会回到最近一个savepoint点对吧?这个savepoint是有cdc程序自己触发对吧,只要代码设置了savepoint参数。savepoint都存起来了,破灭也不会影响上次的记录点。

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

请问flink cdc中我mysql的CDC在任务停止后 连接自然断开 什么原因?

请问flink cdc中我mysql的CDC在任务停止后 连接自然断开 但是我看mysql端的内存没有释放,什么原因?

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

请问flink升级之后如何保持流任务继续运行呢?

请问flink升级之后如何保持流任务继续运行呢?

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

请教下 flink on k8s checkpoint 到s3上开始可以成功,任务跑一段时间后失败?

请教下 flink on k8s checkpoint 到s3上开始可以成功,任务跑一段时间后checkpoint 持续失败 有遇到吗?

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

请问flink cdc 中这个错误是什么问题,oracle flink任务启动,只要新数据写入就报错

请问flink cdc 中这个错误是什么问题,oracle flink任务启动,只要有新的数据写入就报这个错。

问答 2023-07-18 来自:开发者社区

大佬们个看一下报Flink这个错怎么处理呀?我加了个puthbase的任

大佬们个看一下报Flink这个错怎么处理呀,我加了个puthbase的任务,jar里的所有任务启动都报这个错误?

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

产品推荐

阿里云实时计算Flink

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

+关注