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á.
Antes de começar, recomendamos que você assista a este vídeo: Atualizações de versão in-loco
Para realizar atualizações de versão in-loco para o Apache Flink, você pode usar o AWS CLI,, AWS CloudFormation, AWS SDK ou o. AWS Management Console Você pode usar esse recurso com qualquer aplicativo existente que você usa com o Managed Service for Apache Flink em um estado READY ouRUNNING. Ele usa o UpdateApplication API para adicionar a capacidade de alterar o tempo de execução do Flink.
Antes da atualização: atualize seu aplicativo Apache Flink
Ao escrever seus aplicativos Flink, você os agrupa com suas dependências em um aplicativo JAR e os carrega em seu bucket do Amazon JAR S3. A partir daí, o Amazon Managed Service para Apache Flink executa o trabalho no novo tempo de execução do Flink que você selecionou. Talvez seja necessário atualizar seus aplicativos para obter compatibilidade com o tempo de execução do Flink para o qual você deseja fazer o upgrade. Pode haver inconsistências entre as versões do Flink que fazem com que a atualização da versão falhe. Geralmente, isso ocorre com conectores para fontes (entrada) ou destinos (coletores, saída) e dependências do Scala. O Flink 1.15 e versões posteriores no Managed Service for Apache Flink são independentes de Scala, e você JAR deve conter a versão do Scala que você planeja usar.
Para atualizar seu aplicativo
-
Leia os conselhos da comunidade Flink sobre como atualizar aplicativos com o estado. Consulte Atualização de aplicativos e versões do Flink
. -
Leia a lista de problemas e limitações conhecidos. Consulte Precauções e problemas conhecidos com atualizações de aplicativos.
-
Atualize suas dependências e teste seus aplicativos localmente. Essas dependências normalmente são:
-
O tempo de execução do Flink e. API
-
Conectores recomendados para o novo tempo de execução do Flink. Você pode encontrá-los nas versões Release para o tempo de execução específico para o qual deseja atualizar.
-
Scala — O Apache Flink é independente de Scala, começando com e incluindo o Flink 1.15. Você deve incluir as dependências do Scala que deseja usar em seu aplicativo. JAR
-
-
Crie um novo aplicativo JAR no arquivo zip e faça o upload para o Amazon S3. Recomendamos que você use um nome diferente do JAR /zipfile. anterior Se precisar reverter, você usará essas informações.
-
Se você estiver executando aplicativos com estado, é altamente recomendável que você tire um instantâneo do seu aplicativo atual. Isso permite reverter de forma contínua se você encontrar problemas durante ou após a atualização.
