delete statetracker and terminator
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java index 91b2cbc..94b3b58 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java
@@ -85,18 +85,18 @@ executor, writeOperationExecutor, internalServiceClientManager); - if (queryType == QueryType.READ) { - this.stateTracker = - new FixedRateFragInsStateTracker( - stateMachine, scheduledExecutor, instances, internalServiceClientManager); - this.queryTerminator = - new SimpleQueryTerminator( - scheduledExecutor, - queryContext, - instances, - internalServiceClientManager, - stateTracker); - } +// if (queryType == QueryType.READ) { +// this.stateTracker = +// new FixedRateFragInsStateTracker( +// stateMachine, scheduledExecutor, instances, internalServiceClientManager); +// this.queryTerminator = +// new SimpleQueryTerminator( +// scheduledExecutor, +// queryContext, +// instances, +// internalServiceClientManager, +// stateTracker); +// } } private boolean needRetry(TSStatus failureStatus) { @@ -107,7 +107,7 @@ @Override public void start() { - stateMachine.transitionToDispatching(); +// stateMachine.transitionToDispatching(); long startTime = System.nanoTime(); Future<FragInstanceDispatchResult> dispatchResultFuture = dispatcher.dispatch(instances); @@ -142,10 +142,10 @@ // The FragmentInstances has been dispatched successfully to corresponding host, we mark the // QueryState to Running - stateMachine.transitionToRunning(); +// stateMachine.transitionToRunning(); // TODO: (xingtanzjr) start the stateFetcher/heartbeat for each fragment instance - this.stateTracker.start(); +// this.stateTracker.start(); logger.debug("state tracker starts"); }