FlinkRuntimeException:“检测到不允许的配置更改” - Managed Service for Apache Flink
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

FlinkRuntimeException:“检测到不允许的配置更改”

从 Flink 版本 1.19 及更高版本开始,我们已使用 Flink 作业代码禁用了 Flink 作业配置更改。

如果您执行此类不受支持的配置更改,则会收到以下异常:

Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Not allowed configuration change(s) were detected: - Configuration execution.checkpointing.unaligned.enabled:true not allowed. - Setter CheckpointConfig#setCheckpointStorage has been used at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:108) at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84) ... 9 more

异常消息表明您使用了哪些不允许的配置或设置器。在前面的示例中,应用程序尝试配置execution.checkpointing.unaligned.enabled和使用setCheckpointStorage

您可以在代码中继续修改的配置包括:

  1. 管道。 auto-watermark-interval

  2. 管道。 closure-cleaner-level

  3. pipeline.max-parallelism

  4. pipeline.name

  5. pipeline.operator-chaining。 chain-operators-with-different-最大并行度

  6. pipeline.operator-chaing.enabled

  7. 管道。 vertex-description-mode

  8. 管道。 vertex-name-include-index-前缀

  9. python.execution-Mode

  10. python.operator-chaing.enabled

您仍然可以使用支持案例请求修改某些任务或集群配置。有关更多信息,请参阅可修改的 Flink 配置属性。