fix code and test bugs

timeplus-io · Jul 16, 2024 · aeb5cdb · aeb5cdb
1 parent 9f7401c
commit aeb5cdb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/timeplus-native-jdbc/src/main/java/com/timeplus/serde/BinarySerializer.java b/timeplus-native-jdbc/src/main/java/com/timeplus/serde/BinarySerializer.java
@@ -36,8 +36,8 @@ public BinarySerializer(BuffedWriter writer, boolean enableCompress) {
             compressWriter = new CompressedBuffedWriter(TimeplusDefines.SOCKET_SEND_BUFFER_BYTES, writer);
         }
         switcher = new Switcher<>(compressWriter, writer);
-        // max num of byte is 32 for Int256
-        writeBuffer = new byte[32];
+        // max num of byte is 8 for double and long
+        writeBuffer = new byte[8];
     }
 
     public void writeVarInt(long x) throws IOException {