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/12/10 06:55:23 UTC
[iotdb] branch fix_sync_compression created (now 5c82a11)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch fix_sync_compression
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 5c82a11 [To rel/0.11] Fix sync failed bug (#2241)
This branch includes the following new commits:
new 5c82a11 [To rel/0.11] Fix sync failed bug (#2241)
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.
[iotdb] 01/01: [To rel/0.11] Fix sync failed bug (#2241)
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_sync_compression
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5c82a110e554fae30ec6fe6d2060079684058f48
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Thu Dec 10 14:52:21 2020 +0800
[To rel/0.11] Fix sync failed bug (#2241)
---
.../java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 215fc77..838d74e 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
@@ -278,9 +278,9 @@ public class SyncClient implements ISyncClient {
.getTransport(new TSocket(serverIp, serverPort, TIMEOUT_MS));
TProtocol protocol = null;
if (IoTDBDescriptor.getInstance().getConfig().isRpcThriftCompressionEnable()) {
- protocol = new TBinaryProtocol(transport);
- } else {
protocol = new TCompactProtocol(transport);
+ } else {
+ protocol = new TBinaryProtocol(transport);
}
serviceClient = new SyncService.Client(protocol);