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

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

实时计算 Flink版是不是和机器网络带宽啥的有关系?

实时计算 Flink版消费kafka只有一个或者几个分区数据存在积压,我们配置了host还是有这种情况,然后吧日志打印改成debug模式消费就变好了,是不是和机器网络带宽啥的有关系?

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC里这是哪里配置给低了嘛 ?我看了下机器还有内存 cpu也够用,所以是怎么回事?

Flink CDC里这是哪里配置给低了嘛 ?我看了下机器还有内存 cpu也够用,所以是怎么回事?

Flink CDC计算任务导致 机器的网络pps 比较高, 一般排查哪些点。 滑动窗口会是一个点吗?

Flink CDC计算任务导致 机器的网络pps 比较高, 一般排查哪些点。 滑动窗口会是一个点吗?

Flink计算产生了大量的pps 包,导致机器网络不稳定有人遇到过这样问题吗?

Flink计算产生了大量的pps 包,导致机器网络不稳定有人遇到过这样问题吗?

Flink CDC中postgresql 其中一台机器做了主从切换,你们有碰到过这个问题吗?

Flink CDC中postgresql 其中一台机器做了主从切换,然后我的flink作业重启后一直读不到该机器的任何变更数据 整整等了3个多小时,又开始同步了。。 你们有碰到过这个问题吗?

大佬们,Flink CDC Standalone模式(3台机器)怎么设置checkpoint的位置?

大佬们,Flink CDC Standalone模式(3台机器)怎么设置checkpoint的位置,不依赖hdfs或者s3,有没有什么好的解决办法?

flink任务从intel x86机器迁移到arm机器, 报错怎么解决?

flink任务从intel x86机器迁移到arm机器, 从checkpoint启动 state rockdb报错 怎么解决?Snappy not supported or corrupted Snappy compressed block contents,

实时计算Flink中我在SQL开发中调试程序,能远程登录一下Session分配的机器?

实时计算Flink中 我在SQL开发中,调试程序,能远程登录一下Session分配的机器,看机器上内容和运行结果吗?

实时计算Flink我能登录机器看我程序运行的结果,和机器上文件内容是否正确吗?

实时计算Flink我能登录机器看我程序运行的结果,和机器上文件内容是否正确吗?

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

产品推荐

社区圈子

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

实时计算 Flink版机器相关内容