[FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not …

…compile with Java 9 (apache#7981)
silenceland · Mar 14, 2019 · c6878ac · c6878ac
1 parent e20a9f8
commit c6878ac
Showing 1 changed file with 0 additions and 16 deletions.
diff --git a/...-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java b/...-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
@@ -20,8 +20,6 @@
 
 import org.junit.Assert;
 import org.junit.Test;
-import sun.misc.Cleaner;
-import sun.nio.ch.DirectBuffer;
 
 import java.nio.ByteBuffer;
 
@@ -174,19 +172,5 @@ private void runByteBufferTest(
 		for (int i = 0; i < decompressedLen; i++) {
 			assertEquals((byte) i, decompressedData.get());
 		}
-
-		if (isDirect) {
-			cleanDirectBuffer(data);
-			cleanDirectBuffer(compressedData);
-			cleanDirectBuffer(copiedCompressedData);
-			cleanDirectBuffer(decompressedData);
-		}
-	}
-
-	private void cleanDirectBuffer(ByteBuffer buffer) {
-		Cleaner cleaner = ((DirectBuffer) buffer).cleaner();
-		if (cleaner != null) {
-			cleaner.clean();
-		}
 	}
 }