En esta página, se muestra cómo resolver problemas relacionados con la actualización de canalizaciones de transmisión de Dataflow con funciones como un trabajo de reemplazo paralelo.
Trabajos de reemplazo paralelos
Usa la siguiente guía cuando recibas errores al ejecutar un trabajo de reemplazo paralelo para actualizar una canalización.
Falta la opción obligatoria parallel_replace_job_min_parallel_pipelines_duration
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
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 se produce cuando se configuran parallel_replace_job_name o parallel_replace_job_id, pero no parallel_replace_job_min_parallel_pipelines_duration.
Para resolver este problema, configura la opción parallel_replace_job_min_parallel_pipelines_duration junto con la opción parallel_replace_job_name o parallel_replace_job_id.
Falta una de las opciones obligatorias parallel_replace_job_name o parallel_replace_job_id
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
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 se produce cuando se establece parallel_replace_job_min_parallel_pipelines_duration, pero no se establecen parallel_replace_job_name ni parallel_replace_job_id.
Para resolver este problema, configura la opción parallel_replace_job_name o parallel_replace_job_id junto con parallel_replace_job_min_parallel_pipelines_duration.
Valor de duración no válido para la opción parallel_replace_job_min_parallel_pipelines_duration
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
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 se produce porque el valor de duración proporcionado no es válido.
Para resolver este problema, establece una cadena de duración válida en el formato <value><unit>, como 10s, 1m o 1h. La duración debe ser de entre cero y 31 días.
Los trabajos de reemplazo paralelos solo son compatibles con Streaming Engine
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
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 se produce porque Streaming Engine no está habilitado para el trabajo nuevo.
Para resolver este problema, habilita Streaming Engine y vuelve a ejecutar el trabajo.
No se encontró el ID del trabajo de reemplazo paralelo
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
The parallel replace job id JOB_ID was not found.
Este problema se produce si se establece un ID de trabajo no válido o si el trabajo original se borró del sistema.
Para resolver este problema, asegúrate de que se use un ID de trabajo válido y en ejecución para la opción parallel_replace_job_id. Si el trabajo original ya se finalizó, quita las opciones de actualización de trabajos paralelos y crea un trabajo nuevo normal.
No se encontró el nombre del trabajo de reemplazo paralelo
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
The parallel replace job name JOB_NAME was not found.
Este problema se produce si se establece un nombre de trabajo no válido o si el trabajo original se borró del sistema.
Para resolver este problema, asegúrate de que se use un nombre de trabajo válido y en ejecución para la opción parallel_replace_job_name. Si el trabajo original ya se finalizó, quita las opciones de actualización de trabajos paralelos y crea un trabajo nuevo normal.
El trabajo de reemplazo paralelo apunta a un trabajo inactivo
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
The parallel replace job JOB_ID is not in a active state.
Este problema se produce porque el trabajo que se reemplaza no es un trabajo activo.
Para resolver este problema, asegúrate de que parallel_replace_job_name o parallel_replace_job_id apunten a un trabajo de transmisión válido y en ejecución. Si el trabajo anterior ya finalizó, quita las opciones de actualización de trabajos paralelos y crea un trabajo nuevo normal.
El trabajo de reemplazo paralelo apunta a un trabajo por lotes
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
The parallel replace job must be a streaming job.
Este problema se produce porque el trabajo que se reemplaza no es un trabajo de transmisión.
Para resolver este problema, asegúrate de que parallel_replace_job_name o parallel_replace_job_id apunten a un trabajo de transmisión en ejecución, no a un trabajo por lotes.
Las opciones de trabajos de reemplazo paralelos apuntan a diferentes trabajos
Cuando intentas ejecutar un trabajo de reemplazo paralelo, este se rechaza con el siguiente error:
The parallel replace job id JOB_ID must point to a job with name JOB_NAME.
Este problema se produce porque las opciones parallel_replace_job_name y parallel_replace_job_id apuntan a diferentes trabajos.
Para resolver este problema, si usas ambas opciones, asegúrate de que apunten al mismo trabajo de transmisión en ejecución. Como alternativa, usa solo una de las opciones, ya sea parallel_replace_job_name o parallel_replace_job_id.