Esta página mostra como resolver problemas com a atualização de pipelines de streaming do Dataflow usando funcionalidades como uma tarefa de substituição paralela.
Trabalhos de substituição paralelos
Use as seguintes orientações quando receber erros ao executar uma tarefa de substituição paralela para atualizar um pipeline.
Opção obrigatória em falta parallel_replace_job_min_parallel_pipelines_duration
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job requires you to set the parallel_replace_job_min_parallel_pipelines_duration field. Set the field and try your request again.
Este problema ocorre quando parallel_replace_job_name ou parallel_replace_job_id
está definido, mas parallel_replace_job_min_parallel_pipelines_duration não está.
Para resolver este problema, defina a opção parallel_replace_job_min_parallel_pipelines_duration juntamente com a opção parallel_replace_job_name ou parallel_replace_job_id.
Falta uma das opções obrigatórias parallel_replace_job_name ou parallel_replace_job_id
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job requires you to set either the parallel_replace_job_id field or the parallel_replace_job_name field. Set one of these fields, then try your request again.
Este problema ocorre quando parallel_replace_job_min_parallel_pipelines_duration está definido, mas nem parallel_replace_job_name nem parallel_replace_job_id estão definidos.
Para resolver este problema, defina a opção parallel_replace_job_name ou parallel_replace_job_id juntamente com parallel_replace_job_min_parallel_pipelines_duration.
Valor de duração inválido para a opção parallel_replace_job_min_parallel_pipelines_duration
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
An invalid duration string VALUE is set for `parallel_replace_job_min_parallel_pipelines_duration`. Set a valid duration string, such as 10s, 1m, or 1h. but not longer than 31 days.
Este problema ocorre porque o valor de duração fornecido é inválido.
Para resolver este problema, defina uma string de duração válida no formato <value><unit>, como 10s, 1m ou 1h. A duração tem de ser entre zero e 31 dias.
Os trabalhos de substituição paralelos só são suportados para o Streaming Engine
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
Parallel replace job is only supported for Streaming Engine. To enable Streaming Engine follow the instructions at https://cloud.google.com/dataflow/docs/streaming-engine#use
Este problema ocorre porque o Streaming Engine não está ativado para a nova tarefa.
Para resolver este problema, ative o Streaming Engine e volte a executar a tarefa.
Não foi encontrado o ID da tarefa de substituição paralela
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job id JOB_ID was not found.
Este problema ocorre se for definido um ID de trabalho inválido ou se o trabalho original tiver sido removido do sistema.
Para resolver este problema, certifique-se de que é usado um ID de tarefa válido e em execução para a opção parallel_replace_job_id. Se o trabalho original já tiver sido terminado, remova as opções de atualização de trabalho paralelo e crie um novo trabalho normal.
Não foi encontrado o nome da tarefa de substituição paralela
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job name JOB_NAME was not found.
Este problema ocorre se for definido um nome de tarefa inválido ou se a tarefa original tiver sido eliminada do sistema.
Para resolver este problema, certifique-se de que é usado um nome de tarefa válido e em execução para a opção parallel_replace_job_name. Se o trabalho original já tiver sido terminado, remova as opções de atualização de trabalho paralelo e crie um novo trabalho normal.
O trabalho de substituição paralela aponta para um trabalho não ativo
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job JOB_ID is not in a active state.
Este problema ocorre porque a tarefa que está a ser substituída não é uma tarefa ativa.
Para resolver este problema, certifique-se de que parallel_replace_job_name ou
parallel_replace_job_id apontam para uma tarefa de streaming válida e em execução. Se a tarefa antiga já tiver sido terminada, remova as opções de atualização de tarefas paralelas e crie uma nova tarefa normal.
O trabalho de substituição paralela aponta para um trabalho em lote
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job must be a streaming job.
Este problema ocorre porque a tarefa que está a ser substituída não é uma tarefa de streaming.
Para resolver este problema, certifique-se de que parallel_replace_job_name ou parallel_replace_job_id aponta para uma tarefa de streaming em execução e não para uma tarefa em lote.
As opções de substituição paralela de empregos apontam para empregos diferentes
Quando tenta executar uma tarefa de substituição paralela, a tarefa é rejeitada com o seguinte erro:
The parallel replace job id JOB_ID must point to a job with name JOB_NAME.
Este problema ocorre porque as opções parallel_replace_job_name e parallel_replace_job_id apontam para tarefas diferentes.
Para resolver este problema, se usar ambas as opções, certifique-se de que apontam para a mesma tarefa de streaming em execução. Em alternativa, use apenas uma das opções, parallel_replace_job_name ou parallel_replace_job_id.