Atualize o Studio Runtime - Managed Service for Apache Flink

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente 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á.

Atualize o Studio Runtime

Esta seção contém informações sobre como atualizar o Studio Notebook Runtime. Recomendamos que você sempre atualize para o Studio Runtime compatível mais recente.

Atualize seu notebook para um novo Studio Runtime

Dependendo de como você usa o Studio, as etapas para atualizar seu Runtime são diferentes. Selecione a opção adequada ao seu caso de uso.

Se você estiver usando SQL ou Python sem dependências externas, use o seguinte processo de atualização do Runtime. Recomendamos que você atualize para a versão mais recente do Runtime. O processo de atualização é o mesmo, independentemente da versão do Runtime da qual você está atualizando.

  1. Crie um novo notebook Studio usando o Runtime mais recente.

  2. Copie e cole o código de cada nota do caderno antigo para o novo.

  3. No novo notebook, ajuste o código para torná-lo compatível com qualquer recurso do Apache Flink que tenha sido alterado em relação à versão anterior.

    • Execute o novo notebook. Abra o notebook e execute-o nota por nota, em sequência, e teste se funciona.

    • Faça as alterações necessárias no código.

    • Pare o novo caderno.

  4. Se você tivesse implantado o notebook antigo como aplicativo:

    • Implante o novo notebook como um novo aplicativo separado.

    • Pare o aplicativo antigo.

    • Execute o novo aplicativo sem captura instantânea.

  5. Pare o notebook antigo se ele estiver funcionando. Inicie o novo notebook, conforme necessário, para uso interativo.

Fluxo do processo para atualização sem dependências externas

O diagrama a seguir representa o fluxo de trabalho recomendado para atualizar seu notebook sem dependências externas.

Siga esse processo se você estiver usando SQL ou Python e usando dependências externas, como conectores ou artefatos personalizados, como funções definidas pelo usuário implementadas em Python ou Java. Recomendamos que você atualize para o Runtime mais recente. O processo é o mesmo, independentemente da versão do Runtime da qual você está atualizando.

  1. Crie um novo notebook Studio usando o Runtime mais recente.

  2. Copie e cole o código de cada nota do caderno antigo para o novo.

  3. Atualize as dependências externas e os artefatos personalizados.

    • Procure novos conectores compatíveis com a versão Apache Flink do novo Runtime. Consulte a tabela e os conectores SQL na documentação do Apache Flink para encontrar os conectores corretos para a versão do Flink.

    • Atualize o código das funções definidas pelo usuário para corresponder às alterações na API Apache Flink e em todas as dependências do Python ou JAR usadas pelas funções definidas pelo usuário. Empacote novamente seu artefato personalizado atualizado.

    • Adicione esses novos conectores e artefatos ao novo notebook.

  4. No novo notebook, ajuste o código para torná-lo compatível com qualquer recurso do Apache Flink que tenha sido alterado em relação à versão anterior.

    • Execute o novo notebook. Abra o notebook e execute-o nota por nota, em sequência, e teste se funciona.

    • Faça as alterações necessárias no código.

    • Pare o novo caderno.

  5. Se você tivesse implantado o notebook antigo como aplicativo:

    • Implante o novo notebook como um novo aplicativo separado.

    • Pare o aplicativo antigo.

    • Execute o novo aplicativo sem captura instantânea.

  6. Pare o notebook antigo se ele estiver funcionando. Inicie o novo notebook, conforme necessário, para uso interativo.

Fluxo do processo para atualização com dependências externas

O diagrama a seguir representa o fluxo de trabalho recomendado para atualizar seu notebook com dependências externas.