开发者社区> 问答> 正文

Flink中的Flink on Yarn的两种运行方式具体是些什么啊?

Flink中的Flink on Yarn的两种运行方式具体是些什么啊?

展开
收起
游客vwuxaq6iqaowc 2021-12-08 15:31:40 275 0
1 条回答
写回答
取消 提交回答
  • 第一种【yarn-session.sh(开辟资源)+flink run(提交任务)】

    启动一个一直运行的flink集群

    ./bin/yarn-session.sh -n 2 -jm 1024 -tm 1024 [-d]

    附着到一个已存在的flink yarn session

    ./bin/yarn-session.sh -id application_1463870264508_0001

    执行任务

    ./bin/flink run ./data/batch/WordCount.jar -input hdfs://hadoop00:9000/LICENSE -output hdfs://hadoop00:9000/wordcount-result.txt

    停止任务 【web界面或者命令行执行cancel命令】

    第二种【flink run -m yarn-cluster(开辟资源+提交任务)】

    启动集群,执行任务

    ./bin/flink run -m yarn-cluster -yn 2 -yjm 1024 -ytm 1024 ./data/batch/WordCount.jar

    2021-12-08 15:31:56
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载