Remove unused variable

trinodb · Aug 12, 2022 · 17247b9 · 17247b9
1 parent a4f7876
commit 17247b9
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...rino-main/src/main/java/io/trino/execution/scheduler/FixedSourcePartitionedScheduler.java b/...rino-main/src/main/java/io/trino/execution/scheduler/FixedSourcePartitionedScheduler.java
@@ -80,8 +80,6 @@ public FixedSourcePartitionedScheduler(
 
         ArrayList<SourceScheduler> sourceSchedulers = new ArrayList<>();
 
-        boolean firstPlanNode = true;
-
         partitionIdAllocator = new PartitionIdAllocator();
         scheduledTasks = new HashMap<>();
         for (PlanNodeId planNodeId : schedulingOrder) {
@@ -101,10 +99,6 @@ public FixedSourcePartitionedScheduler(
                     scheduledTasks);
 
             sourceSchedulers.add(sourceScheduler);
-
-            if (firstPlanNode) {
-                firstPlanNode = false;
-            }
         }
         this.sourceSchedulers = new ArrayDeque<>(sourceSchedulers);
     }