Call start() method before FI really executing (#7206)

apache · Sep 2, 2022 · a3559e5 · a3559e5
1 parent 6d2a1cf
commit a3559e5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
  //    private final AtomicLong endFullGcCount = new AtomicLong(-1);
  //    private final AtomicLong endFullGcTimeNanos = new AtomicLong(-1);

  public static FragmentInstanceContext createFragmentInstanceContext(
       FragmentInstanceId id, FragmentInstanceStateMachine stateMachine) {
     FragmentInstanceContext instanceContext = new FragmentInstanceContext(id, stateMachine);
     instanceContext.initialize();
+    instanceContext.start();
     return instanceContext;
   }
 
  public static FragmentInstanceContext createFragmentInstanceContextForCompaction(long queryId) {