gcloud dataflow jobs drain - drains all jobs that match the command line arguments
gcloud dataflow jobs drain JOB_ID [JOB_ID ...] [--region=REGION_ID] [GCLOUD_WIDE_FLAG ...]
Once Drain is triggered, the pipeline will stop accepting new inputs. The input watermark will be advanced to infinity. Elements already in the pipeline will continue to be processed. Drained jobs can safely be cancelled.
- JOB_ID [JOB_ID ...]
The job IDs to operate on.
- --region=REGION_ID
The region ID of the jobs' regional endpoint. Defaults to 'us-central1'.
These flags are available to all commands: --access-token-file, --account, --billing-project, --configuration, --flags-file, --flatten, --format, --help, --impersonate-service-account, --log-http, --project, --quiet, --trace-token, --user-output-enabled, --verbosity.
Run $ gcloud help for details.
This variant is also available:
$ gcloud beta dataflow jobs drain