[flink-benchmarks] branch master updated: [FLINK-30480][runtime] Add benchmarks for adaptive batch scheduler.

[zhuzh]

This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git


The following commit(s) were added to refs/heads/master by this push:
     new 2c03dca  [FLINK-30480][runtime] Add benchmarks for adaptive batch 
scheduler.
2c03dca is described below

commit 2c03dca3c8e8b4aabac1ff803cb363cbd36c74d1
Author: sunxia <xingbe...@gmail.com>
AuthorDate: Fri Jun 9 14:55:53 2023 +0800

    [FLINK-30480][runtime] Add benchmarks for adaptive batch scheduler.
---
 .../SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
 
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
index 7b05575..182776b 100644
--- 
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
+++ 
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
@@ -35,7 +35,7 @@ import org.openjdk.jmh.runner.RunnerException;
 public class SchedulingDownstreamTasksInBatchJobBenchmarkExecutor
         extends SchedulerBenchmarkExecutorBase {
 
-    @Param({"BATCH"})
+    @Param({"BATCH", "BATCH_HYBRID_DEFAULT", "BATCH_HYBRID_PARTIAL_FINISHED", 
"BATCH_HYBRID_ALL_FINISHED"})
     private JobConfiguration jobConfiguration;
 
     private SchedulingDownstreamTasksInBatchJobBenchmark benchmark;