FlinkJobProfile interface

アプリケーション展開モードでの flink クラスターのジョブ仕様。 RunJob API を呼び出してジョブのプロパティが変更された場合でも、この仕様は変更できません。最新のジョブ情報を取得するには、ListJob API を使用してください。

プロパティ

args	Flink ジョブの追加の JVM 引数を表す文字列プロパティ。スペース区切りの値にする必要があります。
entryClass	Flink ジョブのエントリクラスを指定する文字列プロパティ。指定しない場合、エントリポイントは flink ジョブ jar パッケージから自動検出されます。
jarName	ジョブ JAR の名前を表す文字列プロパティ。
jobJarDirectory	ジョブ JAR が配置されているディレクトリを指定する文字列プロパティ。
savePointName	Flink ジョブのセーブポイントの名前を表す文字列プロパティ
upgradeMode	Flink ジョブで実行されるアップグレードモードを示す文字列プロパティ。列挙値 => STATELESS_UPDATE、UPDATE、LAST_STATE_UPDATEのいずれかを指定できます。

Flink ジョブの追加の JVM 引数を表す文字列プロパティ。スペース区切りの値にする必要があります。

args?: string

string

Flink ジョブのエントリクラスを指定する文字列プロパティ。指定しない場合、エントリポイントは flink ジョブ jar パッケージから自動検出されます。

entryClass?: string

string

ジョブ JAR の名前を表す文字列プロパティ。

jarName: string

string

ジョブ JAR が配置されているディレクトリを指定する文字列プロパティ。

jobJarDirectory: string

string

Flink ジョブのセーブポイントの名前を表す文字列プロパティ

savePointName?: string

string

Flink ジョブで実行されるアップグレードモードを示す文字列プロパティ。列挙値 => STATELESS_UPDATE、UPDATE、LAST_STATE_UPDATEのいずれかを指定できます。

upgradeMode: string

string