Adpative调度程序未通过Flink 1.14.0识别

Question

我正在尝试使用Flink 1.14的自适应时间表来基于可用资源来运行Flink作业，而不是等待所需的并行性（缩放），但我看不到Flink识别自适应时间表。

Ex: flink run  -m yarn-cluster -ynm jobName -p 128 -D jobmanager.scheduler=Adaptive  -D cluster.declarative-resource-management.enabled=true -c className JarName

参考：

Caused by: java.util.concurrent.CompletionException: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout
        at org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:515)
        ... 37 more
Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout
        at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
        at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
        ... 35 more

马丹

Answer 1

参见描述。特别是，该部分解释了不支持纱线：

部署仅作为独立应用程序部署支持。主动资源提供者（例如本机Kubernetes，Yarn）明确不支持。独立会话群也不支持。应用程序部署仅限于单个作业申请。

唯一受支持的部署选项是在应用模式下独立的（在此页面上进行描述），在应用程序模式下Docker和独立的Kubernetes应用程序集群。