Atualize o Studio Runtime - 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á.

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 SQL os conectores 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 mudanças no Apache Flink API e em qualquer Python ou JAR dependências 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.