Flink
data class FlinkProfileArgs(val catalogOptions: Output<FlinkCatalogOptionsArgs>? = null, val deploymentMode: Output<Either<String, DeploymentMode>>? = null, val historyServer: Output<ComputeResourceDefinitionArgs>? = null, val jobManager: Output<ComputeResourceDefinitionArgs>, val jobSpec: Output<FlinkJobProfileArgs>? = null, val numReplicas: Output<Int>? = null, val storage: Output<FlinkStorageProfileArgs>, val taskManager: Output<ComputeResourceDefinitionArgs>) : ConvertibleToJava<FlinkProfileArgs>
The Flink cluster profile.
Constructors
Link copied to clipboard
constructor(catalogOptions: Output<FlinkCatalogOptionsArgs>? = null, deploymentMode: Output<Either<String, DeploymentMode>>? = null, historyServer: Output<ComputeResourceDefinitionArgs>? = null, jobManager: Output<ComputeResourceDefinitionArgs>, jobSpec: Output<FlinkJobProfileArgs>? = null, numReplicas: Output<Int>? = null, storage: Output<FlinkStorageProfileArgs>, taskManager: Output<ComputeResourceDefinitionArgs>)
Properties
Link copied to clipboard
Flink cluster catalog options.
Link copied to clipboard
A string property that indicates the deployment mode of Flink cluster. It can have one of the following enum values => Application, Session. Default value is Session
Link copied to clipboard
History Server container/ process CPU and memory requirements
Link copied to clipboard
Job Manager container/ process CPU and memory requirements
Link copied to clipboard
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.
Link copied to clipboard
The number of task managers.
Link copied to clipboard
The storage profile
Link copied to clipboard
Task Manager container/ process CPU and memory requirements