このチュートリアルでは、Google Kubernetes Engine(GKE)で強化学習(RL)の分散トレーニング環境をオーケストレートする方法について説明します。Ray と NVIDIA NeMo RL フレームワークを使用して、モデルをファインチューニングするための分散トレーニング環境を設定します。
このチュートリアルでは、Ray と NeMo RL を使用した GKE のグループ相対ポリシー最適化(GRPO)トレーニング パイプラインについて説明します。GRPO は、モデルの推論能力を向上させるように設計された強化学習アルゴリズムです。このメモリ効率の高いアルゴリズムは、Critic(値モデル)を排除し、相対グループベースの計算を使用することで、RL プロセスを簡素化します。
このチュートリアルを実行する前に、GKE で verl を使用して強化学習をファインチューニングしてスケーリングするチュートリアルを完了してください。このチュートリアルでは、ファインチューニングとスケーリング RL with verl チュートリアルと同じクラスタ設定と構成を使用します。
背景
以降のセクションでは、このチュートリアルで使用するコンセプトの概要を説明します。
強化学習(RL)
RL は、静的な模倣ではなく、経験、探索、フィードバックを通じてモデルを学習させます。事前トレーニングではモデルに何を言うかを教えますが、人間からのフィードバックを用いた強化学習(RLHF)では、有用性、安全性、論理性を教えます。RL は、ベースモデルと特殊なユースケースのファインチューニング済みモデルの橋渡し役として機能します。
詳細については、強化学習とはをご覧ください。
グループ相対ポリシーの最適化(GRPO)
DeepSeek によって普及したアルゴリズムである GRPO は、Critic モデルを削除することで、LLM アライメント用の Proximal Policy Optimization(PPO)に代わるメモリ効率の高い方法を提供します。Critic ネットワークの代わりに、GRPO は同じプロンプトに対する一連のレスポンスを生成し、そのグループの平均報酬をベースラインとして使用します。
詳細については、GRPO をご覧ください。
NVIDIA NeMo RL
NeMo RL は、スケーラブルな RL 用に設計された NVIDIA のオープンソースの事後トレーニング ライブラリです。NeMo RL は、より広範な NeMo フレームワーク エコシステムの一部であり、単一の GPU での小規模な実験と、数千の GPU にわたるマルチノード デプロイの両方を実現します。
詳細については、NVIDIA NeMo RL をご覧ください。
GSM8k データセット
このチュートリアルでは、8,500 個の高品質で言語的に多様な小学校の数学の文章問題を含む GSM8k データセットを使用します。
GSM8k と GRPO を使用することで、モデルは同じ問題に対して n 個の異なる回答を生成します。GRPO は、これらの回答をグループの平均と比較します。このモデルでは、グループの他のパスと比較して、一貫して正しく論理的に妥当なパスに対してより多くの報酬が与えられます。モデルは、手順を明確に説明することが報酬を最大化する最も信頼性の高い方法であることを学習し、パフォーマンスの低い回答に対する報酬を効果的に減らします。
詳細については、GSM8k をご覧ください。
目標
このチュートリアルでは、次の手順に沿って NeMo RL を使用して GKE で RL を設定する方法について説明します。
- 環境を準備します。
- B200 または H200 GPU を使用して GKE クラスタを設定します。
- 分散 Ray クラスタを管理するように KubeRay を構成します。
- 高性能ストレージには Managed Lustre を使用します。
- NeMo RL を使用する GRPO トレーニング ジョブを実行します。
始める前に
-
Google Cloud CLI をインストールします。
-
フェデレーション ID(連携 ID)を使用するように gcloud CLI を構成します。
詳細については、連携 ID を使用して gcloud CLI にログインするをご覧ください。
-
gcloud CLI を初期化するには、次のコマンドを実行します。
gcloud init -
Google Cloud プロジェクトを作成または選択します。
プロジェクトの選択または作成に必要なロール
- プロジェクトを選択する: プロジェクトの選択に特定の IAM ロールは必要ありません。ロールが付与されているプロジェクトであれば、どのプロジェクトでも選択できます。
-
プロジェクトを作成する: プロジェクトを作成するには、
resourcemanager.projects.create権限を含むプロジェクト作成者ロール(roles/resourcemanager.projectCreator)が必要です。詳しくは、ロールを付与する方法をご覧ください。
-
Google Cloud プロジェクトを作成します。
gcloud projects create PROJECT_ID
PROJECT_IDは、作成する Google Cloud プロジェクトの名前に置き換えます。 -
作成した Google Cloud プロジェクトを選択します。
gcloud config set project PROJECT_ID
PROJECT_IDは、 Google Cloud プロジェクトの名前に置き換えます。
必要な API を有効にします。
API を有効にするために必要なロール
API を有効にするには、
serviceusage.services.enable権限が必要です。プロジェクトを作成した場合は、オーナーロール(roles/owner)を介してこの権限がすでに付与されている可能性があります。それ以外の場合は、Service Usage 管理者ロール(roles/serviceusage.serviceUsageAdmin)を介してこの権限を取得できます。ロールを付与する方法をご覧ください。gcloud services enable container.googleapis.com
storage.googleapis.com compute.googleapis.com -
ユーザー アカウントにロールを付与します。次の IAM ロールごとに次のコマンドを 1 回実行します。
roles/container.admin, roles/iam.serviceAccountAdmin, roles/storage.admingcloud projects add-iam-policy-binding PROJECT_ID --member="user:USER_IDENTIFIER" --role=ROLE
次のように置き換えます。
PROJECT_ID: プロジェクト ID。USER_IDENTIFIER: ユーザー アカウント。例については、 IAM ポリシーで Workforce プール ユーザーを表すをご覧ください。ROLE: ユーザー アカウントに付与する IAM ロール。
- Hugging Face アカウントを作成します(まだ作成していない場合)。
read accessを含む Hugging Face トークンがあることを確認します。- Weights & Biases(Wandb)アカウントを作成します(まだアカウントを保有していない場合)。
- Wandb API キーを作成します。
- Google Cloud プロジェクトに B200 GPU と H200 GPU に十分な割り当てがあることを確認します。詳細については、GPU 割り当てを計画すると GPU 割り当てをご覧ください。
環境を準備する
このチュートリアルでは、Cloud Shell を使用します。
Google Cloud コンソールに移動します。
Google Cloud コンソール ウィンドウの上部にある [Cloud Shell をアクティブにする] ボタンをクリックします。
次の環境変数を設定します。
次の値を置き換えます。
YOUR_REGION: GKE クラスタ コントロール プレーンの Compute Engine リージョン。YOUR_NODE_ZONE: ノードのゾーン。NVIDIA B200 または H200 GPU を使用できるゾーンを選択します。YOUR_CLUSTER_NAME: GKE クラスタの名前。YOUR_GPU_TYPE: Compute Engine の容量予約で予約したアクセラレータ。次のいずれかの値を指定する必要があります。nvidia-b200: NVIDIA B200(180 GB)nvidia-h200-141gb: NVIDIA H200(141 GB)
YOUR_MACHINE_TYPE: 使用するマシンのタイプ:- NVIDIA B200(180 GB)GPU の場合は、
a4-highgpu-8g以降を使用します。 - NVIDIA H200(141 GB)GPU の場合は、
a3-ultragpu-8g以降を使用します。
- NVIDIA B200(180 GB)GPU の場合は、
YOUR_RESERVATION_NAME: GPU 予約の名前。CHOSEN_LUSTRE_NAME: Lustre インスタンスの名前。YOUR_HF_TOKEN: Hugging Face トークン。YOUR_WANDB_API_KEY: Wandb API キー。
ネットワークに対して、次の環境変数を作成します。
次の値を置き換えます。
NETWORK_NAME: GKE のネットワーク名。GVNIC_NAME: gVNIC ネットワーク名の接頭辞。任意の接頭辞を使用できます。RDMA_NAME: リモート ダイレクト メモリ アクセス(RDMA)ネットワークの接頭辞。任意の接頭辞を使用できます。
インフラストラクチャを設定する
このセクションでは、VPC ネットワークと GKE クラスタを作成します。
VPC ネットワークの作成
gVNIC インターフェース用の VPC ネットワークを作成します。
8 個の GPU 用に 8 個のサブネットを含む RDMA 用の VPC ネットワークとサブネットを作成します。
GKE クラスタを作成する
GKE Standard クラスタで NeMo RL を設定できます。
Standard クラスタを作成します。
クラスタの認証情報を取得します。
GPU ノードプールを作成します。
NCCL RDMA インストーラをインストールします。
ネットワーク マッピングを構成する
次のマニフェストを
network-mapping.yamlとして保存します。次のようにマニフェストを適用します。
ストレージを準備する
このセクションでは、RL ワークロードに必要な高性能ストレージをプロビジョニングする Managed Lustre インスタンスを作成します。
プライベート サービス アクセス用の IP アドレス範囲を割り振ります。
ピアリングを接続します。
Managed Lustre インスタンスを作成します。
Managed Lustre CSI ドライバを使用して既存の Managed Lustre インスタンスにアクセスします。
Managed Lustre インスタンスの IP アドレスを抽出します。
lustre-pv.yamlマニフェストを調べます。次のようにマニフェストを適用します。
lustre-pvc.yamlマニフェストを調べます。次のようにマニフェストを適用します。
RayCluster をデプロイする
このセクションでは、サンプル リポジトリのクローンを作成し、マニフェストを準備して、Ray クラスタをデプロイします。
サンプル リポジトリのクローンを作成します。
作業ディレクトリに移動します。
マニフェスト
values.yamlを調べます。このチュートリアルで使用するアクセラレータに基づいて、
NCCL_TUNER_CONFIG_PATHを次のいずれかの値に置き換えます。- NVIDIA B200(180 GB):
/usr/local/gib/configs/tuner_config_a4.txtpb - NVIDIA H200(141 GB):
/usr/local/gib/configs/tuner_config_a3u.txtpb
このマニフェストでは、ヘッドノードがジョブを管理し、Ray ダッシュボードをホストします。ワーカーノードはトレーニング ジョブを実行します。
- NVIDIA B200(180 GB):
Ray クラスタをデプロイします。
このチュートリアルでは、2 つのワーカーノードを使用します。ワーカーノードの数を変更する場合は、
REPLICA_COUNTの値を変更します。ワーカーノードとヘッドノードが実行されていることを確認します。
出力は次のようになります。
NAME READY STATUS RESTARTS AGE ray-cluster-kuberay-head-sw7dp 2/2 Running 0 33h ray-cluster-kuberay-worker-grp-0-worker-gkbxw 2/2 Running 0 33h ray-cluster-kuberay-worker-grp-0-worker-kdg62 2/2 Running 0 33hRay クラスタが実行中であることを確認します。
出力は次のようになります。
NAME NAMESPACE DESIRED WORKERS AVAILABLE WORKERS CPUS GPUS TPUS MEMORY CONDITION STATUS AGE ray-cluster-kuberay default 2 2 618 17 0 1573741824k RayClusterProvisioned ready 33h
GRPO ジョブを起動する
Ray クラスタの準備ができたら、GKE で実行中の Ray クラスタに Ray ジョブを送信できます。NeMo RL は、RL トレーニング ジョブの実行中にモデルを自動的にダウンロードします。
Ray ジョブを送信するには、インタラクティブ セッションを開始してジョブを実行します。
Ray クラスタへのローカル接続を確立するには、次のコマンドを実行します。
このコマンドにより、ローカルマシンと GKE クラスタ内の Ray ヘッドノード間のポート転送が開始されます。このセッションがアクティブになっている間は、ターミナルが占有されます。続行するには、別のターミナル インスタンスを開きます。
別のターミナルで、
kubernetes-engine-samples/ai-ml/nemo-rl-on-gke/nemoRL/gemma3-27b-itに移動してgemma3-27b-gsm8k.shファイルを編集します。gemma3-27b-gsm8k.shファイルで次の値を置き換えます。YOUR_WANDB_API_KEY: WandB API キー。YOUR_HF_TOKEN: Hugging Face トークン。
このファイルには、GSM8k データセットで gemma3-27b-it モデルを使用してジョブを実行する構成が記述されています。GRPO トレーニング パイプラインを完了するために、このスクリプトは次のパラメータを定義します。
num_prompts_per_step: 16とnum_generations_per_prompt: 32: Gemma3-27b-it モデルは、プロンプトごとに大量のレスポンスを生成します。この構成では、モデルは合計 512 個のレスポンスを生成します(16 × 32 = 512)。policy.generation.colocated.enabled=False: このパラメータは、コロケーション生成機能を無効にします。つまり、モデルはトレーニング プロセスと同じノードでレスポンスを生成しません。標準の RL では、同じ GPU がトレーニングと生成の両方を処理します。この NeMo RL の設定では、特定のノード(policy.generation.colocated.resourcesパラメータで管理)を vLLM 推論専用にし、クラスタの残りの部分を大規模なトレーニングの計算に集中させます。これらのワークロードを分離することで、メモリ負荷の高いトレーニング バッファとコンピューティング負荷の高い推論ワークロード間のリソースの競合を防ぐことができます。
Job を送信するには、次のコマンドを実行します。
ジョブの実行中、出力にはトレーニング結果、タイミング、パフォーマンス指標が表示されます。
GRPO ジョブの健全性をモニタリングする
Ray がジョブを完了すると、NeMo RL は構成されたパスにチェックポイントを保存します。
GRPO ジョブの出力を確認するには、
ray-headコンテナへの SSH セッションを作成します。ray-headコンテナのターミナル内で apt tree ユーティリティをインストールします。ray-headコンテナのディレクトリ構造を一覧表示します。出力は次のようになります。
root@ray-cluster-kuberay-worker-grp-0-worker-gkbxw:/opt/nemo-rl# tree /data/nemo_rl_gemma3_27b_3_17/ /data/nemo_rl_gemma3_27b_3_17/ `-- step_10 |-- config.yaml |-- policy | |-- optimizer | | |-- __0_0.distcp | | |-- __10_0.distcp | | |-- __11_0.distcp | | |-- __12_0.distcp | | |-- __13_0.distcp | | |-- __14_0.distcp | | |-- __15_0.distcp | | |-- __1_0.distcp | | |-- __2_0.distcp | | |-- __3_0.distcp | | |-- __4_0.distcp | | |-- __5_0.distcp | | |-- __6_0.distcp | | |-- __7_0.distcp | | |-- __8_0.distcp | | `-- __9_0.distcp | |-- tokenizer | | |-- chat_template.jinja | | |-- special_tokens_map.json | | |-- tokenizer.json | | `-- tokenizer_config.json | `-- weights | |-- __0_0.distcp | |-- __10_0.distcp | |-- __11_0.distcp | |-- __12_0.distcp | |-- __13_0.distcp | |-- __14_0.distcp | |-- __15_0.distcp | |-- __1_0.distcp | |-- __2_0.distcp | |-- __3_0.distcp | |-- __4_0.distcp | |-- __5_0.distcp | |-- __6_0.distcp | |-- __7_0.distcp | |-- __8_0.distcp | `-- __9_0.distcp |-- train_dataloader.pt `-- training_info.json 6 directories, 39 files
クリーンアップ
このチュートリアルで使用したリソースについて、 Google Cloud アカウントに課金されないようにするには、個々のリソースを削除するか、リソースを含むプロジェクトを削除します。
リソースの削除
Slurm クラスタを削除します。
GKE クラスタを削除します。
Lustre ファイル システムを削除します。
VPC ピアリングを削除します。
Lustre プライベート IP アドレス範囲を削除します。
RDMA サブネットと gVNIC サブネットを削除します。
ファイアウォール ルールとネットワークを削除します。
プロジェクトの削除
Google Cloud プロジェクトを削除する:
gcloud projects delete PROJECT_ID