Apache Flink InvocationTargetException：作业执行失败。连接超时

Question

我正在根据 Apache Flink 快速入门指南创建 this 示例。我总是不断收到错误消息：

Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.4.0:java (default-cli) on project wiki-edits: An exception occured while executing the Java class. null: InvocationTargetException: Job execution failed. Connection timed out -> [Help 1]

有很多异常来自 Flink 的内部文件，而不是我正在编码的文件。谁能解决这个问题？

这是完整的例外：

Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
    at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$$anonfun$applyOrElse.apply$mcV$sp(JobManager.scala:714)
    at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$$anonfun$applyOrElse.apply(JobManager.scala:660)
    at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$$anonfun$applyOrElse.apply(JobManager.scala:660)
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1(Future.scala:24)
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.net.ConnectException: Connection timed out
    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 java.net.Socket.connect(Socket.java:538)
    at java.net.Socket.<init>(Socket.java:434)
    at java.net.Socket.<init>(Socket.java:211)
    at org.schwering.irc.lib.IRCConnection.connect(IRCConnection.java:295)
    at org.apache.flink.streaming.connectors.wikiedits.WikipediaEditEventIrcStream.start(WikipediaEditEventIrcStream.java:56)
    at org.apache.flink.streaming.connectors.wikiedits.WikipediaEditsSource.open(WikipediaEditsSource.java:77)
    at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38)
    at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:314)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:214)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
    at java.lang.Thread.run(Thread.java:745)

Answer 1

看起来 WikipediaEditsSource 无法与包含维基编辑的 IRC 频道建立连接。

源正在订阅维基百科发布编辑的 IRC 频道。典型的 IRC 端口（6667、6668、..）可能在您的网络中被阻止。

你能检查一下你的网络是否可以到达 irc.wikimedia.org:6667 吗？频道是 #en.wikipedia.

Apache Flink InvocationTargetException：作业执行失败。连接超时

Apache Flink InvocationTargetException: Job execution failed. Connection timed out

java

apache-flink

flink-streaming