Hi 可以分解为两步: 1、生成JobGraph,可以参考org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils 中 toJobGraph() 2、向Yarn提交JobGraph,可以参考org.apache.flink.yarn.YarnClusterDescriptor 中 deployJobCluster() 注:1.11.x
Jacob wrote > 有一个模糊的需求,不知道是否合理 > > 目前我们的实时计算的Job都是以On Yarn模式运行在hadoop集群,每次提交新的job,都是在Flink客户端下面,用./bin/flink > run-application -t yarn-application ....... 的形式去提交Job。 > > 现在我们有自研的一个关于数据处理平台,flink > job是数据处理的一个环节,想着能不能在我们系统的portal中配一个菜单,上传flink项目的jar包,可以提交Job到hadoop集群,形成一体化的管理,不用每次去一个flink客户端下面去提交了,不知道这种需求是否合理? > > 我想着如果在我们自己的平台上提交job,那是不是应该先把flink客户端先集成到我们的系统中呢,否则job如何被启动运行呢? > > 需求比较模糊,各位大佬见谅。 > > > > ----- > Thanks! > Jacob > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ -- Sent from: http://apache-flink.147419.n8.nabble.com/