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

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


The following commit(s) were added to refs/heads/xingtanzjr/write_opt by this 
push:
     new 6a535c5971 try sync
6a535c5971 is described below

commit 6a535c5971ef4d406b8d9f84868ed02fcb0fd784
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Mon Jun 20 00:13:28 2022 +0800

    try sync
---
 .../iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
index 52f455b1f0..35c301e230 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
@@ -90,7 +90,7 @@ public class FragmentInstanceDispatcherImpl implements 
IFragInstanceDispatcher {
     if (type == QueryType.READ) {
       return dispatchRead(instances);
     } else {
-      return dispatchWrite(instances);
+      return dispatchWriteSync(instances);
     }
   }
 

Reply via email to