flink

细节请参考博文: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(有博客讲任务运行起来后就会显示具体的数量)

flink