[iotdb] branch cluster_add_snappy updated: fix read

[ji...@apache.org]

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

jiangtian pushed a commit to branch cluster_add_snappy
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/cluster_add_snappy by this push:
     new 1f94649  fix read
1f94649 is described below

commit 1f946497d2a1e2cb202f07927d49f6ece0907dc7
Author: jt <jt...@163.com>
AuthorDate: Mon Nov 30 20:49:41 2020 +0800

    fix read
---
 .../apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java b/cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java
index a68d804..a8e3b90 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java
@@ -110,7 +110,7 @@ public class TElasticFramedTransport extends TFastFramedTransport {
       if (uncompressedLength < maxLength) {
         readBuffer.shrinkSizeIfNecessary(maxLength);
       }
-      readBuffer.fill(readBuffer, uncompressedLength);
+      readBuffer.fill(readCompressBuffer, uncompressedLength);
     } catch (IOException e) {
       throw new TTransportException(e);
     }