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

Reply via email to