Apache flink(稳定版本1.6.2)不起作用
用WordCount 这个例子,出现Connection refused ,是端口没有被监听,StreamExecutionEnvironment 的socketTextStream 方法并不是自己监听一个端口,起一个服务队,等你给他发消息。是你先得通过nc 启动这个端口,然后flink再与之建立socket连接。 可以看一下源码,不是启动了serverSocket,因此出现Connection refused 就很正常了,你需要通过nc程序启动 https://eternallybored.org/misc/netcat/ 之后到下载的目录中,nc.exe -l -p 9999
赞0
踩0