开发者社区大数据与机器学习实时计算 Flink 正文

Flink CDC可以运行时可以修改并行度吗？根据时间来控制并行度

展开

收起

wenti 2023-02-06 15:32:56 164 版权

2 条回答

写回答

取消提交回答

哈哈是我

Savepoint：触发作业的 Savepoint。Savepoint 是 Flink 提供的一种机制，它可以在不停止作业的情况下，保存当前的状态到持久化存储中。通过Savepoint，可以在作业更新或调整并行度后恢复状态。

停止作业：在有了 Savepoint 之后，停止当前运行的作业。

修改并行度：重新提交作业时，指定新的并行度参数。可以通过 Flink 的命令行接口或编程方式进行。

从 Savepoint 恢复：使用之前生成的Savepoint来恢复作业的状态，从而确保作业可以继续处理数据而不会丢失状态信息。

2024-02-26 17:46:08

赞同展开评论
co63oc_

GitHub https://github.com/co63oc/cloud

Apache Flink并行度设置详解https://cloud.tencent.com/developer/article/1613761

2023-02-11 17:10:39

赞同展开评论

问答分类：

流计算实时计算 Flink版

问答标签：

实时计算 Flink版CDC 实时计算 Flink版运行实时计算 Flink版并行度实时计算 Flink版运行时实时计算 Flink版cdc并行度

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

Flink CDC中两阶段提交是指某个sink里还是所有sink一起成功才成功，否则所有回滚吗？

请问flink sql 事件时间 Temporal Join 设计多个并行度不触发计算

245

Flink的TableSourceScan这个算子支持并行度吗？

106

在Flink CDC中如下得到的并行度一直是1，为什么？

Flink CDC 读取 pg 怎么新增并行度呢？

不通过web界面的方式，flink on yarn怎么查看每个并行度处理数据的情况？

139

Flink消费SLS时对应源表并行度应参考什么设置

在Flink CDC中那我如果env设置的是4，增量的时候也是单并行度？

在Flink CDC中cdc全量是多并行度增量是单并行度？

116

在 docker 上部署 Flink Task，只能通过 UI Port 来查看当前任务吗？

151

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

解析pg_stat_replication状态字段的枚举值

构建高效的实时数据管道：Flink、Kafka、CnosDB 的完美结合

实现千表入湖之Apache Paimon篇

OBS特效与OBS美颜一步到位：专为新手主播打造的YY开播工具集成方案

Flink CDC可以运行时可以修改并行度吗？根据时间来控制并行度

实时计算 Flink

相关文章

热门讨论

热门文章