Realtime Compute for Apache Flink:Iniciar uma implantação

Pré-requisitos

Crie uma implantação. Para mais informações, consulte Implantar uma implantação.

Limitações

As opções de inicialização estão disponíveis apenas para implantações de streaming.

Precauções

• Se um usuário RAM, uma função RAM ou outra conta Alibaba Cloud iniciar a implantação, verifique se a conta tem as permissões necessárias para acessar o namespace de destino. Para mais informações, consulte Autorizar acesso no console e Gerenciar permissões.

• Ao iniciar uma implantação a partir do estado mais recente ou de um estado específico, o sistema verifica a compatibilidade de estado. Iniciar uma implantação com problemas de compatibilidade pode causar falhas na inicialização ou resultados inesperados. Para mais informações, consulte Referência de compatibilidade de estado do Flink.

Procedimento

1. Acesse a página Deployments.

   1. Faça login no console do Realtime Compute for Apache Flink.

   2. Na barra de navegação superior, selecione o namespace de destino.

   3. No painel O&M > Deployments, selecione STREAM ou BATCH na lista suspensa.

2. Localize a implantação desejada e clique em Start na coluna Actions.

3. (Opcional) Para implantações de streaming, configure as opções de inicialização.

   • Initial mode

     Use este modo para executar uma nova implantação ou iniciá-la sem usar um estado anterior.

     Estratégia	Descrição
     Specify source's start time	Selecione Specify source's start time e especifique um horário. Defina o horário de início da source para conectores Kafka, SLS, DataHub, ApsaraMQ for RocketMQ, Hologres, Paimon e MySQL. O horário de início especificado na página de inicialização da implantação substitui o parâmetro startTime definido no código DDL da implantação. Nota Versões do Kafka anteriores à 0,11 podem não ter suporte devido a possíveis incompatibilidades com a versão do cliente do conector. Recomendamos atualizar a versão do Kafka. Nem todos os conectores aceitam o parâmetro startTime. Para verificar a compatibilidade, confira se a cláusula WITH do conector inclui o parâmetro startTime. Para ver um exemplo, consulte Parâmetros WITH do SLS. O parâmetro startTime só entra em vigor para novas implantações iniciadas com esta opção. O sistema ignora esse parâmetro ao retomar uma implantação a partir de um checkpoint do sistema ou de um savepoint.
     Configure automatic tuning	Após ativar esta opção, selecione um modo de ajuste: Autopilot Mode: O sistema reduz recursos automaticamente quando o uso está baixo e os aumenta quando o uso ultrapassa determinado limiar. Para mais informações, consulte Ativar e configurar o Autopilot Mode. Scheduled Mode: Selecione um agendamento na lista suspensa. Um agendamento pode conter várias configurações de recursos mapeadas para diferentes horários. Configure os recursos com base nos padrões de uso de cada período. Para mais informações, consulte Configurar e aplicar um plano de ajuste agendado.

   • Resume mode

     Escolha uma estratégia de inicialização.

     Estratégia	Descrição
     Resume from latest state	Retoma a implantação a partir do savepoint ou checkpoint de sistema mais recente. O Flink detecta alterações no código SQL, nos parâmetros de runtime do Flink e na versão do mecanismo. Se houver alterações, clique em Click to detect ao lado de State Compatibility. Para mais detalhes sobre os resultados e ações recomendadas, consulte Compatibilidade.
     Resume from specified state	Selecione um savepoint específico para retomar. Para saber como criar um savepoint, consulte Gerenciar estado da implantação.
     Resume from another deployment	Use esta opção para especificar a implantação de destino e o respectivo savepoint para retomada. É possível compartilhar um savepoint entre implantações, desde que sejam compatíveis em termos de estado. Para mais informações, consulte Gerenciar estado da implantação.
     Allow Non-restored State Nota Esta opção tem suporte apenas para implantações JAR.	Por padrão, o Flink tenta mapear todo o estado do savepoint para os operadores da nova implantação. Se a implantação tiver sido modificada, esse mapeamento pode falhar. Ative esta opção para permitir que o Flink inicie a implantação ignorando qualquer estado que não possa ser mapeado. Para mais informações, consulte Allow None-Restored State.
     Configure automatic tuning	Após ativar esta opção, selecione um modo de ajuste: Autopilot Mode: O sistema reduz recursos automaticamente quando o uso está baixo e os aumenta quando o uso ultrapassa determinado limiar. Para mais informações, consulte Ativar e configurar o Autopilot Mode. Scheduled Mode: Selecione um agendamento na lista suspensa. Um agendamento pode conter várias configurações de recursos mapeadas para diferentes horários. Configure os recursos com base nos padrões de uso de cada período. Para mais informações, consulte Configurar e aplicar um plano de ajuste agendado.

4. Clique em Start.

   Na página O&M > Deployments, visualize o status da implantação. Para mais informações, consulte Visualizar status da implantação.

Documentação relacionada

• Após iniciar a implantação, modifique seus parâmetros de runtime. Para mais informações, consulte Configurar parâmetros de runtime. Alguns parâmetros também aceitam atualizações dinâmicas, o que reduz o tempo de inatividade do serviço ao evitar reinicializações. Para mais informações, consulte Dimensionamento dinâmico e atualizações de parâmetros.

• Com a implantação em execução, rastreie sua linhagem de dados para localizar problemas ou avaliar impactos. Para mais informações, consulte Visualizar linhagem de dados.

• Para conhecer o backend de estado corporativo GeminiStateBackend e sua comparação de desempenho com o RocksDBStateBackend, consulte Introdução ao GeminiStateBackend.