zoukankan      html  css  js  c++  java
  • Flink实例(五十三): flink 作业提交(三)yarn 提交模式(二)Flink on YARN Per-Job模式

    Flink on YARN Per-Job模式

    首先将之前在 yarn 上运行的应用和相关进程给kill掉:

    [root@hadoop01 ~]# yarn application -kill application_1601372571363_0001
    [root@hadoop01 ~]# jps
    6995 SecondaryNameNode
    7204 ResourceManager
    7305 NodeManager
    11291 Jps
    6734 NameNode
    6830 DataNode
    8942 FlinkYarnSessionCli
    [root@hadoop01 ~]# kill 8942

    Per-Job模式更简单,因为是提交一个作业就创建一次资源的,所以直接运行如下命令就可以提交一个Flink的Word Count作业到 yarn 上,不需要像Session模式那样事先去创建资源:

    [root@hadoop01 /usr/local/flink]# ./bin/flink run -m yarn-cluster ./examples/batch/WordCount.jar

    作业运行完成后,控制台会输出一堆统计结果。此时在 yarn 上可以看到该作业已经执行完成

    作者:端碗吹水
    链接:https://www.jianshu.com/p/9c9f815f249e
    来源:简书
    著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

  • 相关阅读:
    Samba
    百度贴吧
    baidu.com关键字查询
    vim 删除每行开头结尾空格
    read line(逐行读取)
    pycharm 激活
    rsync 启动脚本
    收藏
    elk
    sql is null
  • 原文地址:https://www.cnblogs.com/qiu-hua/p/13805603.html
Copyright © 2011-2022 走看看