FlinkRuntimeException: “Não foram detectadas alterações de configuração permitidas” - Managed Service for Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

FlinkRuntimeException: “Não foram detectadas alterações de configuração permitidas”

A partir da versão 1.19 e posterior do Flink, desativamos as alterações na configuração da tarefa do Flink usando os códigos de tarefa do Flink.

Se você realizar uma alteração de configuração sem suporte, receberá a seguinte exceção:

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

A mensagem de exceção indica quais configurações ou setters não permitidos você usou. No exemplo anterior, o aplicativo tenta configurar execution.checkpointing.unaligned.enabled e usarsetCheckpointStorage.

As configurações que você pode continuar modificando no código incluem:

  1. oleoduto. auto-watermark-interval

  2. oleoduto. closure-cleaner-level

  3. paralelismo pipeline.max

  4. nome do pipeline

  5. pipeline.operator-chaining. chain-operators-with-different-paralelismo máximo

  6. pipeline.operator-chaining.enabled

  7. oleoduto. vertex-description-mode

  8. oleoduto. vertex-name-include-index-prefixo

  9. python.modo de execução

  10. python.operator-chaining.enabled

Você ainda pode solicitar modificações em algumas configurações de trabalho ou cluster usando um caso de suporte. Para obter mais informações, consulte Propriedades de configuração modificáveis do Flink.