[hotfix][runtime] Rename SchedulerTestingUtils#createScheduler(...) t…

…o createSchedulerBuilder(...) because it returns a builder
is · Dec 17, 2020 · b3a2bc1 · b3a2bc1
1 parent 52741b1
commit b3a2bc1
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java
@@ -146,27 +146,27 @@ public static DefaultScheduler createScheduler(
 
  public static DefaultSchedulerBuilder createSchedulerBuilder(
  JobGraph jobGraph,
- ManuallyTriggeredScheduledExecutorService asyncExecutor) throws Exception {
+ ManuallyTriggeredScheduledExecutorService asyncExecutor) {
 
- return createScheduler(jobGraph, asyncExecutor, new SimpleAckingTaskManagerGateway());
+ return createSchedulerBuilder(jobGraph, asyncExecutor, new SimpleAckingTaskManagerGateway());
  }
 
  public static DefaultSchedulerBuilder createSchedulerBuilder(
  JobGraph jobGraph,
  ManuallyTriggeredScheduledExecutorService asyncExecutor,
- TaskExecutorOperatorEventGateway operatorEventGateway) throws Exception {
+ TaskExecutorOperatorEventGateway operatorEventGateway) {
 
  final TaskManagerGateway gateway = operatorEventGateway instanceof TaskManagerGateway
  ? (TaskManagerGateway) operatorEventGateway
  : new TaskExecutorOperatorEventGatewayAdapter(operatorEventGateway);
 
- return createScheduler(jobGraph, asyncExecutor, gateway);
+ return createSchedulerBuilder(jobGraph, asyncExecutor, gateway);
  }
 
- public static DefaultSchedulerBuilder createScheduler(
+ public static DefaultSchedulerBuilder createSchedulerBuilder(
  JobGraph jobGraph,
  ManuallyTriggeredScheduledExecutorService asyncExecutor,
- TaskManagerGateway taskManagerGateway) throws Exception {
+ TaskManagerGateway taskManagerGateway) {
 
  return newSchedulerBuilder(jobGraph)
  .setFutureExecutor(asyncExecutor)