细节请参考博文:https://www.cnblogs.com/importbigdata/p/10747061.html
相关命令:
1)nc -l 9001
2)flink run examples/streaming/SocketWindowWordCount.jar --port 9001
3)tail -f -n 200 flink-*-taskexecutor-1-*.out
单机版注意的坑(官方文档说不用修改直接可以运行):
1.修改flink-conf.yaml下的 jobmanager.rpc.address
2.修改conf下的masters和slave;
3.启动start-cluster.sh后 用jps检查StandaloneSessionClusterEntrypoint是否存在
未解决(换了个环境莫名其妙就好了):
1.任务启动以后报Could not allocate all requires slots within timeout of 300000 ms. Slots required: 2, slots allocated: 0,任务失败
2.web页面所显示的数量都为0(有博客讲任务运行起来后就会显示具体的数量)