文章 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-06-05 来自:开发者社区

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

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

问答 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-01 来自:开发者社区

Flink CDC里在这可以有设置并行度的参数么,貌似没有吧,只有sink端可以吧?

'connector' = 'mysql-cdc', 'hostname' = '{}', 'port' = '{}', 'database-name' = '{}', 'username' = '{}', 'password' = '{}', ...

文章 2024-03-18 来自:开发者社区

在Flink中,你可以通过以下方法为join操作设置并行度

在Flink中,你可以通过以下方法为join操作设置并行度: 使用ExecutionEnvironment的setParallelism方法。首先,你需要创建一个ExecutionEnvironment实例,然后调用setParallelism方法来设置并行度。例如: ExecutionEnvironment env =...

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

Flink CDC我就设置了每个算子的并行度为8 有其他api可以设置动态切换的么?

Flink CDC我就设置了每个算子的并行度为8 有其他api可以设置动态切换的么?

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

flink sql中间insert xx select xx 的算子可以设置并行度么?

flink sql除了source 和sink,中间insert xx select xx 的算子可以设置并行度么?embed 配置如下:

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

flink cdc,当我设置多并行度的时候,他是如何保障顺序的问题的?

flink cdc,当我设置多并行度的时候,他是如何保障顺序的问题的?如何保障,后面的不会被先消费掉

问答 2023-08-01 来自:开发者社区

请教个Flink CDC问题。 现在框架里,如果源端设置的1个并行度,多个切片的情况下,每个切片的?

请教个Flink CDC问题。现在框架里,如果源端设置的1个并行度,多个切片的情况下,每个切片的高低水位肯定是不能完全衔接上,如果这些间隙内有数据变更,是不是就漏了?

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

产品推荐

实时计算 Flink

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

+关注