上边已经能从源码构建出来部署二进制包，接下来就用上面构建的二进制包跑一下，简单感受下Flink

部署启动

常用的部署模式有 local模式，stantalone模式，yarn模式，k8s等

这里搭建stantalone， 假设是在Windows 操作下（Linux搞好搞）
几乎不用配置便可以搭建一个

  • 在二进制包bin目录下执行start-cluster.bat 便启动了所需服务
  • 打开本地IP加8081 接口正常情况可访问到 Flink Dashboard

运行Job任务

这里举一个流处理的任务，就使用官方提供的示例 SocketTextStreamWordCount

  • 这个示例需要安装netcat （Windows 下载地址 https://eternallybored.org/misc/netcat/netcat-win32-1.12.zip）
  • 在解压缩目录导航中输入 CMD，弹出CMD窗口
  • CMD 中创建端口 命令： nc -l -p 9000
  • 在flink-bin目录下 执行 flink run -c org.apache.flink.streaming.examples.socket.SocketWindowWordCount 这jar包路径应该是在 examples/streaming下 —port 9000
  • 自此Starting program
  • 在nc 即可输入单词 Flink任务就会工作起来
  • 在Dashboard 中可以找到这个任务的运行情况
  • 在监控面板可以看到 统计单词的结果

多种任务提交方式

这里提供几种方式，同时还有相关提交可选项
https://blog.csdn.net/qq_33689414/article/details/90671685