メインコンテンツへ移動

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. 設定の変更​

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

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

4. サービスの再起動​

マネージャのルートディレクトリで以下のスクリプトを実行し、サービスを再起動します。

bash ./service.sh restartall
service.sh の場所が不明な場合は、クリックして検索コマンドを表示
find / -path /proc -prune -o -name "service.sh" -print

5. タスクの再公開​

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