Hi Brett, Is your exception generated on your local machine or generated on a remote node?
Best, Vino Brett Marcott <brett.marc...@gmail.com> 于2018年12月15日周六 下午5:38写道： > Hi Flink users, > > I am attempting to follow the tutorial here: > > https://ci.apache.org/projects/flink/flink-docs-release-1.7/tutorials/datastream_api.html > > However I am hitting the below error: > > org.apache.flink.runtime.client.JobExecutionException: Job execution > failed. > > at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146) > > at > org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:647) > > at > org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123) > > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1510) > > at wikiedits.WikipediaAnalysis.main(WikipediaAnalysis.java:42) > > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > > at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > > at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > at java.base/java.lang.reflect.Method.invoke(Method.java:564) > > at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282) > > at java.base/java.lang.Thread.run(Thread.java:844) > > Caused by: java.net.ConnectException: Operation timed out (Connection > timed out) > > at java.base/java.net.PlainSocketImpl.socketConnect(Native Method) > > at > java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:400) > > at > java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:243) > > at > java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:225) > > at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:402) > > at java.base/java.net.Socket.connect(Socket.java:591) > > at java.base/java.net.Socket.connect(Socket.java:540) > > at java.base/java.net.Socket.<init>(Socket.java:436) > > at java.base/java.net.Socket.<init>(Socket.java:213) > > at org.schwering.irc.lib.IRCConnection.connect(IRCConnection.java:295) > > at > org.apache.flink.streaming.connectors.wikiedits.WikipediaEditEventIrcStream.connect(WikipediaEditEventIrcStream.java:62) > > at > org.apache.flink.streaming.connectors.wikiedits.WikipediaEditsSource.run(WikipediaEditsSource.java:80) > > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:94) > > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:58) > > 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:704) > > ... 1 more > > > > Below connection works fine on command line: > > $ nc -z irc.wikimedia.org 6667 > > Connection to irc.wikimedia.org port 6667 [tcp/*] succeeded! > > > Any tips? > > > Thanks, > > > Brett >
