This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch fix_LZ4Uncompressor in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit 9558e572180908341cb96a4a602d26ef8cd73695 Author: DESKTOP-L0L5GPJ\jt <[email protected]> AuthorDate: Thu Mar 28 16:35:08 2024 +0800 fix the mistaken arguement in LZ4Uncompress or --- pom.xml | 6 +++--- .../org/apache/tsfile/compress/IUnCompressor.java | 2 +- .../java/org/apache/tsfile/compress/LZ4Test.java | 21 +++++++++++++++++++++ 3 files changed, 25 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index 928f0c5e..ce766e3c 100644 --- a/pom.xml +++ b/pom.xml @@ -39,7 +39,7 @@ <properties> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> - <argLine /> + <argLine/> <spotless.skip>false</spotless.skip> </properties> <dependencyManagement> @@ -202,7 +202,7 @@ <importOrder> <order>org.apache.tsfile,,javax,java,\#</order> </importOrder> - <removeUnusedImports /> + <removeUnusedImports/> </java> <lineEndings>UNIX</lineEndings> </configuration> @@ -301,7 +301,7 @@ <phase>validate</phase> <configuration> <rules> - <dependencyConvergence /> + <dependencyConvergence/> </rules> </configuration> </execution> diff --git a/tsfile/src/main/java/org/apache/tsfile/compress/IUnCompressor.java b/tsfile/src/main/java/org/apache/tsfile/compress/IUnCompressor.java index aabac3bf..c3560bc2 100644 --- a/tsfile/src/main/java/org/apache/tsfile/compress/IUnCompressor.java +++ b/tsfile/src/main/java/org/apache/tsfile/compress/IUnCompressor.java @@ -238,7 +238,7 @@ public interface IUnCompressor { public int uncompress(byte[] byteArray, int offset, int length, byte[] output, int outOffset) throws IOException { try { - return decompressor.decompress(byteArray, offset, length, output, offset); + return decompressor.decompress(byteArray, offset, length, output, outOffset); } catch (RuntimeException e) { logger.error(UNCOMPRESS_INPUT_ERROR, e); throw new IOException(e); diff --git a/tsfile/src/test/java/org/apache/tsfile/compress/LZ4Test.java b/tsfile/src/test/java/org/apache/tsfile/compress/LZ4Test.java index 2b62f87f..299c70f7 100644 --- a/tsfile/src/test/java/org/apache/tsfile/compress/LZ4Test.java +++ b/tsfile/src/test/java/org/apache/tsfile/compress/LZ4Test.java @@ -80,4 +80,25 @@ public class LZ4Test { byte[] uncompressed = unCompressor.uncompress(compressed); Assert.assertArrayEquals(uncom, uncompressed); } + + @Test + public void testBytes3() throws IOException { + LZ4Compressor compressor = new LZ4Compressor(); + IUnCompressor.LZ4UnCompressor unCompressor = new IUnCompressor.LZ4UnCompressor(); + + int n = 500000; + int offset = 100; + String input = randomString(n); + byte[] origin = input.getBytes(StandardCharsets.UTF_8); + byte[] compressed = new byte[origin.length * 2]; + int compressedLength = compressor.compress(origin, 0, origin.length, compressed); + System.arraycopy(compressed, 0, compressed, offset, compressedLength); + for (int i = 0; i < offset; i++) { + compressed[i] = 0; + } + + byte[] uncompressed = new byte[origin.length]; + unCompressor.uncompress(compressed, offset, compressedLength, uncompressed, 0); + Assert.assertArrayEquals(origin, uncompressed); + } }
