文章 2024-10-14 来自:开发者社区

大数据-128 - Flink 并行度设置 细节详解 全局、作业、算子、Slot

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-128 - Flink 并行度设置 细节详解 全局、作业、算子、Slot
文章 2024-10-14 来自:开发者社区

大数据-123 - Flink 并行度 相关概念 全局、作业、算子、Slot并行度 Flink并行度设置与测试

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-123 - Flink 并行度 相关概念 全局、作业、算子、Slot并行度 Flink并行度设置与测试
问答 2024-08-28 来自:开发者社区

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

Flink这个任务延迟比较高 主要是source端造成的,TableSourceScan这个算子支持并行度吗?设置的并行度是5 但是延迟还是很高

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

实时计算 Flink版产品使用问题之在YARN集群上运行时,如何查看每个并行度的详细处理数据情况

问题一:根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本? 我这边的业务场景是需要把用户点击到下单完成的整个业务串起来,形成一个业务宽表,时延5分钟左右,根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本? 参考答案: 后者 更节约成本 关于...

实时计算 Flink版产品使用问题之在YARN集群上运行时,如何查看每个并行度的详细处理数据情况
文章 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-08-14 来自:开发者社区

Flink就是有一个并行度新增数据,则其他并行度数据可以实时共享吗?

Flink如果使用这个operate state方式,我并行度开启5个,其中又一个并行度put新的key值,则其他4个可以快速共享获取那个新增的key值吗(实时job)? 就是有一个并行度新增数据,则其他并行度数据可以实时共享吗?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版操作报错合集之实时计算 Flink版操作报错合集之使用两个并行度时会报错,一个并行度不会报错,是什么原因

问题一:Flink CDC在哪里可以找到url报错提示? Flink CDC在哪里可以找到url报错提示?2023-12-29 15:46:13,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - PostPartition -> Sink Writer: Flink CDC Event Sink...

实时计算 Flink版操作报错合集之实时计算 Flink版操作报错合集之使用两个并行度时会报错,一个并行度不会报错,是什么原因
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之有5个并行度,但只有其中1个并行度有数据,是什么导致的

问题一:flinkcdc能接kafka开了权限认证吗? flinkcdc能接kafka开了权限认证吗? 参考答案: Flink CDC 可以接入开启了权限认证的 Kafka。在接入过程中,需要进行以下步骤:首先,如果您的 Kafka 集群需要账号和密码认证,需要安装 Kafka 认证插件,例如使用 Kafka 官方提供的 SASL/PLAIN 认证插件...

实时计算 Flink版产品使用问题之有5个并行度,但只有其中1个并行度有数据,是什么导致的
问答 2024-07-16 来自:开发者社区

flink1.18里面,得到的并行度一直是1,有谁知道怎么回事吗?

flink1.18里面,我自定义继承了RichParallelSourceFunction,但getNumberOfParallelSubtasks得到的并行度一直是1,有谁知道怎么回事吗?

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

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

在Flink CDC中我自定义继承了RichParallelSourceFunction,但getNumberOfParallelSubtasks得到的并行度一直是1,为什么?

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

产品推荐

阿里云实时计算Flink

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

+关注