in 1 ms
2021-12-11 14:25:26,626 INFO org.apache.flink.runtime.jobmaster.JobMaster []2-用于Kubernetes部署,on StateFun部署文档()部署类型用于作业管理器组件。另一方面,Flink部署文档(独立/ Kubernetes部分) ()使用作业类型作为职务管理器,用于高可用的设置(作业管理器-应用程序-ha.ya
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers),没有问题: at org.apache.flink.client.CliFrontend.executeProgramDetached(CliFrontend.java:844)
at org.apache.flink.client.CliFront
2019-11-12 01:26:44.908 [flink-akka.actor.default-dispatcher-77] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph) switched from state RUNNING to FAILING.
java.nio.file.NoSuchFileException: /var/data/rawdata/2019-11-11<
我正在使用Apache,并且在我的Flink任务节点上得到了这个错误。当我重新启动我的Flink节点并重新部署作业时,它运行得很好。当时这些经纪人似乎也很好。at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction:102)
at org.apache.flink