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 a766214c7fff9890b1994bf3bf334fceb33b5b2b..aff78135e66725e3d89f175f947cbc016dfde261 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 a885e6b84db6c63eef56e366c798050ef9fbcdb2..814d0ed13724c7a3d1de00bbdbf90bae79b5fbde 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 87707a45db4d2d07d989763b3abe3d94931157a0..af814c3b173328a229ee6b4bf5bcfd2cae79bf8e 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 582077e0ce6acf3abf90499f104b2e4bd7d83344..d2229477a6af07787397800dcdf375444583d4fb 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 33dd989ba59b7a8cce91a5fef69abbdff05e1129..bc4885f1dedf5fa8e3fa6509f0c6fe659e80bfd1 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 fbe1402c5553c98d3efaada1484fa612147a6b65..c2dd434f371d65d4cffb5969630c08ec82892971 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;