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);
}
}