[iotdb] branch QueryMetrics updated: delete statetracker and terminator

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch QueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/QueryMetrics by this push:
     new 670adbe401 delete statetracker and terminator
670adbe401 is described below

commit 670adbe401e50e050ab9e114eba3458f861d06db
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Thu Dec 22 16:21:16 2022 +0800

    delete statetracker and terminator
---
 .../db/mpp/plan/scheduler/ClusterScheduler.java    | 30 +++++++++++-----------
 1 file changed, 15 insertions(+), 15 deletions(-)

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 91b2cbca5f..94b3b58f4d 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 @@ public class ClusterScheduler implements IScheduler {
             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 @@ public class ClusterScheduler implements IScheduler {
 
   @Override
   public void start() {
-    stateMachine.transitionToDispatching();
+//    stateMachine.transitionToDispatching();
     long startTime = System.nanoTime();
     Future<FragInstanceDispatchResult> dispatchResultFuture = dispatcher.dispatch(instances);
 
@@ -142,10 +142,10 @@ public class ClusterScheduler implements IScheduler {
 
     // 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");
   }