ワークスペースの名前空間とデプロイ管理の FAQ - Flink

このトピックでは、Realtime Compute for Apache Flink のワークスペース、プロジェクト、ジョブの管理および使用に関するよくある質問（FAQ）に回答します。これらの質問は、リソーススケーリング、ワークスペース ID の確認、ジョブエンジンバージョンの確認、ジョブパラメーターの設定などのトピックをカバーしています。

ワークスペースおよび名前空間の管理
ジョブ管理

ワークスペースの名前を変更できますか？

Realtime Compute for Apache Flink コンソールで、対象のワークスペースの [操作] 列にある [詳細] をクリックします。
ワークスペース名をクリックして変更します。

VPC および vSwitch を変更できますか？

VPC は変更できませんが、vSwitch は変更できます。

ワークスペース ID などの情報を確認する方法

Realtime Compute for Apache Flink コンソールで、対象のワークスペースの [操作] 列にある [詳細] をクリックすると、ワークスペース ID などの情報を確認できます。

プロジェクトのスケールイン中にリソース割り当てが失敗する

問題の説明
プロジェクトのスケールイン中に「リソース割り当てに失敗しました」というメッセージが表示されます。
原因
すべてのリソースが割り当てられているか、使用中です。
解決方法
まず、リソースキューに割り当てられたリソース量を減らしてください。詳細については、「リソース量の変更」をご参照ください。その後、プロジェクトをスケールインできます。

Flink 計算リソースのスペックアップが反映されない

サブスクリプション
Flink リソースは上位から下位へ向かってスケーリングする必要があります。リソースはワークスペースからプロジェクト、そしてプロジェクトからリソースキューへと割り当てられます。詳細については、「リソース調整」をご参照ください。
従量課金
従量課金は後払い方式の課金方法です。システムはご利用のワークスペースの実際のリソース使用量に基づいて請求を行うため、リソーススケーリングは不要です。対象のワークスペースの [操作] 列で [その他] > [クォータ制限] をクリックすると、バッチジョブシナリオにおけるリソース隔離および管理のニーズを満たすために、プロジェクトのリソースキューを設定できます。詳細については、「リソースキューの管理」をご参照ください。

AccessKey ID および AccessKey Secret の確認方法

AccessKey ID
- Alibaba Cloud アカウントの場合：Alibaba Cloud 管理コンソールにログインし、右上隅のプロフィール画像にポインターを合わせて、[AccessKey 管理] をクリックします。
- RAM ユーザーの場合：詳細については、「RAM ユーザーの AccessKey 情報の確認」をご参照ください。
AccessKey Secret
セキュリティリスクを回避するため、Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey Secret は作成時のみ表示され、後から取得することはできません。AccessKey Secret は安全な場所に保管してください。

AccessKey 情報をお持ちでない場合や忘れた場合は、「AccessKey の作成」をご参照ください。

Flink ジョブで使用するファイルを OSS にアップロードする方法

Flink ワークスペース作成時にストレージクラスとして OSS バケットを選択した場合、ワークスペースにアタッチされた OSS バケットにファイルをアップロードして Flink ジョブで使用できます。Realtime Compute for Apache Flink 開発コンソールの [ファイル管理] ページからも Flink ジョブ用のファイルをアップロードできます。詳細については、「ファイルの管理」をご参照ください。

Realtime Compute for Apache Flink コンソールで、対象のワークスペースを見つけ、[操作] 列の [その他] > [ワークスペースの詳細] を選択して、ワークスペースにアタッチされた OSS バケットの情報を確認します。
リソースファイルを対象の OSS バケットにアップロードします。
- OSS コンソールにログインし、対象のバケット内の /artifacts/namespaces ディレクトリにリソースファイルをアップロードします。
- API オペレーションを呼び出してリソースファイルをアップロードすることもできます。詳細については、「PutObject」をご参照ください。
Realtime Compute for Apache Flink 開発コンソールのナビゲーションウィンドウで、[ファイル管理] をクリックすると、OSS コンソールにアップロードしたリソースファイルを確認できます。

有効化済みの Flink ワークスペースが Realtime Compute for Apache Flink コンソールに表示されない場合の対処方法

以下の項目を確認してトラブルシューティングを行ってください。問題が解決しない場合は、チケットを送信してください。

Flink ワークスペースが初期化されていることを確認してください。このプロセスには通常 5～10 分かかります。
Realtime Compute for Apache Flink コンソールページの上部で正しいリージョンが選択されていることを確認してください。ワークスペースは、作成時に選択したリージョンでのみ表示されます。
RAM ユーザーとしてログインしている場合は、ユーザーが Realtime Compute for Apache Flink コンソールに必要な権限を持っていることを確認してください。権限の設定方法の詳細については、「権限管理」をご参照ください。

エラー: IP アドレスが不足しています: Kubernetes から異常イベントが検出されました

エラーの詳細

Has not enough ip address:abnormal event detected from kubernetes (type:[Warning], reason:[CniError_CodeUnKnownErr], message:[CniAllocateError: allocateIP failed: ipamCreate failed: failed to create ENI: all vSwitches ([*****]) cannot be used: CreateNetworkInterface: RequestId: 67959AE5-EA20-5CB4-8560-5BD6752472FD, ErrorCode: InvalidVSwitchId.IpNotEnough, Message: The specified VSwitch "*****" has not enough IpAddress., elapsedTime: 245.03232ms])

原因
vSwitch に利用可能な IP アドレスがありません。
解決方法
利用可能な IP アドレスを追加してください。詳細については、「vSwitch の変更」をご参照ください。

