Start a Flink deployment - Realtime Compute for Apache Flink: Central de Documentação do Alibaba Cloud

Após criar um deployment, você deve iniciá-lo na página Deployments. Iniciar um deployment também é necessário para retomar um deployment interrompido ou aplicar atualizações de parâmetros que exigem reinicialização.

Pré-requisitos

É necessário ter um deployment existente. Para mais informações, consulte Crie um deployment.

Limitações

Você pode especificar opções de inicialização apenas para um deployment de streaming.

Precauções

Se um usuário do RAM, uma função do RAM ou outra conta da Alibaba Cloud iniciar um deployment, certifique-se de que a identidade correspondente tenha acesso ao namespace de destino. Para mais informações, consulte Authorize access to the fully managed Flink console e Gerencie permissões.
Se você iniciar um deployment usando a opção Latest State ou Specific State, o sistema realizará uma verificação de compatibilidade de estado. Iniciar um deployment com incompatibilidades detectadas é arriscado, pois pode falhar ou produzir resultados inesperados. Para mais informações, consulte Flink state compatibility reference.

Procedimento

Abra a caixa de diálogo Start do deployment.
1. Faça login no console do Flink totalmente gerenciado como um usuário que tenha a função de proprietário do namespace.
2. Na barra de navegação superior, selecione o namespace de destino.
3. Na página O&M > Deployments, na lista suspensa, selecione STREAM ou BATCH.
Encontre o deployment de destino e, na coluna Actions, clique em Start.

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

Initial mode

Selecione este modo para um novo deployment ou quando não for possível reutilizar um estado existente. Com base nos seus requisitos de negócios, você também pode decidir se ativa o Autopilot.

Nota

O modo Initial é uma inicialização sem estado que não reutiliza nenhum estado. Do ponto de vista de um conector source, equivale a uma primeira inicialização, portanto, os parâmetros de posição de inicialização configurados na DDL entram em vigor novamente. Por exemplo, caso uma tabela source do MySQL CDC defina scan.startup.mode como latest-offset, o deployment lerá apenas a partir do offset mais recente atual após ser iniciado no modo Initial e não examinará novamente todos os dados históricos. Se o valor padrão initial for mantido, o deployment examinará novamente todos os dados históricos.

Se o armazenamento upstream tiver um limite de retenção de dados, como o período de retenção de log do Simple Log Service (SLS) ou o período de retenção de mensagens de uma fila de mensagens, o intervalo de dados lido novamente após uma inicialização no modo Initial será restrito por esse período de retenção e poderá diferir do intervalo de dados da primeira execução. Se o sink downstream sobrescrever os dados por chave primária, avalie o período de retenção de dados upstream antes de iniciar o deployment no modo Initial para evitar sobrescritas inesperadas na tabela de resultados.

Estratégia

Descrição

Specify source's start time

Selecione Specify source's start time e insira um horário específico.

Você pode definir um horário de início na interface para os seguintes conectores.

SQL jobs: Fluss, Hologres, Kafka, Upsert Kafka, ApsaraMQ for RocketMQ, ApsaraDB RDS for MySQL, MySQL CDC, Paimon e Log Service (SLS).
Flink CDC (YAML) jobs: MySQL e Kafka.

O tempo de leitura de dados especificado na interface de inicialização do deployment tem precedência sobre o startTime definido no código DDL do deployment.

Nota

Versões do Kafka anteriores a 0.11 podem não ser suportadas devido a uma possível incompatibilidade com a versão do cliente Kafka usada pelo conector. Recomendamos que você atualize sua versão do Kafka.
Nem todos os conectores suportam a configuração do parâmetro startTime. Para mais informações, consulte os parâmetros WITH de cada conector, como Log Service (SLS) WITH parameters, para verificar se o startTime está incluído.
O startTime só entra em vigor quando você inicia um novo deployment e especifica o startTime. Se você iniciar um deployment a partir de um checkpoint ou savepoint, especificar o startTime não terá efeito.

Configure Autopilot

Ative esta opção e selecione um modo de ajuste:

Autopilot Mode: O sistema reduz automaticamente os recursos quando o uso está baixo e os aumenta quando o uso atinge um determinado limiar. Para mais informações, consulte Ative e configure o Autopilot.
Scheduled Mode: Você deve selecionar uma programação na lista suspensa. Uma programação pode conter várias configurações de recursos para diferentes pontos no tempo. Você pode configurar recursos com base nos padrões de uso durante vários períodos. Para mais informações, consulte Configure and apply a scheduled tuning plan.

Resume mode

Você pode selecionar uma estratégia de inicialização com base nos seus requisitos de negócios e decidir se ativa o Autopilot.

Estratégia	Descrição
Latest State	Retoma o deployment a partir do `savepoint` ou `checkpoint` mais recente disponível. Se você selecionar esta opção para um deployment SQL, o sistema Flink detecta alterações no código SQL, nos parâmetros de tempo de execução do Flink e na versão do mecanismo. Se forem detectadas alterações, recomendamos que você clique em Click to detect ao lado de State Compatibility para verificar a compatibilidade. Em seguida, prossiga com base nos resultados. Para obter informações sobre os resultados de compatibilidade e as ações sugeridas, consulte Compatibility.
Specific State	Selecione um savepoint específico para retomar. Para saber como criar um savepoint, consulte Gerencie o estado do deployment.
Outro estado de deployment	Após selecionar esta opção, especifique um deployment de destino e seu respectivo savepoint para retomar. Os savepoints podem ser compartilhados entre deployments, mas o estado deve ser compatível. Para mais informações, consulte Gerencie o estado do deployment.
Allow Non-restored State Nota Esta opção é suportada apenas para deployments JAR.	Por padrão, o Flink tenta mapear todo o savepoint para os operadores do novo deployment. Se as modificações no deployment causarem alterações no estado do operador, o deployment poderá falhar ao retomar. Ative esta opção para permitir que o Flink ignore qualquer estado que não possa ser mapeado e prossiga com a inicialização. Para mais informações, consulte Allow Non-Restored State.
Configure Autopilot	Ative esta opção e selecione um modo de ajuste: Autopilot Mode: O sistema reduz automaticamente os recursos quando o uso está baixo e os aumenta quando o uso atinge um determinado limiar. Para mais informações, consulte Ative e configure o Autopilot. Scheduled Mode: Você deve selecionar uma programação na lista suspensa. Uma programação pode conter várias configurações de recursos para diferentes pontos no tempo. Você pode configurar recursos com base nos padrões de uso durante vários períodos. Para mais informações, consulte Configure and apply a scheduled tuning plan.

Clique em Start.

Na página O&M > Deployments, visualize o status do deployment. Para mais informações, consulte Visualize o status do deployment.

Documentos relacionados

Após o início de um deployment, modifique seus parâmetros de tempo de execução consultando Configure runtime parameters. Alguns parâmetros também suportam atualizações dinâmicas, o que evita o tempo de inatividade associado à interrupção e reinicialização de deployments. Para mais informações, consulte Dynamic scaling and dynamic parameter updates.
Após o início de um deployment, se você precisar rastrear seus dados para localizar problemas ou avaliar o impacto, consulte Visualize a linhagem de dados.
Para conhecer o GeminiStateBackend de nível corporativo e sua comparação de desempenho com o RocksDBStateBackend, consulte Introduction to the enterprise-grade state backend.