Windows运行Flink的wordcount示例代码

1.下载netcat for windows,解压后将nc.exe放到windows的System32文件夹中

2.Flink官方示例代码写好以后,在Intellj Idea的运行配置那,配置一下参数接收相关参数,即,在Program arguments那加上 localhost 9000,即表示该类的main方法接收9000 socket端口发送过来的数据,如下两个图所示:

Windows运行Flink的wordcount示例代码

Windows运行Flink的wordcount示例代码

3.右键运行该类,启动

4.打开cmd窗口,输入命令:nc -L -p 9000 ,改命令为监听9000端口,同时,可以允许在当前cmd窗口中输入参数

5.在cmd窗口中输入参数,观察idea的console中打印的信息,如下所示:

Windows运行Flink的wordcount示例代码