Package version:

Interface FlinkProfile

The Flink cluster profile.

interface FlinkProfile {
    catalogOptions?: FlinkCatalogOptions;
    deploymentMode?: string;
    historyServer?: ComputeResourceDefinition;
    jobManager: ComputeResourceDefinition;
    jobSpec?: FlinkJobProfile;
    numReplicas?: number;
    storage: FlinkStorageProfile;
    taskManager: ComputeResourceDefinition;
}

Properties

catalogOptions? deploymentMode? historyServer? jobManager jobSpec? numReplicas? storage taskManager

Properties

OptionalcatalogOptions

catalogOptions?: FlinkCatalogOptions

Flink cluster catalog options.

OptionaldeploymentMode

deploymentMode?: string

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

OptionalhistoryServer

historyServer?: ComputeResourceDefinition

History Server container/ process CPU and memory requirements

jobManager

jobManager: ComputeResourceDefinition

Job Manager container/ process CPU and memory requirements

OptionaljobSpec

jobSpec?: FlinkJobProfile

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.

OptionalnumReplicas

numReplicas?: number

The number of task managers.

storage

storage: FlinkStorageProfile

The storage profile

taskManager

taskManager: ComputeResourceDefinition

Task Manager container/ process CPU and memory requirements

Settings

Member Visibility