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
。
您可以在代码中继续修改的配置包括:
-
管道。 auto-watermark-interval
-
管道。 closure-cleaner-level
-
pipeline.max-parallelism
-
pipeline.name
-
pipeline.operator-chaining。 chain-operators-with-different-最大并行度
-
pipeline.operator-chaing.enabled
-
管道。 vertex-description-mode
-
管道。 vertex-name-include-index-前缀
-
python.execution-Mode
-
python.operator-chaing.enabled
您仍然可以使用支持案例请求修改某些任务或集群配置。有关更多信息,请参阅可修改的 Flink 配置属性。