Auf dieser Seite wird beschrieben, wie Sie Probleme beim Aktualisieren von Dataflow-Streamingpipelines mithilfe von Funktionen wie einem Job zum parallelen Ersetzen beheben.
Parallele Ersetzungsjobs
Beachten Sie die folgenden Hinweise, wenn beim Ausführen eines Parallel-Replace-Jobs zum Aktualisieren einer Pipeline Fehler auftreten.
Erforderliche Option parallel_replace_job_min_parallel_pipelines_duration fehlt
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
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.
Dieses Problem tritt auf, wenn parallel_replace_job_name oder parallel_replace_job_id festgelegt ist, aber parallel_replace_job_min_parallel_pipelines_duration nicht.
Um dieses Problem zu beheben, legen Sie die Option parallel_replace_job_min_parallel_pipelines_duration zusammen mit der Option parallel_replace_job_name oder parallel_replace_job_id fest.
Eine der erforderlichen Optionen parallel_replace_job_name oder parallel_replace_job_id fehlt
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
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.
Dieses Problem tritt auf, wenn parallel_replace_job_min_parallel_pipelines_duration festgelegt ist, aber weder parallel_replace_job_name noch parallel_replace_job_id.
Um dieses Problem zu beheben, legen Sie die Option parallel_replace_job_name oder parallel_replace_job_id zusammen mit parallel_replace_job_min_parallel_pipelines_duration fest.
Ungültiger Wert für die Dauer der Option parallel_replace_job_min_parallel_pipelines_duration
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
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.
Dieses Problem tritt auf, weil der angegebene Wert für die Dauer ungültig ist.
Um dieses Problem zu beheben, legen Sie einen gültigen Dauerstring im Format <value><unit> fest, z. B. 10s, 1m oder 1h. Die Dauer muss zwischen 0 und 31 Tagen liegen.
Parallele Ersetzungsjobs werden nur für Streaming Engine unterstützt
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
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
Dieses Problem tritt auf, weil Streaming Engine für den neuen Job nicht aktiviert ist.
Aktivieren Sie die Streaming-Engine und führen Sie den Job noch einmal aus, um das Problem zu beheben.
Die ID des Jobs zum parallelen Ersetzen wurde nicht gefunden.
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
The parallel replace job id JOB_ID was not found.
Dieses Problem tritt auf, wenn eine ungültige Job-ID festgelegt ist oder der ursprüngliche Job aus dem System entfernt wurde.
Achten Sie darauf, dass für die Option parallel_replace_job_id eine gültige, aktive Job-ID verwendet wird, um dieses Problem zu beheben. Wenn der ursprüngliche Job bereits beendet wurde, entfernen Sie die Optionen für die Aktualisierung des parallelen Jobs und erstellen Sie einen normalen neuen Job.
Der Name des Jobs für paralleles Ersetzen wurde nicht gefunden.
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
The parallel replace job name JOB_NAME was not found.
Dieses Problem tritt auf, wenn ein ungültiger Jobname festgelegt ist oder der ursprüngliche Job aus dem System entfernt wurde.
Achten Sie zur Behebung dieses Problems darauf, dass für die Option parallel_replace_job_name ein gültiger, aktiver Jobname verwendet wird. Wenn der ursprüngliche Job bereits beendet wurde, entfernen Sie die Optionen für die Aktualisierung des parallelen Jobs und erstellen Sie einen normalen neuen Job.
Der Job zum parallelen Ersetzen verweist auf einen nicht aktiven Job.
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
The parallel replace job JOB_ID is not in a active state.
Dieses Problem tritt auf, weil der zu ersetzende Job kein aktiver Job ist.
Achten Sie zur Behebung dieses Problems darauf, dass parallel_replace_job_name oder parallel_replace_job_id auf einen gültigen, laufenden Streamingjob verweisen. Wenn der alte Job bereits beendet wurde, entfernen Sie die Optionen für die parallele Jobaktualisierung und erstellen Sie einen normalen neuen Job.
Paralleler Ersetzungsjob verweist auf einen Batchjob
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
The parallel replace job must be a streaming job.
Dieses Problem tritt auf, weil der Job, der ersetzt wird, kein Streamingjob ist.
Achten Sie zur Behebung dieses Problems darauf, dass parallel_replace_job_name oder parallel_replace_job_id auf einen laufenden Streamingjob und nicht auf einen Batchjob verweist.
Parallele Ersetzungsjob-Optionen verweisen auf unterschiedliche Jobs
Wenn Sie versuchen, einen parallelen Ersetzungsjob auszuführen, wird der Job mit dem folgenden Fehler abgelehnt:
The parallel replace job id JOB_ID must point to a job with name JOB_NAME.
Dieses Problem tritt auf, weil die Optionen parallel_replace_job_name und parallel_replace_job_id auf unterschiedliche Jobs verweisen.
Wenn Sie beide Optionen verwenden, müssen sie auf denselben laufenden Streamingjob verweisen. Alternativ können Sie auch nur eine der Optionen verwenden, entweder parallel_replace_job_name oder parallel_replace_job_id.