Compartir a través de


FlinkJobProfile interface

Especificaciones de trabajo para clústeres de flink en modo de implementación de aplicaciones. La especificación es inmutable incluso si se cambian las propiedades del trabajo mediante una llamada a runJob API, use listJob API para obtener la información más reciente del trabajo.

Propiedades

args

Propiedad de cadena que representa argumentos JVM adicionales para el trabajo de Flink. Debe ser un valor separado por espacios.

entryClass

Propiedad de cadena que especifica la clase de entrada para el trabajo de Flink. Si no se especifica, el punto de entrada se detecta automáticamente desde el paquete jar del trabajo de flink.

jarName

Propiedad de cadena que representa el nombre del archivo JAR del trabajo.

jobJarDirectory

Propiedad de cadena que especifica el directorio donde se encuentra el archivo JAR del trabajo.

savePointName

Propiedad de cadena que representa el nombre del punto de retorno para el trabajo de Flink

upgradeMode

Propiedad de cadena que indica el modo de actualización que se va a realizar en el trabajo de Flink. Puede tener uno de los siguientes valores de enumeración => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.

Detalles de las propiedades

args

Propiedad de cadena que representa argumentos JVM adicionales para el trabajo de Flink. Debe ser un valor separado por espacios.

args?: string

Valor de propiedad

string

entryClass

Propiedad de cadena que especifica la clase de entrada para el trabajo de Flink. Si no se especifica, el punto de entrada se detecta automáticamente desde el paquete jar del trabajo de flink.

entryClass?: string

Valor de propiedad

string

jarName

Propiedad de cadena que representa el nombre del archivo JAR del trabajo.

jarName: string

Valor de propiedad

string

jobJarDirectory

Propiedad de cadena que especifica el directorio donde se encuentra el archivo JAR del trabajo.

jobJarDirectory: string

Valor de propiedad

string

savePointName

Propiedad de cadena que representa el nombre del punto de retorno para el trabajo de Flink

savePointName?: string

Valor de propiedad

string

upgradeMode

Propiedad de cadena que indica el modo de actualización que se va a realizar en el trabajo de Flink. Puede tener uno de los siguientes valores de enumeración => STATELESS_UPDATE, UPDATE, LAST_STATE_UPDATE.

upgradeMode: string

Valor de propiedad

string