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

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


The following commit(s) were added to refs/heads/ml_0729_test by this push:
     new 4b66ede0a6 add fake write redirect
4b66ede0a6 is described below

commit 4b66ede0a635d4f16fa5bb65911b0df151c4687e
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Fri Jul 29 17:50:03 2022 +0800

    add fake write redirect
---
 .../db/mpp/plan/planner/distribution/WriteFragmentParallelPlanner.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/WriteFragmentParallelPlanner.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/WriteFragmentParallelPlanner.java
index 5f3abfc7d7..cfc17b45cb 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/WriteFragmentParallelPlanner.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/WriteFragmentParallelPlanner.java
@@ -66,7 +66,7 @@ public class WriteFragmentParallelPlanner implements 
IFragmentParallelPlaner {
               queryContext.getQueryType(),
               queryContext.getTimeOut());
       instance.setDataRegionAndHost(split.getRegionReplicaSet());
-      //      
instance.setHostDataNode(fakeSelectDataNode(split.getRegionReplicaSet()));
+      
instance.setHostDataNode(fakeSelectDataNode(split.getRegionReplicaSet()));
       ret.add(instance);
     }
     return ret;

Reply via email to