2016-03-21 33 views
1

たとえば、自分のフローでJARをアップロードし、Apache Flinkダッシュボードで実行します。次に、フローにいくつかの変更を実装し、それらを展開したいと思います。私の流れの新しい変更をApache Flinkクラスタにデプロイするには?

誰でも私のフローの新しいバージョンをApache Flinkクラスタに正しく配置する方法を教えてもらえますか?(ダウンタイム、ルージング状態などなし)私は、公式の文書に展開プロセスの説明が見つかりませんでした。

答えて

1

あなたが使用したいのはFlinkのsavepointsです。

  • があなたの仕事
  • 保存flink savepoint <JobID>
  • ストップ仕事
  • スタート新しいjarファイル使用を使用して、現在実行中のジョブの状態のための新しいjarファイルを準備します。次のように

    手順

    ですちょうど作成されたセーブポイントflink run -s <pathToSavepoint> <jobJar> ...

参照:http://data-artisans.com/how-apache-flink-enables-new-streaming-applications/

関連する問題