关于使用Kafka进行Flink流式处理的问题

Question

我有一个Java应用程序来处理flink作业来处理Kafka流式处理。

1. 的应用正在等待在这里的作业提交在flinkEnv.execute("flink job name")工作以来为串流从卡夫卡传入运行下去。

   在这种情况下，我怎样才能从执行中返回作业ID？我看到jobid正在控制台中打印。只是想知道，如何得到jobid是这种情况下没有flinkEnv.execute返回。

2. 我怎样才能从Java中的远程服务器取消给定作业名称的flink作业？

Answer 1

据我所知目前没有很好的编程方式来控制Flink。但是因为Flink是用Java写的，所以你可以用控制台脚本来调用内部类org.apache.flink.client.CliFrontend。

另一种方法是使用Flink JobManager的REST API。

Answer 2

您可以使用rest api来使用flink作业进程。

检查以下链接：https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html。