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.

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.

jarName

A string property that represents the name of the job JAR.

jobJarDirectory

A string property that specifies the directory where the job JAR is located.

savePointName

A string property that represents the name of the savepoint for the Flink job

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.

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