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
commit 907c3330c6778cc997de80d74bbef8b831796a11 Author: Thesharing <[email protected]> AuthorDate: Wed Jun 23 16:39:53 2021 +0800 [hotfix] Rename SchedulerBenchmarkBase to SchedulerBenchmarkExecutorBase --- ...chedulerBenchmarkBase.java => SchedulerBenchmarkExecutorBase.java} | 2 +- .../DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java | 4 ++-- .../deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java | 4 ++-- .../scheduler/benchmark/e2e/CreateSchedulerBenchmarkExecutor.java | 4 ++-- .../benchmark/e2e/SchedulingAndDeployingBenchmarkExecutor.java | 4 ++-- .../failover/RegionToRestartInBatchJobBenchmarkExecutor.java | 4 ++-- .../failover/RegionToRestartInStreamingJobBenchmarkExecutor.java | 4 ++-- .../partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java | 4 ++-- .../benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java | 4 ++-- .../SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java | 4 ++-- .../benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java | 4 ++-- 11 files changed, 21 insertions(+), 21 deletions(-) diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkBase.java b/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java similarity index 97% rename from src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkBase.java rename to src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java index 3c5eb84..fffbdfa 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkBase.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java @@ -45,7 +45,7 @@ import java.util.concurrent.TimeUnit; "-Dcom.sun.management.jmxremote.ssl=false", "-Dcom.sun.management.jmxremote.ssl" }) -public class SchedulerBenchmarkBase { +public class SchedulerBenchmarkExecutorBase { public static void runBenchmark(Class<?> clazz) throws RunnerException { Options options = new OptionsBuilder() diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java index 4ff2603..c54cdcd 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java @@ -21,7 +21,7 @@ package org.apache.flink.scheduler.benchmark.deploying; import org.apache.flink.runtime.executiongraph.Execution; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.deploying.DeployingDownstreamTasksInBatchJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -35,7 +35,7 @@ import org.openjdk.jmh.runner.RunnerException; * The benchmark of deploying downstream tasks in a BATCH job. * The related method is {@link Execution#deploy}. */ -public class DeployingDownstreamTasksInBatchJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class DeployingDownstreamTasksInBatchJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param("BATCH") private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java index 1c37f86..61434e8 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java @@ -21,7 +21,7 @@ package org.apache.flink.scheduler.benchmark.deploying; import org.apache.flink.runtime.executiongraph.Execution; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.deploying.DeployingTasksInStreamingJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -35,7 +35,7 @@ import org.openjdk.jmh.runner.RunnerException; * The benchmark of deploying tasks in a STREAMING job. * The related method is {@link Execution#deploy}. */ -public class DeployingTasksInStreamingJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class DeployingTasksInStreamingJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param("STREAMING") private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/e2e/CreateSchedulerBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/e2e/CreateSchedulerBenchmarkExecutor.java index 2a7d03f..abdf50e 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/e2e/CreateSchedulerBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/e2e/CreateSchedulerBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.e2e; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.e2e.CreateSchedulerBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -35,7 +35,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of creating the scheduler in a STREAMING/BATCH job. */ -public class CreateSchedulerBenchmarkExecutor extends SchedulerBenchmarkBase { +public class CreateSchedulerBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param({"BATCH", "STREAMING"}) private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/e2e/SchedulingAndDeployingBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/e2e/SchedulingAndDeployingBenchmarkExecutor.java index 14968e6..00b3899 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/e2e/SchedulingAndDeployingBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/e2e/SchedulingAndDeployingBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.e2e; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.e2e.SchedulingAndDeployingBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -34,7 +34,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of scheduling and deploying tasks in a STREAMING/BATCH job. */ -public class SchedulingAndDeployingBenchmarkExecutor extends SchedulerBenchmarkBase { +public class SchedulingAndDeployingBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param({"BATCH", "STREAMING"}) private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInBatchJobBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInBatchJobBenchmarkExecutor.java index 61c0bd4..9815968 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInBatchJobBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInBatchJobBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.failover; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.failover.RegionToRestartInBatchJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -34,7 +34,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of calculating the regions to restart when failover occurs in a BATCH job. */ -public class RegionToRestartInBatchJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class RegionToRestartInBatchJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param("BATCH") private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInStreamingJobBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInStreamingJobBenchmarkExecutor.java index 413e732..f7f6d5d 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInStreamingJobBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInStreamingJobBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.failover; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.failover.RegionToRestartInStreamingJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -34,7 +34,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of calculating region to restart when failover occurs in a STREAMING job. */ -public class RegionToRestartInStreamingJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class RegionToRestartInStreamingJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param("STREAMING") private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java index fa1c921..3568548 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.partitionrelease; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.partitionrelease.PartitionReleaseInBatchJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -33,7 +33,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of releasing partitions in a BATCH job. */ -public class PartitionReleaseInBatchJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class PartitionReleaseInBatchJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param("BATCH") private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java index a20e3c7..8e4ce3d 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.scheduling; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.scheduling.InitSchedulingStrategyBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -34,7 +34,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of initializing the scheduling strategy in a STREAMING/BATCH job. */ -public class InitSchedulingStrategyBenchmarkExecutor extends SchedulerBenchmarkBase { +public class InitSchedulingStrategyBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param({"BATCH", "STREAMING"}) private JobConfiguration jobConfiguration; 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 c6de8fe..bd3b7ef 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 @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.scheduling; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.scheduling.SchedulingDownstreamTasksInBatchJobBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -33,7 +33,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of scheduling downstream task in a BATCH job. */ -public class SchedulingDownstreamTasksInBatchJobBenchmarkExecutor extends SchedulerBenchmarkBase { +public class SchedulingDownstreamTasksInBatchJobBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param({"BATCH"}) private JobConfiguration jobConfiguration; diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java b/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java index 586f535..5f193a7 100644 --- a/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java +++ b/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java @@ -20,7 +20,7 @@ package org.apache.flink.scheduler.benchmark.topology; import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration; import org.apache.flink.runtime.scheduler.benchmark.topology.BuildExecutionGraphBenchmark; -import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkBase; +import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase; import org.openjdk.jmh.annotations.Benchmark; import org.openjdk.jmh.annotations.BenchmarkMode; @@ -33,7 +33,7 @@ import org.openjdk.jmh.runner.RunnerException; /** * The benchmark of building the topology of ExecutionGraph in a STREAMING/BATCH job. */ -public class BuildExecutionGraphBenchmarkExecutor extends SchedulerBenchmarkBase { +public class BuildExecutionGraphBenchmarkExecutor extends SchedulerBenchmarkExecutorBase { @Param({"BATCH", "STREAMING"}) private JobConfiguration jobConfiguration;
