Flink:执行管道java时出错。util。同时发生的TimeoutException:期货在[10000毫秒]后超时

我正在使用 Flink v1.4.0 。

我在利用 Flink 的原生图形API(Gelly),我正在使用它处理1200万个数据点(边)。我目前正在通过 IntelliJ 使用 弗林克 在同一JVM中执行所有TaskManager和JobManager的微型集群。

当我加载数据时,在获取 弗林克 要运行的作业,我始终会遇到以下异常:

...
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#XXXXXXXXXX] with leader session id XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX.
322062 [main] ERROR com.somecompany.some.domain.name.some.javaClass- Error executing pipeline
java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds]
            at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:223)
            at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:157)
            at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:169)
            at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:169)
            at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)

。。。

我确保通过以下方式编辑运行配置 IntelliJ公司 要添加:

-Dakka.client.timeout:600s
-Dakka.ask.timeout:600s

但例外情况依然存在,至于是什么原因造成的,我没有其他线索。当我减小数据大小时,一切正常。

当我试图通过网络提交同一份工作时,也会出现同样的问题 Flink UI 在的本地版本上运行 弗林克 我已在群集上安装。在这种情况下,作业永远不会启动,我甚至无法预览自动生成的运算符DAG。当我减少要处理的数据量时,问题再次消失。我还更新了 flink-conf.yaml 包括相同的 akka 配置属性,但这没有什么区别。

如何修复此问题?