性能白皮书（Nexmark性能测试）

步骤一：下载测试工具

下载 Nexmark 测试工具压缩包nexmark-flink.tar.gz并解压。

解压后的目录结构如下：

nexmark-flink/
├── run_nexmark.sh          # 测试入口脚本
├── nexmark_env.sh          # 环境变量配置文件（需编辑）
├── bin/                    # 运行脚本
├── conf/                   # Flink 作业配置
├── lib/                    # JAR 包（需上传至控制台）
└── queries-vvp/            # Nexmark Query SQL 文件

步骤二：上传 Nexmark JAR

1. 登录实时计算控制台。

2. 单击进入目标项目空间，在左侧导航栏文件管理 > 上传资源。

3. 选择并上传 nexmark-flink-0.2-SNAPSHOT.jar 文件。该文件位于测试工具的 nexmark-flink/lib 目录下。

4. 上传完成后，单击目标文件名称复制 OSS 地址。该地址在后续配置参数时使用。文件路径格式因存储类型而异：

   • OSS Bucket 存储：oss://<OSS Bucket 名称>/artifacts/namespaces/<项目空间名称>/<文件名>

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

   • 全托管存储：oss://flink-fullymanaged-<工作空间ID>/artifacts/namespaces/<项目空间名称>/<文件名>

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

   如需查看工作空间的存储类型，在实时计算管理控制台单击目标工作空间操作列下的详情查看。

步骤三：配置运行参数

编辑 nexmark-flink/nexmark_env.sh 文件，填写以下参数。

步骤四：运行测试

1. 在 nexmark-flink 目录下执行以下命令。

   ./run_nexmark.sh

2. 测试工具通过 OpenAPI 自动创建并运行 Nexmark 作业。

3. 运行完成后，输出各 Query 的运行时长（毫秒）。示例如下：

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