From 348d501625eaa6999dda0027bbe2fb8e06af45db Mon Sep 17 00:00:00 2001 From: zentol Date: Sun, 25 Oct 2015 15:07:37 +0100 Subject: [PATCH] Remove deprecation warning suppressions --- .../operators/hash/NonReusingHashJoinIteratorITCase.java | 2 +- .../operators/hash/NonReusingReOpenableHashTableITCase.java | 1 - .../runtime/operators/hash/ReusingHashJoinIteratorITCase.java | 2 +- .../operators/hash/ReusingReOpenableHashTableITCase.java | 1 - .../iterative/ConnectedComponentsWithDeferredUpdateITCase.java | 1 - .../ConnectedComponentsWithSolutionSetFirstITCase.java | 1 - 6 files changed, 2 insertions(+), 6 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashJoinIteratorITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashJoinIteratorITCase.java index a766214c7ff..aff78135e66 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashJoinIteratorITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashJoinIteratorITCase.java @@ -54,7 +54,7 @@ import java.util.Map.Entry; import org.apache.flink.api.common.typeutils.GenericPairComparator; import org.apache.flink.api.java.tuple.Tuple2; -@SuppressWarnings({"serial", "deprecation"}) +@SuppressWarnings({"serial"}) public class NonReusingHashJoinIteratorITCase { private static final int MEMORY_SIZE = 16000000; // total memory diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingReOpenableHashTableITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingReOpenableHashTableITCase.java index a885e6b84db..814d0ed1372 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingReOpenableHashTableITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingReOpenableHashTableITCase.java @@ -64,7 +64,6 @@ import static org.junit.Assert.fail; * Test specialized hash join that keeps the build side data (in memory and on hard disk) * This is used for iterative tasks. */ -@SuppressWarnings("deprecation") public class NonReusingReOpenableHashTableITCase { private static final int PAGE_SIZE = 8 * 1024; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashJoinIteratorITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashJoinIteratorITCase.java index 87707a45db4..af814c3b173 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashJoinIteratorITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashJoinIteratorITCase.java @@ -62,7 +62,7 @@ import static org.apache.flink.runtime.operators.hash.NonReusingHashJoinIterator import static org.apache.flink.runtime.operators.hash.NonReusingHashJoinIteratorITCase.collectTupleData; import static org.apache.flink.runtime.operators.hash.NonReusingHashJoinIteratorITCase.collectIntPairData; -@SuppressWarnings({"serial", "deprecation"}) +@SuppressWarnings({"serial"}) public class ReusingHashJoinIteratorITCase { private static final int MEMORY_SIZE = 16000000; // total memory diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingReOpenableHashTableITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingReOpenableHashTableITCase.java index 582077e0ce6..d2229477a6a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingReOpenableHashTableITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingReOpenableHashTableITCase.java @@ -66,7 +66,6 @@ import static org.apache.flink.runtime.operators.hash.NonReusingHashJoinIterator * Test specialized hash join that keeps the build side data (in memory and on hard disk) * This is used for iterative tasks. */ -@SuppressWarnings("deprecation") public class ReusingReOpenableHashTableITCase { private static final int PAGE_SIZE = 8 * 1024; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithDeferredUpdateITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithDeferredUpdateITCase.java index 33dd989ba59..bc4885f1ded 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithDeferredUpdateITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithDeferredUpdateITCase.java @@ -39,7 +39,6 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameters; -@SuppressWarnings("deprecation") @RunWith(Parameterized.class) public class ConnectedComponentsWithDeferredUpdateITCase extends JavaProgramTestBase { diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithSolutionSetFirstITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithSolutionSetFirstITCase.java index fbe1402c555..c2dd434f371 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithSolutionSetFirstITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithSolutionSetFirstITCase.java @@ -37,7 +37,6 @@ import org.apache.flink.util.Collector; /** * Tests a bug that prevented that the solution set can be on both sides of the match/cogroup function. */ -@SuppressWarnings("deprecation") public class ConnectedComponentsWithSolutionSetFirstITCase extends JavaProgramTestBase { private static final long SEED = 0xBADC0FFEEBEEFL; -- GitLab