Dela via


FlinkJobProfile interface

Jobbspecifikationer för flink-kluster i programdistributionsläge. Specifikationen är oföränderlig även om jobbegenskaperna ändras genom att anropa RunJob-API:et använder du ListJob-API:et för att hämta den senaste jobbinformationen.

Egenskaper

args

En strängegenskap som representerar ytterligare JVM-argument för Flink-jobbet. Det ska vara blankstegsavgränsat värde.

entryClass

En strängegenskap som anger postklassen för Flink-jobbet. Om inget anges identifieras startpunkten automatiskt från jar-paketet för flink-jobbet.

jarName

En strängegenskap som representerar namnet på jobbets JAR-fil.

jobJarDirectory

En strängegenskap som anger katalogen där jobbets JAR-fil finns.

savePointName

En strängegenskap som representerar namnet på sparandepunkten för Flink-jobbet

upgradeMode

En strängegenskap som anger uppgraderingsläget som ska utföras på Flink-jobbet. Den kan ha något av följande uppräkningsvärden => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE.

Egenskapsinformation

args

En strängegenskap som representerar ytterligare JVM-argument för Flink-jobbet. Det ska vara blankstegsavgränsat värde.

args?: string

Egenskapsvärde

string

entryClass

En strängegenskap som anger postklassen för Flink-jobbet. Om inget anges identifieras startpunkten automatiskt från jar-paketet för flink-jobbet.

entryClass?: string

Egenskapsvärde

string

jarName

En strängegenskap som representerar namnet på jobbets JAR-fil.

jarName: string

Egenskapsvärde

string

jobJarDirectory

En strängegenskap som anger katalogen där jobbets JAR-fil finns.

jobJarDirectory: string

Egenskapsvärde

string

savePointName

En strängegenskap som representerar namnet på sparandepunkten för Flink-jobbet

savePointName?: string

Egenskapsvärde

string

upgradeMode

En strängegenskap som anger uppgraderingsläget som ska utföras på Flink-jobbet. Den kan ha något av följande uppräkningsvärden => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE.

upgradeMode: string

Egenskapsvärde

string