エラー： Unknown Error: Http failure response for xxxxx

エラーの詳細
ファイルのアップロードが失敗し、次のエラーメッセージが表示されます。
原因
Alibaba Cloud 国際サイトのドメイン名が更新された後、クロスドメイン制限により、新しい alibabacloud.com ドメインへのファイルアップロードリクエストが失敗します。これは、Object Storage Service (OSS) にクロスドメインルール（CORS）が設定されていない場合に発生します。
解決方法
OSS コンソールで、Flink ワークスペースにアタッチされた OSS バケットに対して CORS ルールを設定します。ルールの設定方法の詳細については、「ファイルの管理」をご参照ください。

現在のジョブの Flink バージョンを確認する方法

次の方法でバージョンを確認できます。

[ETL] または [データ取り込み] ページの右側で、[その他の設定] をクリックし、[エンジンバージョン] フィールドでバージョン情報を確認します。
[オペレーションセンター] > [ジョブ運用管理] ページで、対象のジョブ名をクリックし、[デプロイメントの詳細] タブの [基本設定] エリアでバージョン情報を確認します。

Realtime Compute for Apache Flink ジョブのエンジンバージョンを変更する方法

SQL または YAML ジョブ
[ETL] または [データ取り込み] ページの右側で、[その他の設定] をクリックし、[エンジンバージョン] フィールドから目的のバージョンを選択します。デプロイ済みのジョブの場合、バージョン変更を反映させるには、ジョブを再デプロイして起動する必要があります。
JAR または Python ジョブ
[ジョブ運用管理] ページで、対象のジョブ名をクリックします。[デプロイメントの詳細] タブで、[基本設定] セクションの右上隅にある [編集] をクリックします。[エンジンバージョン] フィールドで目的のバージョンを選択し、[保存] をクリックしてから、[開始] をクリックします。

ジョブのカスタム実行パラメーターを設定する方法

Realtime Compute for Apache Flink コンソールにログインします。
管理対象のワークスペースを見つけ、[操作] 列の [コンソール] をクリックします。
[ジョブ運用管理] ページで、対象のジョブ名をクリックします。
[デプロイメントの詳細] タブで、[実行パラメーター設定] セクションの右側にある [編集] をクリックします。
[その他の設定] フィールドでパラメーターを設定します。
キーと値の間のコロン（:）の後に半角スペースを入れてください。次のコードはその例です。
```
task.cancellation.timeout: 180s
```
[保存] をクリックします。

共通の Flink 構成を永続化して効率を向上させる方法

Realtime Compute for Apache Flink には [ジョブテンプレート] 機能があります。共通パラメーターをテンプレートとして保存することで、新しいジョブごとに手動で設定する必要がなくなります。

AccessKey やパスワードなどの機密情報が漏洩しないようにする方法

AccessKey Secret やパスワードなどの機密情報をプレーンテキストで公開することによるセキュリティリスクを回避するために、変数を使用できます。変数を使用することで、同じコードや値を繰り返し記述する必要がなくなり、構成管理も簡素化されます。変数は SQL ジョブ、JAR または Python ジョブ、ログ設定、UI 設定などさまざまなシナリオで使用できます。詳細については、「変数の管理」をご参照ください。

Flink ジョブが計算リソースをより効率的に使用する方法

次の方法で調整できます。

手動調整： [スマート診断] タブで [診断を開始] をクリックし、リソース分析結果を確認して、表示される指示に従って手動で調整します。
自動調整： 自動チューニング機能（インテリジェントチューニングおよびスケジュールチューニングモードを含む）を有効にすることで、Flink システムが自動的にリソースを調整します。シナリオおよび設定手順の詳細については、「自動チューニングの設定」をご参照ください。

cron 式の記述ルール

ジョブ状態セット管理では UNIX スタイルのルールが使用され、タスクオーケストレーションでは Java スタイルのルールが使用されます。シナリオに応じて正しい cron 式を使用してください。

UNIX スタイルのルール

フィールド定義： 分時日月曜日。5 つのフィールドがあります。
「日」と「曜日」の和集合： 第 3 フィールド（日）と第 5 フィールド（曜日）の両方を定義した場合、それらは OR の関係になります。
0 12 1 * 5 は、毎月 1 日の 12:00 または 毎週金曜日にジョブが実行されることを意味します。毎月 1 日が金曜日である場合にのみ実行されるという意味ではありません。
疑問符（?）はサポートされていません： ? 文字は使用しないでください。使用すると、システムがエラーを報告するか、式を認識できなくなります。フィールドを無視するには、代わりにアスタリスク（*）を使用してください。

Java スタイルのルール（Quartz）

フィールド定義： 秒分時日月曜日。一般的に 6 つのフィールドがあります。
「日」と「曜日」の競合：
- 「日」と「曜日」のフィールドは、両方とも特定の値に設定することも、両方ともアスタリスク（*）に設定することもできません。
- 論理的な競合を回避するため、2 つのフィールドのいずれかに疑問符（?）を使用する必要があります。たとえば、「1 日」と「金曜日」の両方を指定すると、その月の 1 日が金曜日でない場合に競合が発生します。
- ルール：「日」に値を指定する場合は、「曜日」を ? に設定します。「曜日」に値を指定する場合は、「日」を ? に設定します。
曜日の数値表現：1 は日曜日、2 は月曜日を表します。曖昧さを避けるため、SUN、MON、TUE などの英語の略称を使用することを推奨します。