FlinkProfile interface

The Flink cluster profile.

Properties

catalogOptions

Flink cluster catalog options.

deploymentMode

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

historyServer

History Server container/ process CPU and memory requirements

jobManager

Job Manager container/ process CPU and memory requirements

jobSpec

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.

numReplicas

The number of task managers.

storage

The storage profile

taskManager

Task Manager container/ process CPU and memory requirements

Property Details

catalogOptions

Flink cluster catalog options.

catalogOptions?: FlinkCatalogOptions

Property Value

deploymentMode

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

deploymentMode?: string

Property Value

string

historyServer

History Server container/ process CPU and memory requirements

historyServer?: ComputeResourceDefinition

Property Value

jobManager

Job Manager container/ process CPU and memory requirements

jobManager: ComputeResourceDefinition

Property Value

jobSpec

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.

jobSpec?: FlinkJobProfile

Property Value

numReplicas

The number of task managers.

numReplicas?: number

Property Value

number

storage

The storage profile

storage: FlinkStorageProfile

Property Value

taskManager

Task Manager container/ process CPU and memory requirements

taskManager: ComputeResourceDefinition

Property Value