Move field initialization for clarity

trinodb · May 22, 2024 · ed231b6 · ed231b6
1 parent b6a078b
commit ed231b6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...va/io/trino/execution/scheduler/faulttolerant/EventDrivenFaultTolerantQueryScheduler.java b/...va/io/trino/execution/scheduler/faulttolerant/EventDrivenFaultTolerantQueryScheduler.java
@@ -1923,7 +1923,7 @@ public static class StageExecution
         private boolean taskDescriptorLoadingActive;
         private boolean exchangeClosed;
 
-        private final long startTime = System.nanoTime();
+        private final long startTime;
         private OptionalLong nonSpeculativeSwitchTime;
 
         private MemoryRequirements initialMemoryRequirements;
@@ -1957,7 +1957,8 @@ private StageExecution(
             this.schedulingPriority = schedulingPriority;
             this.eager = eager;
             this.speculative = speculative;
-            this.nonSpeculativeSwitchTime = speculative ? OptionalLong.empty() : OptionalLong.of(System.nanoTime());
+            this.startTime = System.nanoTime();
+            this.nonSpeculativeSwitchTime = speculative ? OptionalLong.empty() : OptionalLong.of(startTime);
             this.dynamicFilterService = requireNonNull(dynamicFilterService, "dynamicFilterService is null");
             outputDataSize = new long[sinkPartitioningScheme.getPartitionCount()];
             sinkOutputSelectorBuilder = ExchangeSourceOutputSelector.builder(ImmutableSet.of(exchange.getId()));