Skip to content

Commit 3209ba2

Browse files
committed
Format compressed frame reset test
1 parent f5b0081 commit 3209ba2

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

‎iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportTest.java‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,7 @@ public void testReadCompressedFramesResetMessageSize() throws TTransportExceptio
6767
byte[] firstFrame = {1, 2};
6868
byte[] secondFrame = {3, 4, 5, 6, 7, 8};
6969
TMemoryBuffer wire = new TMemoryBuffer(128);
70-
TSnappyElasticFramedTransport output =
71-
new TSnappyElasticFramedTransport(wire, 4, 128, false);
70+
TSnappyElasticFramedTransport output = new TSnappyElasticFramedTransport(wire, 4, 128, false);
7271
output.write(firstFrame);
7372
output.flush();
7473
output.write(secondFrame);
@@ -88,8 +87,7 @@ public void testReadCompressedFramesResetMessageSize() throws TTransportExceptio
8887
TMemoryBuffer underlying = new TMemoryBuffer(configuration, maxMessageSize);
8988
underlying.write(framedData);
9089
TSnappyElasticFramedTransport input =
91-
new TSnappyElasticFramedTransport(
92-
underlying, 4, configuration.getMaxFrameSize(), false);
90+
new TSnappyElasticFramedTransport(underlying, 4, configuration.getMaxFrameSize(), false);
9391

9492
byte[] actualFirstFrame = new byte[firstFrame.length];
9593
input.readAll(actualFirstFrame, 0, actualFirstFrame.length);

0 commit comments

Comments
 (0)