Skip to content

Latest commit

 

History

History
55 lines (38 loc) · 2.01 KB

manual-run-word-count.md

File metadata and controls

55 lines (38 loc) · 2.01 KB

运行 Word Count 作业示例

在 Plink 上提交 Flink 自带的 flink-1.9.1\examples\streaming\WordCount.jar,然运行。

作业列表

新建作业

  • 作业管理 -> 作业列表 -> 右侧按钮 -> 新建 -> 输入(作业名称/类型/描述) -> 新建。如下所示: 新建作业

编辑作业

注意: 由于独立部署和容器化部署的 Flink 版本可能不一样,最好使用对应的 WordCount Jar 版本。

  1. 独立部署(Flink 1.9):

    下载链接: https://mirror.bit.edu.cn/apache/flink/flink-1.9.3/flink-1.9.3-bin-scala_2.11.tgz
    Jar 目录: f${FLINK_HOME}examples\streaming\WordCount.jar。

  2. Docker 部署(Flink 1.10):

    下载链接: https://mirrors.bfsu.edu.cn/apache/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz
    Jar 目录: ${FLINK_HOME}\examples\streaming\WordCount.jar

作业列表编辑或新建作业之后会自动跳转到编辑作业的页面。填写参数,上传 Jar,保存即可。如下所示:

编辑作业

Word Count MainClass: org.apache.flink.streaming.examples.wordcount.WordCount

作业详情

  1. 作业信息

    确认自己作业的基础信息,作业配置,运行参数等。 作业详情

  2. 作业实例

    每一次作业运行时,都会产生一个作业实例。

  3. 作业监控

    未实现 。。。

启动作业

在作业详情页的右侧功能按钮点击启动,即可启动作业,同时页面会自动刷新(当前刷新频率为 1s)

  1. 待启动 启动作业
  2. 启动中 启动中
  3. 运行中 运行中
  4. 运行成功 运行成功

实例列表

实例列表可以看所有的作业实例运行历史信息。 实例列表