我正在运行一个Flink代码,它在本地执行时工作良好(在IntelliJ中),但在Flink集群中运行时会崩溃: org.apache.flink.client.program.ProgramInvocationException在作业的初始化过程中,我加载了一个文本文件,该文件通过以下代码嵌入到我的jar文件中: try (InputStream is = new FileInputStream(new File("src
在我的硕士论文中,我尝试在4个节点上建立一个flink独立集群。我已经阅读了文档,该文档很好地解释了如何设置它。但是,当我启动集群时,会出现一个警告,当我尝试运行作业时,会出现错误,并显示相同的消息:
akka.pattern.AskTimeoutException: Ask timed out on [ActorSender[null] sent message of type "org.apache.flink.runtime.messa