通过 REST API 提交 Apache Flink 作业失败

Question

我有一个本地 Apache Flink Cluster 版本 1.16.3 安装，如此处所指定。我已通过 Flink UI 上传了 jar 文件，并尝试使用 Flink REST API 启动作业。作业提交到达 Flink 作业管理器，作业提交立即失败，出现以下异常，

InvalidProgramException: Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available.
JarRunHander- Exception occured in REST handler:could not execute application

除了主类和命令行参数之外，通过 REST api 提交作业是否还需要任何其他配置？

Answer 1

使用REST API中的分离模式进行提交。某些功能（例如累加器、运行时等）在分离模式下不可用。您可以使用附加模式通过命令行提交，也可以删除相关操作符。

您可以提供更详细的描述或代码，以便我为您提供更多帮助。