Flink Job Profile Args
data class FlinkJobProfileArgs(val args: Output<String>? = null, val entryClass: Output<String>? = null, val jarName: Output<String>, val jobJarDirectory: Output<String>, val savePointName: Output<String>? = null, val upgradeMode: Output<Either<String, UpgradeMode>>) : ConvertibleToJava<FlinkJobProfileArgs>
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
Link copied to clipboard
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.
Link copied to clipboard
A string property that specifies the directory where the job JAR is located.
Link copied to clipboard
A string property that represents the name of the savepoint for the Flink job
Link copied to clipboard
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.