メインコンテンツへ移動

Flink 独立サーバーデプロイ（クロスバージョンアップグレード）

1. イメージの取得​

Flink ノードで、アーキテクチャに対応する対象バージョンのアプリケーションイメージを取得してください（オフラインパッケージダウンロード）。

docker pull registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:1.19.720

2. Job 実行記録の削除​

クロスバージョンアップグレードの前に、旧バージョンのジョブ状態を削除する必要があります。以下のコマンドでコンテナに入り、データを整理してください。

1. コンテナに入る

docker exec -it $(docker ps | grep mingdaoyun-flink | awk '{print $1}') bash

2. データのバックアップと削除

# 旧バージョンの Job 一覧データをバックアップして消去
mv /data/flink/zookeeper /data/flink/zookeeper.backup-$(date +%Y%m%d%H%M%S)

3. 設定の変更​

flink.yaml 設定ファイルを編集し、flink サービスのイメージタグを対象バージョンに変更します。

# 設定例（抜粋）
flink:
  image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:1.19.720

以下のスクリプトを実行し、サービスを再デプロイします。

1. 現在のサービスを停止

docker stack rm flink

2. 新バージョンのサービスを起動

docker ps で Flink 関連コンテナが表示されなくなってから、デプロイを実行します。

docker stack deploy -c flink.yaml flink

5. タスクの再公開​

アップグレード完了後、同期タスク一覧で対象タスクを手動で再度有効化／公開してください。これにより同期タスクが正常に動作するようになります。