Partilhar via


FlinkJobProfile interface

Especificações de tarefas para clusters flink no modo de implementação de aplicações. A especificação é imutável mesmo que as propriedades da tarefa sejam alteradas ao chamar a API RunJob, utilize a API ListJob para obter as informações mais recentes da tarefa.

Propriedades

args

Uma propriedade de cadeia que representa argumentos JVM adicionais para a tarefa Flink. Deve ser um valor separado por espaço.

entryClass

Uma propriedade de cadeia que especifica a classe de entrada para a tarefa Flink. Se não for especificado, o ponto de entrada é detetado automaticamente a partir do pacote jar da tarefa de flink.

jarName

Uma propriedade de cadeia que representa o nome do JAR da tarefa.

jobJarDirectory

Uma propriedade de cadeia que especifica o diretório onde está localizado o JAR da tarefa.

savePointName

Uma propriedade de cadeia que representa o nome do ponto de poupança para a tarefa Flink

upgradeMode

Uma propriedade de cadeia que indica o modo de atualização a executar na tarefa Flink. Pode ter um dos seguintes valores de enum => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.

Detalhes de Propriedade

args

Uma propriedade de cadeia que representa argumentos JVM adicionais para a tarefa Flink. Deve ser um valor separado por espaço.

args?: string

Valor de Propriedade

string

entryClass

Uma propriedade de cadeia que especifica a classe de entrada para a tarefa Flink. Se não for especificado, o ponto de entrada é detetado automaticamente a partir do pacote jar da tarefa de flink.

entryClass?: string

Valor de Propriedade

string

jarName

Uma propriedade de cadeia que representa o nome do JAR da tarefa.

jarName: string

Valor de Propriedade

string

jobJarDirectory

Uma propriedade de cadeia que especifica o diretório onde está localizado o JAR da tarefa.

jobJarDirectory: string

Valor de Propriedade

string

savePointName

Uma propriedade de cadeia que representa o nome do ponto de poupança para a tarefa Flink

savePointName?: string

Valor de Propriedade

string

upgradeMode

Uma propriedade de cadeia que indica o modo de atualização a executar na tarefa Flink. Pode ter um dos seguintes valores de enum => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.

upgradeMode: string

Valor de Propriedade

string