问答 2024-07-17 来自:开发者社区

Flink的并发度 可以动态更新 我改完以后 怎么确定它已经更新了?

Flink的并发度 可以动态更新 我改完以后 怎么确定它已经更新了?

问答 2024-04-14 来自:开发者社区

Flink CDC里请问flink-sql有设置source并发度为1的参数么?

Flink CDC里请问flink-sql有设置source并发度为1的参数么?其他并发大于1,没找到那个参数。 'write.tasks' = '4' ,'compaction.tasks' = '2',parallelism.default=1,是能控制source=1,'compaction.tasks' = '2','write.tasks' = '4'。但是我们是用sql文件提交的,只....

问答 2024-03-19 来自:开发者社区

Flink CDC 里mysql source并发度大于1,在每个keyby分区里面数据是排序的吗?

Flink CDC 里mysql source并发度大于1,做了keyby,在每个keyby分区里面数据是排序的吗?

问答 2024-01-04 来自:开发者社区

请问一下Flink,咱们这个平台怎么关闭 动态调整并发度 的功能?

请问一下Flink,咱们这个平台怎么关闭 动态调整并发度 的功能? 因为我在测试环境,用的和生产环境相同的Jar包, 测试环境不想调整那么放开调整那么多并发度, 设置了全局并发度,好像也没控制住

问答 2023-12-10 来自:开发者社区

Flink我一个作业4000个并发度,jobmanager内存大概给多少?

Flink我一个作业4000个并发度,jobmanager内存大概给多少?

问答 2023-11-22 来自:开发者社区

flink-cdc pg支持多并发启动 然后变为增量后并发度变为1,其他slot回收 吗?

flink-cdc pg支持多并发启动 然后变为增量后并发度变为1,其他slot回收 吗?我看oracle sqlserver mysql支持这些配置 pg说明文档中没写?

问答 2023-11-21 来自:开发者社区

flink cdc的时候并发度如何? 是每个表一个topic吗?

flink cdc的时候并发度如何? 是每个表一个topic吗?

问答 2023-11-21 来自:开发者社区

Flink CDC全量初始化慢怎么能快点呢 加并行度吗?并发度 和topic是啥关系?

Flink CDC全量初始化慢怎么能快点呢 加并行度吗?并发度 和topic是啥关系?

问答 2022-12-04 来自:开发者社区

大佬们Flink CDC ,addSink设置多个并发度的时候,会不会造成数据不一致啊?

大佬们Flink CDC ,addSink设置多个并发度的时候,会不会造成数据不一致啊?

问答 2021-12-02 来自:开发者社区

Flink SQL并发度设置问题

Flink SQL中Source和sink可以通过修改connector配置实现并发度配置,而其他算子的并发度都是根据Source并发度来设置的,这样最多是128个并发度。但是有些算子做聚合等处理,128并发明显不够这个应该怎么解决呢?支持通过配置设置其他算子并发度吗?*来自志愿者整理的flink邮件归档

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

产品推荐

实时计算 Flink

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

+关注