First use of flink

本文记录学习使用flink系列(一).

昨天在按照某篇博客的demo程序,在自己的电脑上也尝试把flink程序运行起来,可是出现了在报错,当初在网上也简单找了下答案,没有搜索到相关的解决方案.
参考学习博客:https://ververica.cn/developers/build-from-zero/
可是步骤都是一样的,在我的电脑上没有启动成功,当时一下子没排查出原因.
报错简要描述如下:

0:15:08,342 INFO  org.apache.flink.runtime.blob.BlobServer                      - Stopped BLOB server at 0.0.0.0:43927
Exception in thread "main" 00:15:08,342 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Stopped Akka RPC service.
org.apache.flink.runtime.client.JobExecutionException: java.net.ConnectException: Connection refused (Connection refused)
    at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:623)
    at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123)
    at myflink.SocketWindowWordCount.main(SocketWindowWordCount.java:31)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:589)
    at org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:96)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:56)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:99)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
    at java.lang.Thread.run(Thread.java:748)

今天晚上我尝试换了别的关键词:org.apache.flink.runtime.client.JobExecutionException: java.net.ConnectException: Connection refused (Connection refused)进行搜索,找到解决的答案,哈哈!
解决方法:使用nc -l -p 9000 代替了命令 nc -lk 9000
https://stackoverflow.com/questions/53784757/unable-to-run-flink-example-program-connection-refused

解决了昨晚我郁闷了好久的问题.
有时候还是需要换个关键词,就可以找到对应的答案.

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • 我叫YH,生在辽宁一个还算繁华的城市里,这座城市里的人有个毛病,如果聊天的对象是本地人,那他们就会说“哎呦,你知道...
    sunshine打老虎阅读 1,713评论 0 1
  • 前言 如果你了解 Apache Flink 的话,那么你应该熟悉该如何像 Flink 发送数据或者如何从 Flin...
    zhisheng_blog阅读 1,526评论 0 5
  • 《最后一只歌》,好看,亲情与爱情的暖心电影,深夜独自看完,喜欢!暖暖幸福的感觉,环抱我入眠。
    果果爱阅读阅读 43评论 0 1
  • 包容人家的缺点容易,包容别人的优点很难。包容别人的优点才是真正的包容。很多人容不下别人的优点,忌妒别人的优点。当你...
    区荣炎阅读 741评论 0 1
  • 19.1.11跨域请求,使用jsonp,采用回调函数callback。以下两个参考不错:https://segme...
    静心安分读书阅读 163评论 0 0

友情链接更多精彩内容