FlinkRuntimeException：“检测到不允许的配置更改” - Managed Service for Apache Flink

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 配置属性。