Flink CDC里任务失败会自动清除其他机器的checkpoint文件,只保留本机吗?

问题一:Flink CDC里任务失败会自动清除其他机器的checkpoint文件,只保留本机的checkpoint么?我这个问题就是 taskmanager1执行任务 然后挂掉了,重启,taskmanager2接手这个任务,但是在2这个机器里找不到checkpoint的文件。问题二:有无其他办法呢?...

实时计算 Flink版如何设置taskmanager.out 只保留7天的数据?

实时计算 Flink版如何设置taskmanager.out 只保留7天的数据?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC里关于doris的动态分区问题,对以及建好的动态分区表,可以再次修改历史分区的保留时间嘛?

Flink CDC里关于doris的动态分区问题,对以及建好的动态分区表,可以再次修改历史分区的保留时间嘛? 在Doris中,一旦启用了动态分区功能,将不再允许用户手动管理分区。系统会根据所设定的动态分区属性来自动进行分区管理。如果已设定dynamic_partition.start,那么在动态分区...

Flink CDC里cdc2.4.0出现这个报错,是什么原因引起的呢?

Flink CDC里cdc2.4.0出现这个报错,是什么原因引起的呢?1.17中如果任务失败,在session模式中。失败任务保留2个小时就看不到了在webui。除了historyserver外。如果要失败的任务保留更长时间,还有按个参数设置呢?

Flink CDC关于doris的动态分区问题,对以及建好的动态分区表,能再次修改历史分区的保留吗?

Flink CDC里关于doris的动态分区问题,对以及建好的动态分区表,可以再次修改历史分区的保留时间嘛?

Flink这里日志有效归档期是不是指的是日志的保留时间?

Flink这里日志有效归档期是不是指的是日志的保留时间?

Flink CDC业务库 只保留近一个小时的binlog超时间的归档到oss 有啥好的解决方法么?

Flink CDC业务库 只保留近一个小时的binlog 超时间的归档到oss 有啥好的解决方法么 cdc有没有接口能读取oss的binlog?

Flink CDC中binlog只保留七天,那历史数据是不是没办法直接通过CDC同步?

Flink CDC中binlog只保留七天,那历史数据是不是没办法直接通过CDC同步?

Flink CDC添加这个ttl 状态保留时长参数为啥会给我报这个错?

Flink CDC添加这个ttl 状态保留时长参数为啥会给我报这个错?

Flink CDC要是这么短时间的ck,那这ck的文件我要是还要保留,会不会导致ck失败啊?

Flink CDC要是这么短时间的ck,那这ck的文件我要是还要保留(程序突然故障导致任务失败检查点恢复任务),会不会导致ck失败啊?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载