FlinkProfile interface

O perfil do cluster Flink.

Propriedades

catalogOptions

Opções de catálogo de cluster Flink.

deploymentMode

Uma propriedade de cadeia de caracteres que indica o modo de implantação do cluster Flink. Ele pode ter um dos seguintes valores de enumeração => Aplicativo, Sessão. O valor padrão é Session

historyServer

Requisitos de CPU e memória de processo e contêiner do Servidor de Histórico

jobManager

Requisitos de CPU e memória de processo e contêiner do Gerenciador de Trabalho

jobSpec

Especificações de trabalho para clusters flink no modo de implantação de aplicativo. A especificação é imutável mesmo que as propriedades do trabalho sejam alteradas chamando a API RunJob, use a API ListJob para obter as informações de trabalho mais recentes.

numReplicas

O número de gerentes de tarefas.

storage

O perfil de armazenamento

taskManager

Requisitos de CPU e memória de processo e contêiner do Gerenciador de Tarefas

Detalhes da propriedade

catalogOptions

Opções de catálogo de cluster Flink.

catalogOptions?: FlinkCatalogOptions

Valor da propriedade

deploymentMode

Uma propriedade de cadeia de caracteres que indica o modo de implantação do cluster Flink. Ele pode ter um dos seguintes valores de enumeração => Aplicativo, Sessão. O valor padrão é Session

deploymentMode?: string

Valor da propriedade

string

historyServer

Requisitos de CPU e memória de processo e contêiner do Servidor de Histórico

historyServer?: ComputeResourceDefinition

Valor da propriedade

jobManager

Requisitos de CPU e memória de processo e contêiner do Gerenciador de Trabalho

jobManager: ComputeResourceDefinition

Valor da propriedade

jobSpec

Especificações de trabalho para clusters flink no modo de implantação de aplicativo. A especificação é imutável mesmo que as propriedades do trabalho sejam alteradas chamando a API RunJob, use a API ListJob para obter as informações de trabalho mais recentes.

jobSpec?: FlinkJobProfile

Valor da propriedade

numReplicas

O número de gerentes de tarefas.

numReplicas?: number

Valor da propriedade

number

storage

O perfil de armazenamento

storage: FlinkStorageProfile

Valor da propriedade

taskManager

Requisitos de CPU e memória de processo e contêiner do Gerenciador de Tarefas

taskManager: ComputeResourceDefinition

Valor da propriedade