zoukankan      html  css  js  c++  java
  • flink常用命令

    1.查看flink任务

    /var/lib/hadoop-hdfs/flink/bin/flink  list

    2.停止flink任务

    /var/lib/hadoop-hdfs/flink/bin/flink  cancel  job Id

    3.启动一个yarn session

    bin/yarn-session.sh -d -s 3 -jm 2048 -tm 6144 -qu root.sparkstreaming -nm  flash_dev_pv_uv

    4.查看yarn session

    yarn application --list

    5.杀掉yarn session

    yarn appclication -kill application_1625727533919_9502

    6.启动flink job

    /var/lib/hadoop-hdfs/flink/bin/flink run -p 6  -c com.code2144.flashOverwrite.FashDevPVAndUVFunction

    -yid application_1630824298449_96210 /var/lib/hadoop-hdfs/flink/jars/flash_dev_pv_uv/BSS-ONSS-Flink-1.0-SNAPSHOT.jar

    6.1指定checkpoint启动

    /var/lib/hadoop-hdfs/flink/bin/flink run -p 8 -s hdfs://bigdata/flink/checkpoints/workFlowCheckpoint/75f16ca2cebdc1a636370eede87ac497/chk-4066916/_metadata

    -c com.code2144.helper_workflow.HelperWorkFlowStreaming -yid application_1625727533919_9494 /var/lib/hadoop-hdfs/flink/jars/BSS-ONSS-Flink-1.0-SNAPSHOT.jar

  • 相关阅读:
    httpclient用法
    JS逻辑运算符&&与||的妙用
    jackson详解
    MVC +EF+linq 多表联查
    Log4net 集成到MVC+EF框架
    Asp.net中的页面跳转及post数据
    字符串的分割操作
    线程的信号机制
    事件的标准模式
    Java网络编程
  • 原文地址:https://www.cnblogs.com/lizihao/p/15475365.html
Copyright © 2011-2022 走看看