Compartilhar via


FlinkJobProfile interface

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.

Propriedades

args

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

entryClass

Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink. Se não for especificado, o ponto de entrada será detectado automaticamente do pacote jar do trabalho flink.

jarName

Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho.

jobJarDirectory

Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado.

savePointName

Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink

upgradeMode

Uma propriedade de cadeia de caracteres que indica o modo de atualização a ser executado no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE.

Detalhes da propriedade

args

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

args?: string

Valor da propriedade

string

entryClass

Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink. Se não for especificado, o ponto de entrada será detectado automaticamente do pacote jar do trabalho flink.

entryClass?: string

Valor da propriedade

string

jarName

Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho.

jarName: string

Valor da propriedade

string

jobJarDirectory

Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado.

jobJarDirectory: string

Valor da propriedade

string

savePointName

Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink

savePointName?: string

Valor da propriedade

string

upgradeMode

Uma propriedade de cadeia de caracteres que indica o modo de atualização a ser executado no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE.

upgradeMode: string

Valor da propriedade

string