我正在尝试启动 flink 作业集群。 我已经将HA共同定位为动物园管理员，并将工作.jar放在类路径中。 我期待作业管理器从一个等待任务管理器启动的作业开始。 但是当我通过./flink/bin/standalone-job.sh start-foreground启动作业管理器时，作业管理器立即开始执行作业，而无需运行任何任务管理器。WebUI说：{
errors: [
"Service temporarily unavailable due to an ongoing leader election. Please refresh."
]
}
该作业是用 Apache Beam 编写的，其行为类似于使用java -jar job.jar --runner=DirectRunner手动启动作业
问题在于缺少参数。Flink 只运行 main 方法，beam 默认使用 DirrectRunner。所以作业不会在 flink 上运行。此命令有效：./flink/bin/standalone-job.sh start-foreground --runner=org.apache.beam.runners.flink.FlinkRunner