gcloud: Wed Aug 2 11:22:33 UTC 2023

gcloud/alpha/dataproc/jobs/submit/flink

@@ -0,0 +1,152 @@
+NAME
+    gcloud alpha dataproc jobs submit flink - submit a Flink job to a cluster
+
+SYNOPSIS
+    gcloud alpha dataproc jobs submit flink
+        (--class=MAIN_CLASS | --jar=MAIN_JAR)
+        (--cluster=CLUSTER | --cluster-labels=[KEY=VALUE,...]) [--async]
+        [--bucket=BUCKET] [--driver-log-levels=[PACKAGE=LEVEL,...]]
+        [--jars=[JAR,...]] [--labels=[KEY=VALUE,...]]
+        [--max-failures-per-hour=MAX_FAILURES_PER_HOUR]
+        [--max-failures-total=MAX_FAILURES_TOTAL]
+        [--properties=[PROPERTY=VALUE,...]] [--properties-file=PROPERTIES_FILE]
+        [--region=REGION] [--savepoint=SAVEPOINT] [GCLOUD_WIDE_FLAG ...]
+        [-- JOB_ARGS ...]
+
+DESCRIPTION
+    (ALPHA) Submit a Flink job to a cluster.
+
+EXAMPLES
+    To submit a Flink job that runs the main class of a jar, run:
+
+        $ gcloud alpha dataproc jobs submit flink --cluster=my-cluster \
+            --region=us-central1 --jar=my_jar.jar -- arg1 arg2
+
+    To submit a Flink job that runs a specific class as an entrypoint:
+
+        $ gcloud alpha dataproc jobs submit flink --cluster=my-cluster \
+            --region=us-central1 --class=org.my.main.Class \
+            --jars=my_jar.jar -- arg1 arg2
+
+    To submit a Flink job that runs a jar that is on the cluster, run:
+
+        $ gcloud alpha dataproc jobs submit flink --cluster=my-cluster \
+            --region=us-central1 \
+            --jar=/usr/lib/flink/examples/streaming/TopSpeedWindowing.jar
+
+POSITIONAL ARGUMENTS
+     [-- JOB_ARGS ...]
+        The job arguments to pass.
+
+        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
+     --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,...]
+        List of package to log4j log level pairs to configure driver logging.
+        For example: root=FATAL,com.example=INFO.
+
+     --jars=[JAR,...]
+        Comma-separated list of jar files to provide to the task manager
+        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,...]
+        List of key=value pairs to configure Flink. For a list of available
+        properties, see:
+        https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/.
+
+     --properties-file=PROPERTIES_FILE
+        Path to a local file or a file in a Cloud Storage bucket containing
+        configuration properties for the job. The client machine running this
+        command must have read permission to the file.
+
+        Specify properties in the form of property=value in the text file. For
+        example:
+
+              # Properties to set for the job:
+              key1=value1
+              key2=value2
+              # Comment out properties not used.
+              # key3=value3
+
+        If a property is set in both --properties and --properties-file, the
+        value defined in --properties takes precedence.
+
+     --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.
+
+     --savepoint=SAVEPOINT
+        HCFS URI of the savepoint that is used to refer to the state of the
+        previously stopped job. The new job will resume previous state from
+        there.
+
+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
+    This command is currently in alpha and might change without notice. If this
+    command fails with API permission errors despite specifying the correct
+    project, you might be trying to access an API with an invitation-only early
+    access allowlist. These variants are also available:
+
+        $ gcloud dataproc jobs submit flink
+
+        $ gcloud beta dataproc jobs submit flink
+

gcloud/alpha/dataproc/jobs/submit/help

@@ -63,6 +63,9 @@ GCLOUD WIDE FLAGS
 COMMANDS
     COMMAND is one of the following:
 
+     flink
+        (ALPHA) Submit a Flink job to a cluster.
+
      hadoop
         (ALPHA) Submit a Hadoop job to a cluster.