Realtime Compute for Apache Flink:Namespace clone

ユースケース

制限事項

• リージョン制限：クローンは同一リージョン内の名前空間でのみサポートされます。リージョン間の操作はサポートされていません。

• クローン範囲：名前空間のみクローン可能で、ワークスペース全体はクローンできません。

• 除外されるコンテンツ：タスクオーケストレーション、キュー、権限、およびアラート設定はクローンされません。

• バージョンポリシー：開発環境の最新のドラフトと、運用環境のデプロイメントのみがクローンされます。ドラフトの過去のバージョンは無視されます。

• 同時操作：1 つのソース名前空間を複数のターゲットに、または複数のソース名前空間を 1 つのターゲットに同時にクローンすることはできません。

• ストレージの互換性：ソースワークスペースがフルマネージドストレージを使用している場合、ターゲットワークスペースも同様である必要があります。OSS を使用するワークスペースをターゲットとして選択することはできません。

• アーキテクチャの互換性：クローンは、同じアーキテクチャを持つ名前空間間でのみサポートされます。x86 と ARM の間でのクロスアーキテクチャのクローンはサポートされていません。

• ステートフルクローン：ステート (チェックポイントまたはセーブポイント) を伴うクローンは、エンジンバージョン VVR 6.0.2 以降でのみサポートされます。

注意事項

権限
クローンを開始するには、ソースとターゲットの両方の名前空間に対する編集者ロールが必要です。システムは、このユーザーの ID を使用してエンドツーエンドの認証を行います。詳細については、「開発コンソールでのユーザーへの権限付与」をご参照ください。

クローンの制限

• リソースロック：クローンプロセス中にリソース構成を変更することはできません。

• 不可逆な操作：クローン操作は元に戻すことができません。プロセスを停止した場合、すでにクローンされたリソースは手動で削除する必要があります。

• 重複の回避：同じターゲット名前空間に複数回クローンすると、リソースが重複します。

• ストレージ権限：OSS ストレージからフルマネージドストレージにクローンするには、名前空間に関連付けられたバケットに対する読み取り専用権限 (ListObject アクションを含む) をフルマネージドアカウント arn:sts::1060219998962774:assumed-role/aliyunstreamasidefaultrole/refresh_token に付与する必要があります。詳細については、「バケットポリシーの設定」をご参照ください。

クローンされたジョブのステータス

ステートありでクローンすることを選択した場合：

• 完了または停止したストリーミングジョブの場合、システムは最新のスナップショットまたはシステムチェックポイントをクローンします。

• 実行中または移行中のストリーミングジョブの場合、[スキップしない] ポリシーを選択すると、システムはクローン前に自動的にスナップショットを作成します。ただし、ジョブは実行を続けるため、より新しいシステムチェックポイントが生成される可能性があり、クローンされたスナップショットが最新の状態であるとは限りません。

ストリーミングジョブのステータスの確認

• 移行シナリオでは、新たに生成されたステートによるデータの不整合を防ぐため、クローン前にソースジョブを停止してください。

• ソースジョブとそのクローンされたコピーを同時に実行すると、ビジネスロジックが中断される可能性があります。クローンされたジョブを開始する前に、影響がないことを確認してください。

• システムチェックポイントが成功すると、クローンされたジョブが正しく機能していることを示します。そのステータスを注意深くモニターしてください。

命名競合の処理
ターゲット名前空間にクローンされたエンティティと同じ名前のエンティティがある場合、システムは自動的に名前を変更します。名前が変更された項目のリストは、クローン履歴の [詳細] ページで確認できます。

手動での設定更新
ジョブで設定または参照されているカタログ名は自動的に更新されません。ジョブの失敗を防ぐために、ジョブのコードと構成で手動で変更する必要があります。

ジョブのデバッグ
クローンが完了すると、クローンされたすべてのジョブとセッションクラスターは停止状態になります。クローンされたジョブは、依存関係の設定が欠落している場合など、調整なしでは正しく実行されないことがあります。以下の操作を実行できます：

1. ジョブのドラフトをデバッグします。

2. 依存関係ファイルが期待どおりであるか確認します。

3. ジョブの依存関係の設定を調整します。

操作手順

1. ソース名前空間、ターゲットワークスペース、およびターゲット名前空間を準備します。詳細については、「Realtime Compute for Apache Flink の有効化」または「名前空間の管理」をご参照ください。

2. 名前空間のエンティティと構成情報をクローンします。

   1. Realtime Compute for Apache Flink コンソールにログインします。

   2. ソース名前空間を含む ワークスペースの [その他] 列で、[スペースクローニング] > [クローニングを開始] を選択します。

   3. クローン設定を構成します。

      1. ソースとターゲットの名前空間を選択します。

      2. クローンするオブジェクトを選択します。

         必要に応じて、ドラフト、デプロイメント、ファイルリソース、カスタムカタログ、UDF、コネクタ、データ形式、変数設定など、クローンするオブジェクトを選択できます。

         デプロイメントをクローンする場合、現在の名前空間内のすべてのジョブがデフォルトで選択されます。リストをフィルターして特定のジョブを選択できます。フィルターは、ジョブ名、ジョブタイプ、エンジンバージョン、実行ステータス、および最後のクローン完了時間でサポートされています。

      3. クローンポリシーを構成します。

         設定	オプション	説明
         ストリーミングジョブの状態クローンポリシー	ステートあり	最新のスナップショットまたはシステムチェックポイントをクローンして、すでに処理されたデータの再処理を防ぎます。
         	ステートレス	ジョブの構成とコードのみをクローンし、スナップショットやシステムチェックポイントは含みません。
         実行中のストリーミングジョブのクローンポリシー	スキップ	ソースジョブによって生成される新しいステートによるデータ干渉を防ぐため、実行中のストリーミングジョブをスキップします。移行に推奨されます。
         	スキップしない	クローン前に実行中のストリーミングジョブのスナップショットを作成し、最新の状態がキャプチャされるようにします。バックアップに推奨されます。
         エラー処理ポリシー	スキップして続行	エンティティのクローンに失敗した場合、失敗がログに記録され、プロセスは残りのエンティティで続行されます。
         	クローンを停止	いずれかのエンティティのクローンに失敗した場合、クローンタスク全体が直ちに停止されます。正常にクローンされたデータは保持されます。
         	ステートレスクローンを許可	ステートありのクローンに失敗した場合、プロセスは自動的にステートレスクローンにフォールバックして続行します。

   4. [クローンを開始] をクリックします。

3. クローンの進捗と結果を表示します。

   • クローン中

     [クローンを開始] をクリックすると、すぐに通知が表示されます。[クローンの進捗を表示] をクリックしてタスクをモニターします。このタスクはバックグラウンドで実行できます。

     

   • クローン完了後

     ターゲットワークスペースの [その他] 列で、[スペースクローン] > [クローンの履歴] を選択し、[詳細] をクリックします。クローンされたエンティティのカテゴリ、総数、失敗数を表示できます。名前が変更されたエンティティのリストも表示されます。

関連ドキュメント