Properly target Java 8

.github/workflows/main.yml

@@ -10,9 +10,14 @@ jobs:
         java: ['8', '11', '15', '16']
     steps:
       - uses: actions/checkout@v1
-      - name: Setup JDK ${{ matrix.java }}
+      - name: Setup test JDK ${{ matrix.java }}
         uses: actions/setup-java@v1
         with:
           java-version: ${{ matrix.java }}
+      - run: echo "test_java_home=$JAVA_HOME" >> $GITHUB_ENV
+      - name: Setup build JDK 16
+        uses: actions/setup-java@v1
+        with:
+          java-version: 16
       - name: Maven Test
-        run: mvn install -B
+        run: mvn install -V -P ci -B -Dtest_java_home=${{ env.test_java_home }}

pom.xml

@@ -167,4 +167,21 @@
             </plugins>
         </pluginManagement>
     </build>
+
+    <profiles>
+        <profile>
+            <id>ci</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <configuration>
+                            <jvm>${test_java_home}/bin/java</jvm>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
 </project>

src/main/java/io/airlift/compress/lz4/Lz4Compressor.java

@@ -15,6 +15,7 @@
 
 import io.airlift.compress.Compressor;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.lz4.Lz4RawCompressor.MAX_TABLE_SIZE;
@@ -45,8 +46,15 @@ public int compress(byte[] input, int inputOffset, int inputLength, byte[] outpu
     }
 
     @Override
-    public void compress(ByteBuffer input, ByteBuffer output)
+    public void compress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/lz4/Lz4Decompressor.java

@@ -16,6 +16,7 @@
 import io.airlift.compress.Decompressor;
 import io.airlift.compress.MalformedInputException;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.lz4.UnsafeUtil.getAddress;
@@ -37,9 +38,16 @@ public int decompress(byte[] input, int inputOffset, int inputLength, byte[] out
     }
 
     @Override
-    public void decompress(ByteBuffer input, ByteBuffer output)
+    public void decompress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
             throws MalformedInputException
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/lzo/LzoCompressor.java

@@ -15,6 +15,7 @@
 
 import io.airlift.compress.Compressor;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.lzo.LzoRawCompressor.MAX_TABLE_SIZE;
@@ -45,8 +46,15 @@ public int compress(byte[] input, int inputOffset, int inputLength, byte[] outpu
     }
 
     @Override
-    public void compress(ByteBuffer input, ByteBuffer output)
+    public void compress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/lzo/LzoDecompressor.java

@@ -16,6 +16,7 @@
 import io.airlift.compress.Decompressor;
 import io.airlift.compress.MalformedInputException;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.lzo.UnsafeUtil.getAddress;
@@ -37,9 +38,16 @@ public int decompress(byte[] input, int inputOffset, int inputLength, byte[] out
     }
 
     @Override
-    public void decompress(ByteBuffer input, ByteBuffer output)
+    public void decompress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
             throws MalformedInputException
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/snappy/SnappyCompressor.java

@@ -15,6 +15,7 @@
 
 import io.airlift.compress.Compressor;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.snappy.UnsafeUtil.getAddress;
@@ -43,8 +44,15 @@ public int compress(byte[] input, int inputOffset, int inputLength, byte[] outpu
     }
 
     @Override
-    public void compress(ByteBuffer input, ByteBuffer output)
+    public void compress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/snappy/SnappyDecompressor.java

@@ -16,6 +16,7 @@
 import io.airlift.compress.Decompressor;
 import io.airlift.compress.MalformedInputException;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.snappy.UnsafeUtil.getAddress;
@@ -45,9 +46,16 @@ public int decompress(byte[] input, int inputOffset, int inputLength, byte[] out
     }
 
     @Override
-    public void decompress(ByteBuffer input, ByteBuffer output)
+    public void decompress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
             throws MalformedInputException
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/zstd/ZstdCompressor.java

@@ -15,6 +15,7 @@
 
 import io.airlift.compress.Compressor;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.zstd.Constants.MAX_BLOCK_SIZE;
@@ -46,8 +47,15 @@ public int compress(byte[] input, int inputOffset, int inputLength, byte[] outpu
     }
 
     @Override
-    public void compress(ByteBuffer input, ByteBuffer output)
+    public void compress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/main/java/io/airlift/compress/zstd/ZstdDecompressor.java

@@ -16,6 +16,7 @@
 import io.airlift.compress.Decompressor;
 import io.airlift.compress.MalformedInputException;
 
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 
 import static io.airlift.compress.zstd.UnsafeUtil.getAddress;
@@ -39,9 +40,16 @@ public int decompress(byte[] input, int inputOffset, int inputLength, byte[] out
     }
 
     @Override
