Hi Brett, I have just tried it locally and it works for me. It looks like some networking issue with the JVM or environment setup where Flink is started.
Best, Andrey > On 18 Dec 2018, at 05:28, Brett Marcott <brett.marc...@gmail.com> wrote: > > Hi Vino, > > I am running everything (and generating the exception) locally I believe, as > the tutorial instructs. > > Thanks, > Brett > > On Mon, Dec 17, 2018 at 6:12 PM vino yang <yanghua1...@gmail.com > <mailto:yanghua1...@gmail.com>> wrote: > Hi Brett, > > Is your exception generated on your local machine or generated on a remote > node? > > Best, > Vino > > Brett Marcott <brett.marc...@gmail.com <mailto: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 > > <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 <http://irc.wikimedia.org/> 6667 > Connection to irc.wikimedia.org <http://irc.wikimedia.org/> port 6667 [tcp/*] > succeeded! > > Any tips? > > Thanks, > > Brett
