问答 2022-02-15 来自:开发者社区

Flink程序打成jar包在集群中无法运行

Flink中WorldCount程序在idea中可以读取HDFS中的数据,也可以将结果写入到HDFS中,当将该程序打成jar包,在Flink standalone模式下运行就出问题 lhm@bd1:~$ flink run -c flink_core.WorldCount Flink-1.0-SNAPSHOT-jar-with-dependencies.jar --in hdfs://bd1:.....

问答 2022-02-15 来自:开发者社区

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

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

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

产品推荐

阿里云实时计算Flink

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

+关注