E-MapReduce (EMR) サーバーレス Spark は、spark-submit コマンドライン引数に対応しており、ジョブの送信プロセスを簡素化します。
前提条件
-
ワークスペースが作成済みであること。詳細については、「ワークスペースの管理」をご参照ください。
-
アプリケーションを開発し、JAR パッケージにビルド済みであること。
操作手順
手順1:JAR パッケージの開発
すぐに開始できるように、このガイドではテスト用の JAR パッケージを提供します。
spark-examples_2.12-3.5.2.jar をクリックし、テスト用の JAR パッケージをダウンロードします。
spark-examples_2.12-3.5.2.jar は、円周率 (π) の値を計算する Spark に含まれる簡単な例です。この JAR パッケージを使用してジョブを送信するには、esr-4.x エンジンバージョンを使用する必要があります。esr-5.x エンジンバージョンを使用している場合は、spark-examples_2.13-4.0.1.jar をダウンロードして、このガイドの手順を完了してください。
手順2:JAR パッケージの OSS へのアップロード
spark-examples_2.12-3.5.2.jar を OSS にアップロードします。手順については、「シンプルアップロード」をご参照ください。
手順3:ジョブの開発と実行
-
E-MapReduce (EMR) サーバーレス Spark のページで、左側のナビゲーションペインにある Development をクリックします。
[開発] タブで、
アイコンをクリックします。-
名前を入力し、タイプとして Application > [Spark Submit] を選択し、OK をクリックします。
-
右上隅でキューを選択します。
キューの追加方法の詳細については、「リソースキューの管理」をご参照ください。
-
新しいジョブエディターで、次のパラメーターを設定し、他のパラメーターはデフォルト設定のままにします。その後、実行 をクリックします。
パラメーター
説明
[Script]
Spark Submit スクリプトを入力します。
以下のコードはその例です。
--class org.apache.spark.examples.SparkPi \ --conf spark.executor.memory=2g \ oss://<YourBucket>/spark-examples_2.12-3.5.2.jar -
下部にある Execution Records セクションで、対象のジョブの [操作] 列にある Log Exploration をクリックします。
-
Log Exploration タブで、ジョブログを表示できます。
[ドライバーログ] > [Stdout] タブを選択します。
Pi is roughly 3.1415557077785388のようなジョブ出力が、stdout.log ファイルに表示されます。
手順4:ジョブの公開
公開したジョブは、ワークフローノードのタスクとして使用できます。
-
ジョブが正常に完了したら、右上隅の Publish をクリックします。
-
公開ダイアログボックスで、公開情報を入力し、OK をクリックします。
(オプション) 手順5:Spark UI の表示
ジョブが正常に完了したら、Spark UI でその詳細を表示できます。
-
左側のナビゲーションペインで、Job History をクリックします。
-
[Application] ページで、対象のジョブの [操作] 列にある Spark UI をクリックします。
Spark UI が新しいタブで開き、ジョブの詳細が表示されます。
関連ドキュメント
ジョブを公開した後、ワークフロー内でスケジュールできます。詳細については、「ワークフローの管理」をご参照ください。ジョブの開発とオーケストレーションプロセスの完全な例については、「SparkSQL 開発クイックスタート」をご参照ください。