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;