En esta página se explica cómo resolver problemas al actualizar las canalizaciones de streaming de Dataflow mediante funciones como la sustitución paralela de trabajos.
Tareas de sustitución paralelas
Sigue estas directrices cuando se produzcan errores al ejecutar un trabajo de sustitución en paralelo para actualizar una canalización.
Falta la opción obligatoria parallel_replace_job_min_parallel_pipelines_duration
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra 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 define parallel_replace_job_name o parallel_replace_job_id, pero no parallel_replace_job_min_parallel_pipelines_duration.
Para solucionar este problema, define 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 sustitución en paralelo, se rechaza y se muestra 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 define parallel_replace_job_min_parallel_pipelines_duration, pero no se definen parallel_replace_job_name ni parallel_replace_job_id.
Para solucionar este problema, define la opción parallel_replace_job_name o la opción 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 sustitución en paralelo, se rechaza y se muestra 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 solucionar este problema, defina una cadena de duración válida con el formato <value><unit>
, como 10s, 1m o 1h. La duración debe ser de entre cero y 31 días.
Las tareas de sustitución en paralelo solo se admiten en Streaming Engine
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra 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 nuevo trabajo.
Para solucionar este problema, habilita Streaming Engine y vuelve a ejecutar el trabajo.
No se ha encontrado el ID de la tarea de sustitución paralela
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra 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 ha eliminado del sistema.
Para solucionar este problema, asegúrese de que se utiliza un ID de trabajo válido y activo para la opción parallel_replace_job_id. Si el trabajo original ya se ha finalizado, elimina las opciones de actualización del trabajo paralelo y crea un nuevo trabajo normal.
No se ha encontrado el nombre del trabajo de sustitución paralela
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra el siguiente error:
The parallel replace job name JOB_NAME was not found.
Este problema se produce si se ha definido un nombre de trabajo no válido o si el trabajo original se ha eliminado del sistema.
Para solucionar este problema, asegúrese de que se utiliza un nombre de trabajo válido y en ejecución para la opción parallel_replace_job_name. Si el trabajo original ya se ha finalizado, elimina las opciones de actualización del trabajo paralelo y crea un nuevo trabajo normal.
El trabajo de sustitución en paralelo apunta a un trabajo no activo
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra el siguiente error:
The parallel replace job JOB_ID is not in a active state.
Este problema se produce porque el trabajo que se va a sustituir no está activo.
Para solucionar este problema, asegúrate de que parallel_replace_job_name o parallel_replace_job_id apunten a un trabajo de streaming válido y en ejecución. Si el antiguo trabajo ya se ha finalizado, elimina las opciones de actualización del trabajo paralelo y crea un nuevo trabajo normal.
La tarea de sustitución paralela apunta a una tarea por lotes
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra el siguiente error:
The parallel replace job must be a streaming job.
Este problema se produce porque el trabajo que se va a sustituir no es un trabajo de streaming.
Para solucionar este problema, asegúrate de que parallel_replace_job_name o parallel_replace_job_id apunten a un trabajo de streaming en ejecución, no a un trabajo por lotes.
Las opciones de la tarea de sustitución paralela apuntan a tareas diferentes
Cuando intentas ejecutar un trabajo de sustitución en paralelo, se rechaza y se muestra 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 trabajos diferentes.
Para solucionar este problema, si usa ambas opciones, asegúrese de que apunten al mismo trabajo de streaming en ejecución. También puedes usar solo una de las opciones, ya sea parallel_replace_job_name o parallel_replace_job_id.