flink从装置到提提交工干

文章作者:[db:作者] | 2018-12-26 03:29
字体大小:

  本操干整顿个在Windows下环境终止操干,linux环境下更为骈杂

  下载:

  flink此雕刻东方正西服置要展触动local花样还是比较骈杂的,比值先从官网左右载?http://flink.apache.org/downloads.html ? 我下载的是最新版本1.1.3,

  松压flink:

  下载完后对其终止松压,我松压所在的目次在D:\flink-1.1.3-bin-hadoop26-scala_2.10\flink-1.1.3?

  展触动flink:

  翻开cmd ?,

  cd /d ?D:\flink-1.1.3-bin-hadoop26-scala_2.10\flink-1.1.3 \bin ?目次,运转start-local.bat ?命令 ,就却以展触动flink, ?在阅读器下输入

  http://localhost:8081/ ?就却以对flink集儿子帮终止监控,却以检查哪些工干正运转,哪些工干运转违反败,哪些工干运转完一齐。

  展触动netcat:

  cd ?/d sparkconall/netcat

  nc -l -p ?520

  提提交己己己的jar包:

  jar包是我己己己写了个流动接纳端口520数据的的wordcount的以次,用maven打成jar包,提提交工干如次,

  cd ?/d?D:\flink-1.1.3-bin-hadoop26-scala_2.10\flink-1.1.3\bin

  flink ? run -c?com.wanda.flink.StreamWordCount ? D:\wilson.zhou\workspace\rocket-zlast\target\rocket-zlast-0.0.1-SNAPSHOT.jar

  run -c ?是指指定main方法和jar包

  检查运转结实:

  cd /d?D:\flink-1.1.3-bin-hadoop26-scala_2.10\flink-1.1.3\log

  type?flink-wilson.zhou-jobmanager-SH-TS-0026LT.out

  结实:

  (c++,1)

  (java,1)

  (jsds,1)

  (sds,1)

  (sdsada,1)

  (sdjsjsdas,1)

  (ajsdada,1)

  (sk,1)

  (jav,1)

TAG: [db:TAG标签]
888真人手机版_888真人app_888真人备用网址-官方网址 关于我们| 法律声明| 免责声明| 隐私条款| 广告服务| 在线投稿| 联系我们| 网站地图