Práticas recomendadas e orientações gerais sobre as atualizações de aplicativos - Managed Service for Apache Flink

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

Práticas recomendadas e orientações gerais sobre as atualizações de aplicativos

  • Teste o novo trabalho/runtime sem estado em um ambiente que não seja de produção antes de tentar uma atualização de produção.

  • Considere primeiro testar a atualização com estado em um aplicativo que não seja de produção.

  • Certifique-se de que seu novo gráfico de tarefas tenha um estado compatível com o snapshot que você usará para iniciar seu aplicativo atualizado.

    • Verifique se os tipos armazenados nos estados do operador permanecem os mesmos. Se o tipo mudou, o Apache Flink não consegue restaurar o estado do operador.

    • Certifique-se de que os IDs de operador que você definiu usando o método uid permaneçam os mesmos. O Apache Flink recomenda fortemente atribuir IDs exclusivos aos operadores. Para obter mais informações, consulte Como atribuir IDs de operadores na Documentação do Apache Flink.

      Se não atribuir IDs aos seus operadores, o Flink os gera automaticamente. Nesse caso, eles podem depender da estrutura do programa e, caso alterados, podem causar problemas de compatibilidade. O Flink usa IDs de operador para combinar o estado no snapshot com o operador. A alteração das IDs do operador faz com que o aplicativo não seja iniciado ou que o estado armazenado no snapshot seja descartado e o novo operador seja iniciado sem estado.

    • Não altere a chave usada para armazenar o estado da chave .

    • Não modifique o tipo de entrada de operadores com estado, como janela ou junção . Isso altera implicitamente o tipo do estado interno do operador, causando uma incompatibilidade de estado .