You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/02/04 10:40:08 UTC
[incubator-iotdb] branch rel/0.9 updated: catch runtime exception
and sync schema pos bug (#766)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.9
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/rel/0.9 by this push:
new e2ba4f7 catch runtime exception and sync schema pos bug (#766)
e2ba4f7 is described below
commit e2ba4f7df3f5fdcb57cc5b20b9791795a0d555d9
Author: Tianan Li <li...@163.com>
AuthorDate: Tue Feb 4 18:40:02 2020 +0800
catch runtime exception and sync schema pos bug (#766)
---
.../iotdb/db/sync/sender/transfer/DataTransferManager.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
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 ae93413..962225f 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
@@ -206,7 +206,7 @@ public class DataTransferManager implements IDataTransferManager {
executorService.scheduleWithFixedDelay(() -> {
try {
syncAll();
- } catch (SyncConnectionException | IOException | TException e) {
+ } catch (Exception e) {
logger.error("Sync failed", e);
}
}, SyncConstant.SYNC_PROCESS_DELAY, SyncConstant.SYNC_PROCESS_PERIOD, TimeUnit.SECONDS);
@@ -421,11 +421,16 @@ public class DataTransferManager implements IDataTransferManager {
try {
if (syncSchemaLogFile.exists()) {
try (BufferedReader br = new BufferedReader(new FileReader(syncSchemaLogFile))) {
- return Integer.parseInt(br.readLine());
+ String pos = br.readLine();
+ if(pos != null) {
+ return Integer.parseInt(pos);
+ }
}
}
} catch (IOException e) {
logger.error("Can not find file {}", syncSchemaLogFile.getAbsoluteFile(), e);
+ } catch (NumberFormatException e){
+ logger.error("Sync schema pos is not valid", e);
}
return 0;
}