mirror of
https://github.com/imjasonh/gcloud-help
synced 2026-07-16 20:36:39 +00:00
133 lines
4.9 KiB
Text
133 lines
4.9 KiB
Text
NAME
|
|
gcloud dataproc jobs submit hadoop - submit a Hadoop job to a cluster
|
|
|
|
SYNOPSIS
|
|
gcloud dataproc jobs submit hadoop (--class=MAIN_CLASS | --jar=MAIN_JAR)
|
|
(--cluster=CLUSTER | --cluster-labels=[KEY=VALUE,...])
|
|
[--archives=[ARCHIVE,...]] [--async] [--bucket=BUCKET]
|
|
[--driver-log-levels=[PACKAGE=LEVEL,...]] [--files=[FILE,...]]
|
|
[--jars=[JAR,...]] [--labels=[KEY=VALUE,...]]
|
|
[--max-failures-per-hour=MAX_FAILURES_PER_HOUR]
|
|
[--max-failures-total=MAX_FAILURES_TOTAL]
|
|
[--properties=[PROPERTY=VALUE,...]] [--region=REGION]
|
|
[GCLOUD_WIDE_FLAG ...] [-- JOB_ARGS ...]
|
|
|
|
DESCRIPTION
|
|
Submit a Hadoop job to a cluster.
|
|
|
|
EXAMPLES
|
|
To submit a Hadoop job that runs the main class of a jar, run:
|
|
|
|
$ gcloud dataproc jobs submit hadoop --cluster=my_cluster \
|
|
--jar=my_jar.jar -- arg1 arg2
|
|
|
|
To submit a Hadoop job that runs a specific class of a jar, run:
|
|
|
|
$ gcloud dataproc jobs submit hadoop --cluster=my_cluster \
|
|
--class=org.my.main.Class --jars=my_jar1.jar,my_jar2.jar \
|
|
-- arg1 arg2
|
|
|
|
To submit a Hadoop job that runs a jar that is already on the cluster, run:
|
|
|
|
$ gcloud dataproc jobs submit hadoop --cluster=my_cluster \
|
|
--jar=file:///usr/lib/hadoop-op/hadoop-op-examples.jar \
|
|
-- wordcount gs://my_bucket/my_file.txt gs://my_bucket/output
|
|
|
|
POSITIONAL ARGUMENTS
|
|
[-- JOB_ARGS ...]
|
|
The arguments to pass to the driver.
|
|
|
|
The '--' argument must be specified between gcloud specific args on the
|
|
left and JOB_ARGS on the right.
|
|
|
|
REQUIRED FLAGS
|
|
Exactly one of these must be specified:
|
|
|
|
--class=MAIN_CLASS
|
|
The class containing the main method of the driver. Must be in a
|
|
provided jar or jar that is already on the classpath
|
|
|
|
--jar=MAIN_JAR
|
|
The HCFS URI of jar file containing the driver jar.
|
|
|
|
Exactly one of these must be specified:
|
|
|
|
--cluster=CLUSTER
|
|
The Dataproc cluster to submit the job to.
|
|
|
|
--cluster-labels=[KEY=VALUE,...]
|
|
List of label KEY=VALUE pairs to add.
|
|
|
|
Keys must start with a lowercase character and contain only hyphens
|
|
(-), underscores (_), lowercase characters, and numbers. Values must
|
|
contain only hyphens (-), underscores (_), lowercase characters, and
|
|
numbers.
|
|
|
|
Labels of Dataproc cluster on which to place the job.
|
|
|
|
OPTIONAL FLAGS
|
|
--archives=[ARCHIVE,...]
|
|
Comma separated list of archives to be provided to the job. must be one
|
|
of the following file formats: .zip, .tar, .tar.gz, or .tgz.
|
|
|
|
--async
|
|
Return immediately, without waiting for the operation in progress to
|
|
complete.
|
|
|
|
--bucket=BUCKET
|
|
The Cloud Storage bucket to stage files in. Defaults to the cluster's
|
|
configured bucket.
|
|
|
|
--driver-log-levels=[PACKAGE=LEVEL,...]
|
|
A list of package to log4j log level pairs to configure driver logging.
|
|
For example: root=FATAL,com.example=INFO
|
|
|
|
--files=[FILE,...]
|
|
Comma separated list of file paths to be provided to the job. A file
|
|
path can either be a path to a local file or a path to a file already
|
|
in a Cloud Storage bucket.
|
|
|
|
--jars=[JAR,...]
|
|
Comma separated list of jar files to be provided to the MR and driver
|
|
classpaths.
|
|
|
|
--labels=[KEY=VALUE,...]
|
|
List of label KEY=VALUE pairs to add.
|
|
|
|
Keys must start with a lowercase character and contain only hyphens
|
|
(-), underscores (_), lowercase characters, and numbers. Values must
|
|
contain only hyphens (-), underscores (_), lowercase characters, and
|
|
numbers.
|
|
|
|
--max-failures-per-hour=MAX_FAILURES_PER_HOUR
|
|
Specifies the maximum number of times a job can be restarted per hour
|
|
in event of failure. Default is 0 (no retries after job failure).
|
|
|
|
--max-failures-total=MAX_FAILURES_TOTAL
|
|
Specifies the maximum total number of times a job can be restarted
|
|
after the job fails. Default is 0 (no retries after job failure).
|
|
|
|
--properties=[PROPERTY=VALUE,...]
|
|
A list of key value pairs to configure Hadoop.
|
|
|
|
--region=REGION
|
|
Dataproc region to use. Each Dataproc region constitutes an independent
|
|
resource namespace constrained to deploying instances into Compute
|
|
Engine zones inside the region. Overrides the default dataproc/region
|
|
property value for this command invocation.
|
|
|
|
GCLOUD WIDE FLAGS
|
|
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.
|
|
|
|
NOTES
|
|
These variants are also available:
|
|
|
|
$ gcloud alpha dataproc jobs submit hadoop
|
|
|
|
$ gcloud beta dataproc jobs submit hadoop
|
|
|