文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之如何在EMR-Flink的Flink SOL中针对source表单独设置并行度

问题一:请问:Flink1.13.6版本除了升级flink版本外还有其他解决办法吗? 请问:Flink1.13.6版本的单节点flink出现“Apache Flink Dashboard未授权访问导致任意Jar包上传漏洞”这个问题,除了升级flink版本外还有其他解决办法吗? 参考答案: "Flink Dashboard未授权访问导致任意Jar包上传漏...

实时计算 Flink版产品使用问题之如何在EMR-Flink的Flink SOL中针对source表单独设置并行度
问答 2024-05-14 来自:开发者社区

请教一下Flink,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?

请教一下Flink,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?比如kafka source表。 kafka source表如果使用全局并行度的话灵活度会很差,全局并行度比较多的话kafka-topic也没那么多分区。

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

请教一下,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?

请教一下,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?比如kafka source表。 kafka source表如果使用全局并行度的话灵活度会很差,全局并行度比较多的话kafka-topic也没那么多分区?

问答 2024-05-08 来自:开发者社区

Flink source这是不是还是单并行度消费,其他并行度消费不到?

Flink source这是不是还是单并行度消费,其他并行度消费不到?

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

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,可以做到这个效果不?

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位或者其他特性分发到其他taskmanager了吗?

文章 2024-02-26 来自:开发者社区

Flink问题之source并行度不同导致任务没有数据落地如何解决

问题一:‘=-yD Kerberos 认证问题 大家好 我们这里有通过-yd动态的提交Kerberos认证参数的需求 想问下这个jira为啥被标记为了won’t fix,谢谢 https://issues.apache.org/jira/browse/FLINK-12130 参考回答: 这个问题在最新的代码上已经修复了,在flink 1.9 上...

问答 2024-02-25 来自:开发者社区

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位分发 了吗?

Flink CDC3.0增量读取source时候,是自动根据库表了么,有没有issue或者其他介绍呀?

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

Flink CDC增量source 并行度1,导致的拉取数据处理不过来,这个有啥优化方案吗?

Flink CDC增量source 并行度1,导致的拉取数据处理不过来,flink下游的数据量明显低于mysql数据量,造成延迟。这个有啥优化方案吗?

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

Flink CDC增量source 并行度1,导致消费不到binlog,这个有没好的优化方案?

Flink CDC增量source 并行度1,导致消费不到binlog,导致延迟。这个有没好的优化方案?

问答 2023-09-27 来自:开发者社区

flink mongodb cdc source多个并行度时是不是有一个额外的职责?

flink mongodb cdc source多个并行度时是不是有一个source task有额外的职责?我发现我这里75个并行度每次checkpoint时都是74个很快完成,有一个卡很久(十几分钟)完成,或者卡很久后oom?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等