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

慢sql治理问题之在 Flink 中, userjar 分发问题如何优化

问题一:美团 Flink 如何优化大作业的部署流程? 美团 Flink 如何优化大作业的部署流程? 参考回答: 美团 Flink 针对大作业部署流程中的问题,进行了多方面的优化。首先,分析了 JobManager 视角的作业部署流程,找出影响部署的关键因素。然后,针对资源申请、部署和启动 Task 等环节进行了优化,比如改善资源调度策略、优化 Task...

慢sql治理问题之在 Flink 中, userjar 分发问题如何优化
问答 2024-07-30 来自:开发者社区

在 Flink 中,你们是如何优化 userjar 分发问题的?

在 Flink 中,你们是如何优化 userjar 分发问题的?

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

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

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

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

flink on yarn运行模式很多部署还是分发了,这个是什么情况?

flink on yarn运行模式,都说只要在yarn的master主机上部署flink就行了,不需要分发到数据节点,但是我看很多部署还是分发了,这个是什么情况?

问答 2023-07-24 来自:开发者社区

flink cdc中我想只保留一条消息,再分发给业务系统怎么处理?

部署多个实例,就会监听重复啊。一个集群,部署了多个节点,每个节点都通过 Flink 来监听 Mysql (全库)或者某些表的变化,当Mysql 表变化时,每个实例都收到相同的变更消息我想只保留一条消息,再分发给业务系统。部署多实例,就是想当一个实例重启时,另一个实例可以继续监听。

问答 2022-06-23 来自:开发者社区

有个问题问一下 我flink双路分发两套kafka 一套Sasl-kafka另外一套非安全ka

有个问题问一下 我flink双路分发两套kafka 一套Sasl-kafka另外一套非安全kafka 在发往 Sasl-kafka 报 导致数据发不过去 就会反压 这个应该怎么解决

文章 2022-05-24 来自:开发者社区

Flink组件之分发器

Flink 运行时架构主要包括四个不同的组件,它们会在运行流处理应用程序时协同工作:作业管理器(JobManager)、资源管理器(ResourceManager)、任务管理器(TaskManager),以及分发器(Dispatcher)。因为 Flink 是用 Java 和 Scala 实现的,所以所有组件都会运行在Java 虚拟机上。分发器的职责如下:分发器(Dispatcher)可以跨作业....

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

Flink 运行时的组件 分发器(Dispatcher)具体是什么?

Flink 运行时的组件 分发器(Dispatcher)具体是什么?

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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