请问有人用 NAS 挂载 Flink CP | SP 吗?效果怎么样?

请问有人用 NAS 挂载 Flink CP | SP 吗?效果怎么样?

Flink CDC 里新加的表,从sp重启后,全量同步一会,就不同步了,数据条数一直不变为什么?

Flink CDC 里新加的表,从sp重启后,全量同步一会,就不同步了,数据条数一直不变为什么?scanNewlyAddedTableEnabled(true) 开了,我一直在用这个参数,之前加表都没啥问题的,都是先全量再增量

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC 里新加dwd_purchase_detail_log表后,从sp重启怎么办?

Flink CDC 里新加dwd_purchase_detail_log表后,从sp重启,发现有问题,其他表数据不正常同步了,新加的表一开始同步很快,最后一分钟才几百条,一直卡在全量阶段了,我看日志也不报错。

Flink任务做sp大概率出现 容器内存超用被kill 有朋友出现过吗 有解决办法吗?

Flink任务做sp大概率出现 容器内存超用被kill 有朋友出现过吗 有解决办法吗?1.13.5

Flink CK和SP不设置自动清理的话,系统会怎样处理,一直堆积下去吗?

Flink CK和SP不设置自动清理的话,系统会怎样处理,一直堆积下去吗?

Flink CDC消费kafka停止后,使用sp启动,有的拿到的偏移量是-1,导致中间丢数据?

Flink CDC消费kafka停止后,使用sp启动,15个分区都有数据,但是有的拿到的偏移量是-1,导致中间丢数据?

Flink CDC中timestamp 模式用sp启动报错?

Flink CDC中timestamp 模式用sp启动报错?就我昨天发你的脚本,什么都没动,非sp启动,然后五分钟后开始采集数据了,这时候是正常的,然后停止任务生成sp,这时候用sp启动任务,就报了图片上的错误

Flink CDC提示大概意思是改了代码不能从sp恢复,有遇见过么?

Flink CDC中mysql-cdc 在做这个自动加表,从savepoint恢复失败,提示大概意思是改了代码不能从sp恢复,有大佬遇见过么?

flink-oracle-cdc 2.4.1 cancel任务后从sp恢复的时候提示这个错误?

flink-oracle-cdc 2.4.1 cancel任务后从sp恢复的时候提示这个错误?2023-09-05 10:53:31,766 ERROR io.debezium.pipeline.ErrorHandler [] - Producer failurejava.sql.SQLExcept...

大佬,Flink CDC可不可以在从sp,或是cp恢复的时候重新读取下元数据,这个新增字段的时候就?

大佬,Flink CDC可不可以在从sp,或是cp恢复的时候重新读取下元数据,这个新增字段的时候就只用停掉,然后再接上scn就好了?

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

产品推荐

社区圈子

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