官方文档中只给了wordcount的输入输出示例,直接右键run main就可以了。但到了跑SocketTextStreamWordCount,由于程序是需要接收参数的,直接run main会保缺少参数的错误:
当然你可以导出编译好的jar包来运行,不过又麻烦而且不够直观。
首先你需要使用命令:“nc -lk 9080”来用netcat开启本机socket连接并制定端口“9080”,然后在Edit configurations里面设置运行程序接收的参数
然后右键run main,在命令行中输入文本,就可以交由flink计算了: