You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/11/13 04:18:36 UTC

[incubator-iotdb] branch sync_remove_stop created (now 4b9490d)

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

lta pushed a change to branch sync_remove_stop
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


      at 4b9490d  remove stop after unable connection

This branch includes the following new commits:

     new 4b9490d  remove stop after unable connection

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[incubator-iotdb] 01/01: remove stop after unable connection

Posted by lt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

lta pushed a commit to branch sync_remove_stop
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit 4b9490d2b984a562f68e9f363f586dfb6c45ad9f
Author: lta <li...@163.com>
AuthorDate: Wed Nov 13 12:18:15 2019 +0800

    remove stop after unable connection
---
 .../org/apache/iotdb/db/sync/sender/transfer/DataTransferManager.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/DataTransferManager.java b/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/DataTransferManager.java
index dc04a1a..fd42bdd 100644
--- a/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/DataTransferManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/DataTransferManager.java
@@ -204,7 +204,6 @@ public class DataTransferManager implements IDataTransferManager {
         syncAll();
       } catch (SyncConnectionException | IOException | TException e) {
         logger.error("Sync failed", e);
-        stop();
       }
     }, SyncConstant.SYNC_PROCESS_DELAY, SyncConstant.SYNC_PROCESS_PERIOD, TimeUnit.SECONDS);
   }