问答 2021-01-31 来自:开发者社区

大佬们,我在启动Flink的JOB时,将job的启动参数保存到了某个常量,但当我在si #Flink

大佬们,我在启动Flink的JOB时,将job的启动参数保存到了某个常量,但当我在sink中的invoke方法里,我获取时为Null,这个怎么处理啊? 我本地开发运行没问题,发布到Flink环境有问题。#Flink

问答 2021-01-10 来自:开发者社区

如何把多个FLINK SQL放到同一个Yarn JOB里

在一个FLINK Application中(一个main class)用FLINK Kafka SQL Connector 都多个Kafka TOPIC, 然后对每一个Kafka Table, 取出一些字段后, insert后续Kafka Table。 任务提交到Yarn后, 为什么每一个SQL语句都会启动一个JobManager? 甚至都一个Kafka Source Table, SINK两.....

问答 2021-01-05 来自:开发者社区

Flink on Yarn 的 Session 模式和 Per Job 模式的应用场景有什么区别

Flink on Yarn 的 Session 模式和 Per Job 模式的应用场景有什么区别

问答 2021-01-05 来自:开发者社区

Flink on Yarn 中的 Per Job 模式运行流程是怎样的

Flink on Yarn 中的 Per Job 模式运行流程是怎样的

问答 2021-01-05 来自:开发者社区

Flink on Yarn 中的 Per Job 模式是指什么

Flink on Yarn 中的 Per Job 模式是指什么

问答 2020-08-20 来自:开发者社区

flink job cancel的时候 有钩子方法没? 需要释放一些资源。#Flink

flink job cancel的时候 有钩子方法没? 需要释放一些资源。#Flink

问答 2020-08-06 来自:开发者社区

用yarn集群模式,一般用哪种?Yarn Session 还是Single Job?#Flink

用yarn集群模式,一般用哪种?Yarn Session 还是Single Job?#Flink

问答 2020-07-26 来自:开发者社区

Flink1.11.1有没有解决sql任务没能指定job名称的bug啊?#Flink

Flink1.11.1有没有解决sql任务没能指定job名称的bug啊?#Flink

问答 2020-07-26 来自:开发者社区

我用hivecatalog建了张kafka的source表,那么我有两个job都需要从这#Flink

我用hivecatalog建了张kafka的source表,那么我有两个job都需要从这张source表取数据写到不同的 数据库,那么怎么保证group.id 不同的啊 #Flink

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

Flink1.11咋定义JOB NAME啊? #Flink

Flink1.11咋定义JOB NAME啊? #Flink

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

产品推荐

阿里云实时计算Flink

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

+关注