个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
26
4
我知道 Jobs 可以通过 flink 或 flink.bat 提交给 JobManager。我想知道Flink有没有提供Java API给JobManager提交作业？
最佳答案
是的。根据您要连接的集群类型，ClusterClient ( https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html) 有多种实现。
它可以以阻塞(同步)或分离(异步)方式运行作业。部署作业的一种方法是提供一个 PackagedProgram，它由一个带有主类的 JAR 文件和几个支持 JAR 文件(该作业专门需要的其他库)组成。
关于java - Flink 是否提供 Java API 来向 JobManager 提交作业？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45769652/
26
4
0
我试图让 Flink 使用 Zookeeper 在 HA 模式下运行，但是当我尝试通过杀死领导者 JobManager 来测试它时，我所有的备用作业管理器也被杀死了。 因此，与其由备用工作经理接任新的
所以我在我们的网络上安装了一个 apache flink 集群。我已经完成了如下所示的配置。这个Master(JobManager)启动，通过ssh向所有slave发送启动命令。我可以看到任务管理器在
我正在尝试在 kubernetes 上部署 Apache Flink 1.6。按照 job manager high availabilty 上的教程进行操作 页。我已经有一个运行中的 Zookeep
我已经将 Flink 配置为 HA 模式，如上所述 here : 我想测试容错能力，因此我做了以下操作: 设置具有 2 个 JobManager 和 1 个 TaskManager 的 Flink 集
本文整理了Java中org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore类的一些代码示例，展示了ZooKeeperSu
Flink 官方文档提供了 jobmanager high availability Standalone 和 Yarn Flink 集群的解决方案。但是使用 Kubernetes Flink 集群应
本文整理了Java中org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.getPathForJob()方法的一些代码
本文整理了Java中org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.jobIdfromPath()方法的一些代码
本文整理了Java中org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.verifyIsRunning()方法的一些
本文整理了Java中org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.()方法的一些代码示例，展示了ZooKeep
我知道 Jobs 可以通过 flink 或 flink.bat 提交给 JobManager。我想知道Flink有没有提供Java API给JobManager提交作业？ 最佳答案 是的。根据您要连接
我正在尝试使用以下命令在 yarn 上提交 flink 作业: /usr/flink-1.3.2/bin/flink run -yd -yn 1 -ynm MyApp -ys 1 -yqu defau
我无法让 TaskManager 与 docker swarm 堆栈上的 JobManager 进行通信。 stack.yml的内容我使用的文件 docker stack deploy是: versi
假设我有 8 个任务管理器和 16 个任务槽。如果我使用 Jobmanager UI 提交作业并将并行度设置为 8，我是否只使用 8 个任务槽？ 如果我有 8 个具有 8 个槽的任务管理器，并以 8
我在 Java 中使用 Akka 类型的 actor。我有一个 BatchManager ，它是与 Controller 的接口(interface)，还有一个 JobManager ，它创建一些工作
我是一名优秀的程序员,十分优秀！