Nesta página, mostramos como resolver problemas com a atualização de pipelines de streaming do Dataflow usando recursos como um job de substituição paralela.
Jobs de substituição paralelos
Use as orientações a seguir quando receber erros ao executar um job de substituição paralela para fazer upgrade de um pipeline.
Opção obrigatória ausente: parallel_replace_job_min_parallel_pipelines_duration
Ao tentar executar um job de substituição paralela, ele é rejeitado 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.
Esse problema ocorre quando parallel_replace_job_name ou parallel_replace_job_id
está definido, mas parallel_replace_job_min_parallel_pipelines_duration não.
Para resolver esse problema, defina a opção parallel_replace_job_min_parallel_pipelines_duration junto com a opção parallel_replace_job_name ou parallel_replace_job_id.
Uma das opções obrigatórias parallel_replace_job_name ou parallel_replace_job_id está faltando
Ao tentar executar um job de substituição paralela, ele é rejeitado 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.
Esse problema ocorre quando parallel_replace_job_min_parallel_pipelines_duration é
definido, mas nem parallel_replace_job_name nem parallel_replace_job_id são
definidos.
Para resolver esse problema, defina a opção parallel_replace_job_name ou parallel_replace_job_id 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
Ao tentar executar um job de substituição paralela, ele é rejeitado 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.
Esse problema ocorre porque o valor de duração fornecido é inválido.
Para resolver esse problema, defina uma string de duração válida no formato <value><unit>, como 10s, 1m ou 1h. A duração precisa ser entre zero e 31
dias.
Os jobs de substituição paralela só são compatíveis com o Streaming Engine.
Ao tentar executar um job de substituição paralela, ele é rejeitado 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
Esse problema ocorre porque o Streaming Engine não está ativado para o novo job.
Para resolver esse problema, ative o Streaming Engine e execute o job novamente.
O ID do job de substituição paralela não foi encontrado
Ao tentar executar um job de substituição paralela, ele é rejeitado com o seguinte erro:
The parallel replace job id JOB_ID was not found.
Esse problema ocorre se um ID de job inválido for definido ou se o job original tiver sido removido do sistema.
Para resolver esse problema, verifique se um ID de job válido e em execução está sendo usado na opção
parallel_replace_job_id. Se o job original já tiver sido
encerrado, remova as opções de atualização de job paralelo e crie um novo job normal.
O nome do job de substituição paralela não foi encontrado
Ao tentar executar um job de substituição paralela, ele é rejeitado com o seguinte erro:
The parallel replace job name JOB_NAME was not found.
Esse problema ocorre se um nome de job inválido for definido ou se o job original tiver sido removido do sistema.
Para resolver esse problema, verifique se um nome de job válido e em execução está sendo usado para a opção
parallel_replace_job_name. Se o job original já tiver sido
encerrado, remova as opções de atualização de job paralelo e crie um novo job normal.
O job de substituição paralela aponta para um job inativo
Ao tentar executar um job de substituição paralela, ele é rejeitado com o seguinte erro:
The parallel replace job JOB_ID is not in a active state.
Esse problema ocorre porque o job que está sendo substituído não está ativo.
Para resolver esse problema, verifique se parallel_replace_job_name ou
parallel_replace_job_id apontam para um job de streaming válido e em execução. Se o job antigo já tiver sido encerrado, remova as opções de atualização paralela e crie um novo job normal.
O job de substituição paralela aponta para um job em lote
Ao tentar executar um job de substituição paralela, ele é rejeitado com o seguinte erro:
The parallel replace job must be a streaming job.
Esse problema ocorre porque o job que está sendo substituído não é de streaming.
Para resolver esse problema, verifique se parallel_replace_job_name ou
parallel_replace_job_id aponta para um job de streaming em execução, não um job em lote.
As opções de jobs de substituição paralela apontam para jobs diferentes
Ao tentar executar um job de substituição paralela, ele é rejeitado com o seguinte erro:
The parallel replace job id JOB_ID must point to a job with name JOB_NAME.
Isso acontece porque as opções parallel_replace_job_name e parallel_replace_job_id apontam para jobs diferentes.
Para resolver esse problema, se você usa as duas opções, verifique se elas apontam para o mesmo job de streaming em execução. Como alternativa, use apenas uma das opções, parallel_replace_job_name ou parallel_replace_job_id.