Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效怎么办?

Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效,从而引发作业一直重启失败,flinkcdc有什么 方法可以规避这种情况吗?没有用过gtid,是需要rds这边配置吗?确实是凌晨低峰进行的。

[帮助文档] Flink动态扩缩容与参数动态更新

动态更新Flink作业参数可以实现更快的参数配置生效,减少作业启停对业务的中断时间,方便进行TM动态扩缩容和系统检查点的排查。

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

[帮助文档] Flink资源扩缩容

实时计算Flink版支持对工作空间和项目空间的资源进行调整。您可以创建多个项目空间,为每个项目空间分配单独的资源和权限,通过项目空间实现资源和权限的完全隔离。本文为您介绍如何进行工作空间和项目空间的资源调整。

关于Flink弹性扩缩容有个疑问:缩容同理(释放TM)这种能做到吗?

关于Flink弹性扩缩容有个疑问:比如Kafka12个分区,Flink任务(KafkaSource -> Process -> BDSink)On Yarn application模式,初始化的并行度也是12,但是Kafka生产者的流量有波峰波谷,波峰时就会出现反压,此时期望sink端自...

你们有flink on k8s的动态扩缩容的案例吗?可以参考一下吗?

你们有flink on k8s的动态扩缩容的案例吗?可以参考一下吗?

Flink CDC中有flink on k8s的动态扩缩容的案例吗?可以参考一下吗?

Flink CDC中有flink on k8s的动态扩缩容的案例吗?可以参考一下吗?

Flink on k8s动态扩缩容有大佬了解嘛?

Flink on k8s动态扩缩容有大佬了解嘛?

使用了一年多的flink,发现有两个痛点,一个是不能自动扩缩容,一个是启动/恢复时间过长?对运维和服

使用了一年多的flink,发现有两个痛点,一个是不能自动扩缩容,一个是启动/恢复时间过长?对运维和服务的持续性有很大的挑战,是用flink operator k8s那种吗?

各位大佬,Flink CDC怎么实现弹性扩缩容,采用什么技术?

问题1:各位大佬,Flink CDC怎么实现弹性扩缩容,采用什么技术? 问题2:是采用flink operator k8s hpa 技术吗? 细节到反压、内存、cpu等 扩缩,有没有例子?

Apache Flink成本中弹性扩缩容的优势在哪呀?

Apache Flink成本中弹性扩缩容的优势在哪呀?

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

产品推荐

社区圈子

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