Questa pagina mostra come risolvere i problemi relativi all'upgrade delle pipeline di streaming Dataflow utilizzando funzionalità come un job di sostituzione parallela.
Job di sostituzione parallela
Segui queste indicazioni quando si verificano errori durante l'esecuzione di un job di sostituzione parallela per eseguire l'upgrade di una pipeline.
Opzione obbligatoria mancante parallel_replace_job_min_parallel_pipelines_duration
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
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.
Questo problema si verifica quando è impostato parallel_replace_job_name o parallel_replace_job_id, ma non parallel_replace_job_min_parallel_pipelines_duration.
Per risolvere il problema, imposta l'opzione
parallel_replace_job_min_parallel_pipelines_duration insieme all'opzione
parallel_replace_job_name o parallel_replace_job_id.
Manca una delle opzioni obbligatorie parallel_replace_job_name o parallel_replace_job_id
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
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.
Questo problema si verifica quando parallel_replace_job_min_parallel_pipelines_duration è
impostato, ma non parallel_replace_job_name né parallel_replace_job_id.
Per risolvere il problema, imposta l'opzione parallel_replace_job_name o
parallel_replace_job_id insieme a
parallel_replace_job_min_parallel_pipelines_duration.
Valore di durata non valido per l'opzione parallel_replace_job_min_parallel_pipelines_duration
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
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.
Questo problema si verifica perché il valore della durata fornito non è valido.
Per risolvere il problema, imposta una stringa di durata valida nel formato <value><unit>, ad esempio 10s, 1m o 1h. La durata deve essere compresa tra zero e 31
giorni.
I job di sostituzione parallela sono supportati solo per Streaming Engine
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
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
Questo problema si verifica perché Streaming Engine non è abilitato per il nuovo job.
Per risolvere il problema, attiva Streaming Engine ed esegui nuovamente il job.
Impossibile trovare l'ID job di sostituzione parallela
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
The parallel replace job id JOB_ID was not found.
Questo problema si verifica se è impostato un ID lavoro non valido o se il lavoro originale è stato eliminato dal sistema.
Per risolvere il problema, assicurati che venga utilizzato un ID job valido e in esecuzione per l'opzione
parallel_replace_job_id. Se il job originale è già stato
terminato, rimuovi le opzioni di aggiornamento del job parallelo e crea un nuovo job normale.
Impossibile trovare il nome del job di sostituzione parallela
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
The parallel replace job name JOB_NAME was not found.
Questo problema si verifica se è impostato un nome del job non valido o se il job originale è stato eliminato dal sistema.
Per risolvere il problema, assicurati che per l'opzione
parallel_replace_job_name venga utilizzato un nome di job valido e in esecuzione. Se il job originale è già stato
terminato, rimuovi le opzioni di aggiornamento del job parallelo e crea un nuovo job normale.
Il job di sostituzione parallela punta a un job non attivo
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
The parallel replace job JOB_ID is not in a active state.
Questo problema si verifica perché il job sostituito non è un job attivo.
Per risolvere il problema, assicurati che parallel_replace_job_name o
parallel_replace_job_id indirizzino a un job di streaming valido e in esecuzione. Se il vecchio
job è già stato terminato, rimuovi le opzioni di aggiornamento del job parallelo e crea un
nuovo job normale.
Il job di sostituzione parallela punta a un job batch
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
The parallel replace job must be a streaming job.
Questo problema si verifica perché il job sostituito non è un job di streaming.
Per risolvere il problema, assicurati che parallel_replace_job_name o
parallel_replace_job_id punti a un job di streaming in esecuzione, non a un job batch.
Le opzioni del job di sostituzione parallela puntano a job diversi
Quando provi a eseguire un job di sostituzione parallela, il job viene rifiutato con il seguente errore:
The parallel replace job id JOB_ID must point to a job with name JOB_NAME.
Questo problema si verifica perché le opzioni parallel_replace_job_name e
parallel_replace_job_id rimandano a job diversi.
Per risolvere il problema, se utilizzi entrambe le opzioni, assicurati che puntino allo stesso
job di streaming in esecuzione. In alternativa, utilizza solo una delle opzioni, parallel_replace_job_name o parallel_replace_job_id.