[hotfix] Remove duplicated inherited interfaces of AdaptiveBatchSched…

…uler
tongcheng-elong · Jul 22, 2022 · 3b1165b · 3b1165b
1 parent 2e5cac1
commit 3b1165b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...rc/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java b/...rc/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java
@@ -47,7 +47,6 @@
 import org.apache.flink.runtime.scheduler.ExecutionOperations;
 import org.apache.flink.runtime.scheduler.ExecutionSlotAllocatorFactory;
 import org.apache.flink.runtime.scheduler.ExecutionVertexVersioner;
-import org.apache.flink.runtime.scheduler.SchedulerOperations;
 import org.apache.flink.runtime.scheduler.VertexParallelismStore;
 import org.apache.flink.runtime.scheduler.adaptivebatch.forwardgroup.ForwardGroup;
 import org.apache.flink.runtime.scheduler.adaptivebatch.forwardgroup.ForwardGroupComputeUtil;
@@ -71,7 +70,7 @@
  * This scheduler decides the parallelism of JobVertex according to the data volume it consumes. A
  * dynamically built up ExecutionGraph is used for this purpose.
  */
-public class AdaptiveBatchScheduler extends DefaultScheduler implements SchedulerOperations {
+public class AdaptiveBatchScheduler extends DefaultScheduler {
 
  private final DefaultLogicalTopology logicalTopology;