问答 2024-08-12 来自:开发者社区

在Flink CDC中,mysql修改为+8后,重启了cdc服务,请问应该从哪里进行排查?

在Flink CDC中,mysql修改为+8后,重启了cdc服务,读取的时间还是多了8小时,请问应该从哪里进行排查?

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之遇到重启服务后重新执行DDL语句,该如何避免

问题一:设置了includeSchemaChanges后怎么避免每次重启都执行DDL 1、基于flink cdc2.1.0版本,设置了checkpoints和savepoints; 2、DML变更正常监听; 3、但是表结构变更,每次重启服务后表结构的变更DDL语句都要重新执行,如:time1变更ddl1,同步ddl1,重启服务后仍然会执行ddl1;在time2变更ddl2...

实时计算 Flink版产品使用问题之遇到重启服务后重新执行DDL语句,该如何避免
问答 2024-04-10 来自:开发者社区

java flink + kafka,后端状态放hdfs后,每次重启服务,又从最早的消息开始消费问题

java flink + kafka,后端状态放hdfs后,每次重启服务,又从最早的消息开始消费,不是每次会提交检查点到hdfs吗,重启后,不应从最新的检查点开始处理么?

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

有知道使用flink cdc 重启服务之后目标数据库不会进行删除是什么原因吗?

有大佬知道使用flink cdc 在服务启动时候进行增删除操作都是可以的,但在服务关闭后对源数据库进行删除操作,重启服务之后目标数据库不会进行删除是什么原因吗?

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

产品推荐

阿里云实时计算Flink

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

+关注