Atualize o runtime do Studio - Managed Service for Apache Flink
Atualize seu notebook para um novo runtime do Studio

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

Atualize o runtime do Studio

Esta seção contém informações sobre como atualizar o runtime do seu notebook do Studio. Recomendamos que o runtime do Studio esteja sempre atualizado com a última versão suportada.

Atualize seu notebook para um novo runtime do Studio

Dependendo da maneira como o Studio é usado, as etapas para atualizar seu Runtime são diferentes. Selecione a opção que se aplica ao seu caso de uso.

Se você estiver usando SQL ou Python sem dependências externas, use o processo de atualização do Runtime a seguir. Recomendamos a atualização para a versão mais recente do runtime. O processo de atualização é o mesmo, independentemente da versão do Runtime que 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 notebook 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 para ver se funciona.

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

    • Interrompa o notebook.

  4. Se tivesse implantado o notebook antigo como aplicativo:

    • Implante o novo notebook como um novo aplicativo separadamente.

    • Interrompa o aplicativo antigo.

    • Execute o novo aplicativo sem snapshot.

  5. Interrompa 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 apresenta 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 atualizar para o Runtime mais recente. O processo é o mesmo, independentemente da versão do Runtime a partir 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 notebook antigo para o novo.

  3. Atualize as dependências externas e 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 do Apache Flink e em todas as dependências do Python ou JAR usadas pelas funções definidas pelo usuário. Empacote seu artefato personalizado atualizado novamente.

    • 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 para ver se funciona.

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

    • Interrompa o notebook.

  5. Se tivesse implantado o notebook antigo como aplicativo:

    • Implante o novo notebook como um novo aplicativo separadamente.

    • Interrompa o aplicativo antigo.

    • Execute o novo aplicativo sem snapshot.

  6. Interrompa 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 apresenta o fluxo de trabalho recomendado para atualizar seu notebook com dependências externas.