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 2020/02/04 08:49:00 UTC
[incubator-iotdb] 01/01: fix sync schema pos bug
This is an automated email from the ASF dual-hosted git repository.
lta pushed a commit to branch fix_sync_runtime_exception_for_master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit d7ac8155c9aa17732b3146d1d2ebf290c869ba7b
Author: lta <li...@163.com>
AuthorDate: Tue Feb 4 16:48:11 2020 +0800
fix sync schema pos bug
---
.../java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java b/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
index b5d315b..1699d08 100644
--- a/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
+++ b/server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
@@ -418,11 +418,16 @@ public class SyncClient implements ISyncClient {
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;
}