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

Flink application on native k8s如何修改配置文件?

Hi all, 最近再把flink任务迁移到native k8s,发现flink-conf系列的文件没有办法很好地被修改,比如log4j文件还有一些很通用的写在flink-conf的配置项(e.g. Prometheus配置)。 flink-conf的配置我还可以在flink run的时候带上,那log4j的配置好像没有太好的办法带上。 大家在这块有什么实践吗?thx.*来自志愿者整理的f...

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

Flink1.11.1版本Application Mode job on K8S集群问题

Flink1.11.1版本job以Application Mode在K8S集群上运行,jobmanager每个小时会重启一次,报错【Fatal error  occurred in  ResourceManager.io.fabric8.kubernetes.client.KubernetesClientException: too  old resource ver...

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

flink Application Native k8s使用oss作为backend日志偶尔报错怎么

环境:Native Kubernetes 模式:Application Mode 描述: Flink以Native Kubernetes Application模式运行在k8s时,使用filesystem OSS作为backend发现日志请求OSS报错。 当代码使用`source.setStartFromEarliest();`,启动job之后从头开始消费,运行过程正常,运行到最新点位后...

文章 2021-04-30 来自:开发者社区

Flink on Zeppelin 系列之:Yarn Application 模式支持

作者:章剑锋(简锋)去年 Flink Forward 在讲 Flink on Zeppelin 这个项目的未来时我们谈到了对Application 模式的支持,今天就有一个好消息要告诉大家,社区已经实现了这一Feature,欢迎大家加入 Flink on Zeppelin 的钉钉群(32803524),下载最新版来使用这个Feature。GitHub 地址https://github.com/a....

Flink on Zeppelin 系列之:Yarn Application 模式支持
问答 2021-01-10 来自:开发者社区

在统一FLINK Application中(一个main class)用FLINK Kafka C

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

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

yarn-session.sh 如何退出shell yarn application #Flink

yarn-session.sh 如何退出shell yarn application 不退出呢?#Flink

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

flink 1.10.0 基于yarn 部署的,启动的yarn application #Flink

flink 1.10.0 基于yarn 部署的,启动的yarn application 修改 name 和 queue 无效,谁有遇到过类似问题吗? ./bin/yarn-session.sh 指定 -nm 和 -qu 无效 #Flink

问答 2019-12-05 来自:开发者社区

请问一下各位大佬,java 写的flink程序提交到yarn集群,application name都

请问一下各位大佬,java 写的flink程序提交到yarn集群,application name都是flink session cluster,多个程序运行的话,难以分辨,如何在代码里指定application的名字呢?多谢多谢啦 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

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

产品推荐

阿里云实时计算Flink

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

+关注