FlinkJobProfile interface
Job specifications for flink clusters in application deployment mode. The specification is immutable even if job properties are changed by calling the RunJob API, please use the ListJob API to get the latest job information.
Properties
args | A string property representing additional JVM arguments for the Flink job. It should be space separated value. |
entry |
A string property that specifies the entry class for the Flink job. If not specified, the entry point is auto-detected from the flink job jar package. |
jar |
A string property that represents the name of the job JAR. |
job |
A string property that specifies the directory where the job JAR is located. |
save |
A string property that represents the name of the savepoint for the Flink job |
upgrade |
A string property that indicates the upgrade mode to be performed on the Flink job. It can have one of the following enum values => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE. |
Property Details
args
A string property representing additional JVM arguments for the Flink job. It should be space separated value.
args?: string
Property Value
string
entryClass
A string property that specifies the entry class for the Flink job. If not specified, the entry point is auto-detected from the flink job jar package.
entryClass?: string
Property Value
string
jarName
A string property that represents the name of the job JAR.
jarName: string
Property Value
string
jobJarDirectory
A string property that specifies the directory where the job JAR is located.
jobJarDirectory: string
Property Value
string
savePointName
A string property that represents the name of the savepoint for the Flink job
savePointName?: string
Property Value
string
upgradeMode
A string property that indicates the upgrade mode to be performed on the Flink job. It can have one of the following enum values => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.
upgradeMode: string
Property Value
string
Azure SDK for JavaScript