-    public void decompress(ByteBuffer input, ByteBuffer output)
+    public void decompress(ByteBuffer inputBuffer, ByteBuffer outputBuffer)
             throws MalformedInputException
     {
+        // Java 9+ added an overload of various methods in ByteBuffer. When compiling with Java 11+ and targeting Java 8 bytecode
+        // the resulting signatures are invalid for JDK 8, so accesses below result in NoSuchMethodError. Accessing the
+        // methods through the interface class works around the problem
+        // Sidenote: we can't target "javac --release 8" because Unsafe is not available in the signature data for that profile
+        Buffer input = inputBuffer;
+        Buffer output = outputBuffer;
+
         Object inputBase;
         long inputAddress;
         long inputLimit;

src/test/java/io/airlift/compress/AbstractTestCompression.java

@@ -22,6 +22,7 @@
 import javax.inject.Inject;
 
 import java.io.IOException;
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -155,7 +156,7 @@ public void testDecompressByteBufferHeapToHeap(DataSet dataSet)
         ByteBuffer uncompressed = ByteBuffer.allocate(uncompressedOriginal.length);
 
         getDecompressor().decompress(compressed, uncompressed);
-        uncompressed.flip();
+        ((Buffer) uncompressed).flip();
 
         assertByteBufferEqual(ByteBuffer.wrap(uncompressedOriginal), uncompressed);
     }
@@ -174,7 +175,7 @@ public void testDecompressByteBufferHeapToDirect(DataSet dataSet)
         ByteBuffer uncompressed = ByteBuffer.allocateDirect(uncompressedOriginal.length);
 
         getDecompressor().decompress(compressed, uncompressed);
-        uncompressed.flip();
+        ((Buffer) uncompressed).flip();
 
         assertByteBufferEqual(ByteBuffer.wrap(uncompressedOriginal), uncompressed);
     }
@@ -193,7 +194,7 @@ public void testDecompressByteBufferDirectToHeap(DataSet dataSet)
         ByteBuffer uncompressed = ByteBuffer.allocate(uncompressedOriginal.length);
 
         getDecompressor().decompress(compressed, uncompressed);
-        uncompressed.flip();
+        ((Buffer) uncompressed).flip();
 
         assertByteBufferEqual(ByteBuffer.wrap(uncompressedOriginal), uncompressed);
     }
@@ -212,7 +213,7 @@ public void testDecompressByteBufferDirectToDirect(DataSet dataSet)
         ByteBuffer uncompressed = ByteBuffer.allocateDirect(uncompressedOriginal.length);
 
         getDecompressor().decompress(compressed, uncompressed);
-        uncompressed.flip();
+        ((Buffer) uncompressed).flip();
 
         assertByteBufferEqual(ByteBuffer.wrap(uncompressedOriginal), uncompressed);
     }
@@ -323,17 +324,17 @@ private void verifyCompressByteBuffer(Compressor compressor, ByteBuffer expected
         if (expected.remaining() > 1) {
             ByteBuffer duplicate = expected.duplicate();
             duplicate.get(); // skip one byte
-            compressor.compress(duplicate, ByteBuffer.allocate(compressed.remaining()));
+            compressor.compress(duplicate, ByteBuffer.allocate(((Buffer) compressed).remaining()));
         }
 
         compressor.compress(expected.duplicate(), compressed);
-        compressed.flip();
+        ((Buffer) compressed).flip();
 
-        ByteBuffer uncompressed = ByteBuffer.allocate(expected.remaining());
+        ByteBuffer uncompressed = ByteBuffer.allocate(((Buffer) expected).remaining());
 
         // TODO: validate with "control" decompressor
         getDecompressor().decompress(compressed, uncompressed);
-        uncompressed.flip();
+        ((Buffer) uncompressed).flip();
 
         assertByteBufferEqual(expected.duplicate(), uncompressed);
     }
@@ -409,21 +410,27 @@ public static void assertByteArraysEqual(byte[] left, int leftOffset, int leftLe
 
     private static void assertByteBufferEqual(ByteBuffer left, ByteBuffer right)
     {
-        int leftPosition = left.position();
-        int rightPosition = right.position();
-        for (int i = 0; i < Math.min(left.remaining(), right.remaining()); i++) {
+        Buffer leftBuffer = left;
+        Buffer rightBuffer = right;
+
+        int leftPosition = leftBuffer.position();
+        int rightPosition = rightBuffer.position();
+        for (int i = 0; i < Math.min(leftBuffer.remaining(), rightBuffer.remaining()); i++) {
             if (left.get(leftPosition + i) != right.get(rightPosition + i)) {
                 fail(String.format("Byte buffers differ at position %s: 0x%02X vs 0x%02X", i, left.get(leftPosition + i), right.get(rightPosition + i)));
             }
         }
 
-        assertEquals(left.remaining(), right.remaining(), String.format("Buffer lengths differ: %s vs %s", left.remaining(), left.remaining()));
+        assertEquals(leftBuffer.remaining(), rightBuffer.remaining(), String.format("Buffer lengths differ: %s vs %s", leftBuffer.remaining(), leftBuffer.remaining()));
     }
 
     private static ByteBuffer toDirectBuffer(byte[] data)
     {
         ByteBuffer direct = ByteBuffer.allocateDirect(data.length);
-        direct.put(data).flip();
+        direct.put(data);
+
+        ((Buffer) direct).flip();
+
         return direct;
     }