[flink] branch master updated: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 (#7981)

[kurt]

This is an automated email from the ASF dual-hosted git repository.

kurt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new c6878ac  [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest 
does not compile with Java 9 (#7981)
c6878ac is described below

commit c6878aca6c5aeee46581b4d6744b31049db9de95
Author: Kurt Young <ykt...@gmail.com>
AuthorDate: Thu Mar 14 21:39:01 2019 +0800

    [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not 
compile with Java 9 (#7981)
---
 .../table/runtime/compression/BlockCompressionTest.java  | 16 ----------------
 1 file changed, 16 deletions(-)

diff --git 
a/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
 
b/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
index ebcfec7..bfc888c 100644
--- 
a/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
+++ 
b/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
@@ -20,8 +20,6 @@ package org.apache.flink.table.runtime.compression;
 
 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 @@ public class BlockCompressionTest {
                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();
-               }
        }
 }