1、准备文件

flink安装包（1.9）

netcat（windows版）

2、创建maven工程。

可以使用idea之类的工具，pom文件至少必须引用

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.9.0</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>1.9.0</version>
</dependency>

3、代码中完成一个功能（抄了一个满世界都是的wordcount工程）并打成jar包。

4、使用netcat 启动一个端口，作为wordcount的输入端 （nc -L -p 9000）

5、启动flink集群start-cluster.bat

6、启动wordcount的jar包（flink.bat run -c myMain.StreamingJob sm-1.0-SNAPSHOT.jar -port 9000）

注意，需要优先指定 主类（-c） 反正我的版本不指定会报错。

7、确认flink中job正常运行

8、netcat启动界面输入字符串 观察输出结果

优质内容筛选与推荐>>
1、为文本添加全选Ctrl + A 功能
2、关于闭包我想说的
3、雷曼兄弟公司(Lehman-Brothers)
4、行为树（Behavior Tree）【转载】
5、软件工程学习总结（1）——软件测试工具详解

赞赏

长按二维码向我转账

受苹果公司新规定影响，微信 iOS 版的赞赏功能被关闭，可通过二维码转账支持公众号。

阅读

已发送

发送中