Realtime Compute for Apache Flink:性能ホワイトペーパー: Nexmark ベンチマーク

ステップ 1: テストツールのダウンロード

Nexmark テストツールパッケージ nexmark-flink.tar.gz をダウンロードして展開します。

展開後、ディレクトリ構造は次のとおりです。

nexmark-flink/
├── run_nexmark.sh          # テストエントリスクリプト
├── nexmark_env.sh          # 環境変数構成ファイル (編集が必要)
├── bin/                    # ランタイムスクリプト
├── conf/                   # Flink ジョブ構成
├── lib/                    # JAR パッケージ (コンソールにアップロード)
└── queries-vvp/            # Nexmark クエリ SQL ファイル

ステップ 2: Nexmark JAR のアップロード

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

2. クリックして対象の名前空間に移動し、左側のナビゲーションバーで [ファイル管理] > [リソースのアップロード] を選択します。

3. nexmark-flink-0.2-SNAPSHOT.jar ファイルを選択してアップロードします。このファイルは、テストツールの nexmark-flink/lib ディレクトリにあります。

4. アップロードが完了したら、ファイル名をクリックしてその OSS パスをコピーします。このパスは後のステップでパラメーターとして必要になります。ファイルパスの形式はストレージタイプによって異なります。

   • OSS バケットストレージ: oss://<your-bucket-name>/artifacts/namespaces/<your-namespace>/<your-file-name>

     例: oss://oss-test/artifacts/namespaces/flink-default/nexmark-flink-0.2-SNAPSHOT.jar

   • フルマネージドストレージ: oss://flink-fullymanaged-<your-workspace-id>/artifacts/namespaces/<your-namespace>/<your-file-name>

     例: oss://flink-fullymanaged-e6a123456789/artifacts/namespaces/flink-default/nexmark-flink-0.2-SNAPSHOT.jar

   ワークスペースのストレージタイプを表示するには、Realtime Compute for Apache Flink コンソールに移動し、対象のワークスペースを見つけ、[アクション] 列の [詳細] をクリックします。

ステップ 3: ランタイムパラメーターの構成

nexmark-flink/nexmark_env.sh ファイルを編集し、次のパラメーターを構成します。

ステップ 4: テストの実行

1. nexmark-flink ディレクトリで、次のコマンドを実行します。

   ./run_nexmark.sh

2. テストツールは OpenAPI を使用して Nexmark ジョブを自動的に作成および実行します。

3. テストが完了すると、出力には各クエリの持続時間 (ミリ秒単位) が表示されます。出力例:

   INFO  com.github.nexmark.flink.vvp.Nexmark - q0 13078
   ============================================================================
   ✓ Benchmark execution completed successfully
   ============================================================================