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

请教一下,一个flink集群有多个task节点,我提交一个任务,这个任务是在一个节点运行还是会在每一

请教一下,一个flink集群有多个task节点,我提交一个任务,这个任务是在一个节点运行还是会在每一个节点都会执行?

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

请问,flink sql写hive 可以支持在一个任务里面sink 多张hive表?

请问,flink sql写hive 可以支持在一个任务里面sink 多张hive表?

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

请问flink 能动态提交任务吗?任务的形态可能就是一个api的格式而不是jar 啥的,任务的形态可

请问flink 能动态提交任务吗?任务的形态可能就是一个api的格式而不是jar 啥的,任务的形态可能就是一个api的格式而不是jar 啥的。

文章 2022-06-10 来自:开发者社区

Flink 任务实时监控最佳实践(Prometheus + Grafana)打造企业级监控方案

我们都知道 Flink 任务是一个 7*24 小时不停运行的任务,所以对于任务的实时监控就显得尤为重要,因为任务运行的状态对于我们来说是一个黑盒,比如任务是否挂掉,是否存在反压,使用的内存,CPU 等情况我们是不知道的,虽然 Flink 的 UI 上面可以添加相关的 metrics 来查看,但是需要手动的一个一个添加,还是比较麻烦的,特别是在任务非常多的情况下.所以就需要有一种统一的监控方案来解....

Flink 任务实时监控最佳实践(Prometheus + Grafana)打造企业级监控方案
问答 2022-06-10 来自:开发者社区

flink啥时候可以支持在sql-client模式下,往yarn上提交任务可以指定applicati

flink啥时候可以支持在sql-client模式下,往yarn上提交任务可以指定application_id?

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

flink1.14,perjob模式提交任务运行正常,application模式提交任务运行就报这个

flink1.14,perjob模式提交任务运行正常,application模式提交任务运行就报这个错,有大佬知道什么原因吗?

文章 2022-06-09 来自:开发者社区

Flink 任务 Jackson 解析 JSON 使用不当引发的反压问题

背景最近业务方反馈线上一个 topic 的数据延迟比较大,然后我查看了这个 topic 的数据是由一个 Flink 任务产生的,于是就找到了这个任务开始排查问题,发现这个任务是一个非常简单的任务,大致的逻辑是 kafka source -> flatmap -> filter -> map -> sink kafka.中间没有复杂的操作,我在本地写了一个简单的程序模拟线上....

Flink 任务 Jackson 解析 JSON 使用不当引发的反压问题
文章 2022-06-07 来自:开发者社区

Flink on zeppelin从checkpoint&savepoint自动恢复任务​

在上一篇的文章中介绍了Flink on zeppelin怎么配置checkpoint,并且从指定的checkpoint恢复任务,但是这个过程还是相对复杂,对用户来说不是很友好,在最新的版本中,zeppelin支持了自动从checkpoint&savepoint恢复任务,只需要添加几个参数即可,下面就来介绍一下如何使用.1.checkpoint自动恢复1.1 指定checkpoint恢复先....

Flink on zeppelin从checkpoint&savepoint自动恢复任务​
文章 2022-05-29 来自:开发者社区

基于 Flink 实现解决数据库分库分表任务拆分

1、场景描述例如订单库进行了分库分表,其示例如下图所示:现在的需求是希望创建一个任务就将数据同步到MQ集群,而不是为每一个数据库实例单独创建一个任务,将其数据导入到MQ集群,因为同步任务除了库不同之外,表的结构、数据映射规则都是一致的。2、flinkx 的解决方案详解2.1 fink Stream API 开发基本流程使用 Flink Stream API 编程的通用步骤如下图所示:温馨提示:有....

基于 Flink 实现解决数据库分库分表任务拆分
问答 2022-05-10 来自:开发者社区

flink过程中,出现报错,直接任务挂了,能自动配置重启吗?

flink过程中,出现报错,直接任务挂了,能自动配置重启吗?

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

产品推荐

阿里云实时计算Flink

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

+关注