This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/write_opt_0621
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xingtanzjr/write_opt_0621 by
this push:
new 883c1ce488 change to sync write
883c1ce488 is described below
commit 883c1ce4881375b8468392dff57c2f391fdad311
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Wed Jun 22 10:45:24 2022 +0800
change to sync write
---
.../iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java | 2 ++
1 file changed, 2 insertions(+)
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 ef89b659da..7ad2776ea7 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
@@ -196,6 +196,8 @@ public class FragmentInstanceDispatcherImpl implements
IFragInstanceDispatcher {
} catch (IOException | TException e) {
logger.error("can't connect to node {}", endPoint, e);
throw new FragmentInstanceDispatchException(e);
+ } finally {
+
}
return false;
}