A Dataproc job for running Apache Flink applications on YARN.
JSON representation |
---|
{ "args": [ string ], "jarFileUris": [ string ], "savepointUri": string, "properties": { string: string, ... }, "loggingConfig": { object ( |
Fields | |
---|---|
args[] |
Optional. The arguments to pass to the driver. Do not include arguments, such as |
jarFileUris[] |
Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks. |
savepointUri |
Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job. |
properties |
Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might be An object containing a list of |
loggingConfig |
Optional. The runtime log config for job execution. |
Union field driver . Required. The specification of the main method to call to drive the job. Specify either the jar file that contains the main class or the main class name. To pass both a main jar and a main class in the jar, add the jar to jarFileUris , and then specify the main class name in mainClass . driver can be only one of the following: |
|
mainJarFileUri |
The HCFS URI of the jar file that contains the main class. |
mainClass |
The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in |