This is an automated email from the ASF dual-hosted git repository. lta pushed a commit to branch fix_sync_bug in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit d06cf0986417c864f24c94b7c953069eff6650e9 Author: lta <[email protected]> AuthorDate: Thu Aug 27 11:23:27 2020 +0800 fix a bug of bytebuffer via thrift --- .../org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java index f5f325f..dc51ba3 100644 --- a/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java +++ b/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java @@ -210,8 +210,9 @@ public class SyncServiceImpl implements SyncService.Iface { @Override public SyncStatus syncData(ByteBuffer buff) { try { + int pos = buff.position(); currentFileWriter.get().write(buff); - buff.flip(); + buff.position(pos); messageDigest.get().update(buff); } catch (IOException e) { logger.error("Can not sync data for file {}", currentFile.get().getAbsoluteFile(), e);
