From 7a5e3e406eadb35fcc66f71c827d618dbbcc4415 Mon Sep 17 00:00:00 2001 From: Stephan Ewen Date: Mon, 13 Oct 2014 20:24:35 +0200 Subject: [PATCH] Fix various deprecation warnings in tests --- .../org/apache/flink/compiler/postpass/JavaApiPostPass.java | 3 --- .../org/apache/flink/compiler/AdditionalOperatorsTest.java | 2 +- .../apache/flink/compiler/BranchingPlansCompilerTest.java | 4 ++-- .../java/org/apache/flink/compiler/CompilerTestBase.java | 1 + .../test/java/org/apache/flink/compiler/DOPChangeTest.java | 3 +-- .../test/java/org/apache/flink/compiler/GroupOrderTest.java | 6 ++---- .../org/apache/flink/compiler/HardPlansCompilationTest.java | 6 ++---- .../test/java/org/apache/flink/compiler/ReduceAllTest.java | 3 +-- .../apache/flink/compiler/UnionPropertyPropagationTest.java | 4 ++-- .../compiler/WorksetIterationsRecordApiCompilerTest.java | 1 + .../org/apache/flink/compiler/util/DummyCoGroupStub.java | 1 + .../java/org/apache/flink/compiler/util/DummyCrossStub.java | 1 + .../org/apache/flink/compiler/util/DummyInputFormat.java | 1 - .../java/org/apache/flink/compiler/util/DummyMatchStub.java | 2 +- .../flink/compiler/util/DummyNonPreservingMatchStub.java | 3 +-- .../java/org/apache/flink/compiler/util/IdentityMap.java | 2 +- .../java/org/apache/flink/compiler/util/IdentityReduce.java | 1 + .../flink/test/accumulators/AccumulatorIterativeITCase.java | 1 + .../flink/test/broadcastvars/BroadcastBranchingITCase.java | 1 + .../test/broadcastvars/BroadcastVarsNepheleITCase.java | 1 + .../apache/flink/test/cancelling/MapCancelingITCase.java | 1 + .../flink/test/cancelling/MatchJoinCancelingITCase.java | 1 + .../flink/test/compiler/examples/KMeansSingleStepTest.java | 2 +- .../test/compiler/examples/RelationalQueryCompilerTest.java | 1 + .../flink/test/compiler/examples/WordCountCompilerTest.java | 4 +--- .../test/compiler/iterations/ConnectedComponentsTest.java | 4 +--- .../flink/test/compiler/iterations/IterativeKMeansTest.java | 2 +- .../flink/test/distributedCache/DistributedCacheTest.java | 3 +-- .../test/exampleJavaPrograms/WordCountNestedPOJOITCase.java | 2 +- .../flink/test/failingPrograms/TaskFailureITCase.java | 2 +- .../test/iterative/CoGroupConnectedComponentsITCase.java | 1 + .../ConnectedComponentsWithDeferredUpdateITCase.java | 1 + .../ConnectedComponentsWithSolutionSetFirstITCase.java | 1 + .../iterative/IterationTerminationWithTerminationTail.java | 1 + .../test/iterative/IterationTerminationWithTwoTails.java | 2 +- .../flink/test/iterative/IterationWithAllReducerITCase.java | 2 +- .../flink/test/iterative/IterationWithChainingITCase.java | 1 + 37 files changed, 39 insertions(+), 39 deletions(-) diff --git a/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java b/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java index acce51fdf70..22734612d59 100644 --- a/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java +++ b/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java @@ -275,7 +275,6 @@ public class JavaApiPostPass implements OptimizerPostPass { throw new RuntimeException("Wrong operator type found in post pass."); } } - private static TypeSerializerFactory createSerializer(TypeInformation typeInfo) { TypeSerializer serializer = typeInfo.createSerializer(); @@ -287,8 +286,6 @@ public class JavaApiPostPass implements OptimizerPostPass { } } - - @SuppressWarnings("unchecked") private static TypeComparatorFactory createComparator(TypeInformation typeInfo, FieldList keys, boolean[] sortOrder) { TypeComparator comparator; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/AdditionalOperatorsTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/AdditionalOperatorsTest.java index 98e838b3266..cf32126b993 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/AdditionalOperatorsTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/AdditionalOperatorsTest.java @@ -43,7 +43,7 @@ import org.junit.Test; * Tests that validate optimizer choices when using operators that are requesting certain specific execution * strategies. */ -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class AdditionalOperatorsTest extends CompilerTestBase { @Test diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/BranchingPlansCompilerTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/BranchingPlansCompilerTest.java index 7204b73b73c..196f602089e 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/BranchingPlansCompilerTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/BranchingPlansCompilerTest.java @@ -58,7 +58,7 @@ import org.apache.flink.compiler.util.IdentityReduce; import org.apache.flink.types.IntValue; import org.apache.flink.types.LongValue; -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class BranchingPlansCompilerTest extends CompilerTestBase { @@ -358,7 +358,7 @@ public class BranchingPlansCompilerTest extends CompilerTestBase { } } - @SuppressWarnings({ "unchecked", "deprecation" }) + @SuppressWarnings("unchecked") @Test public void testBranchEachContractType() { try { diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/CompilerTestBase.java b/flink-compiler/src/test/java/org/apache/flink/compiler/CompilerTestBase.java index f7d2fd6ea35..c6a9b55c517 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/CompilerTestBase.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/CompilerTestBase.java @@ -44,6 +44,7 @@ import org.junit.Before; /** * */ +@SuppressWarnings("deprecation") public abstract class CompilerTestBase implements java.io.Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/DOPChangeTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/DOPChangeTest.java index 98a9bb78a26..6eb4c49de2b 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/DOPChangeTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/DOPChangeTest.java @@ -20,7 +20,6 @@ package org.apache.flink.compiler; import org.junit.Assert; - import org.apache.flink.api.common.Plan; import org.apache.flink.api.java.record.operators.FileDataSink; import org.apache.flink.api.java.record.operators.FileDataSource; @@ -52,7 +51,7 @@ import org.junit.Test; * parallelism between tasks is increased or decreased. * */ -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class DOPChangeTest extends CompilerTestBase { /** diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/GroupOrderTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/GroupOrderTest.java index 5009eddb312..1bb800decbd 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/GroupOrderTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/GroupOrderTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler; import static org.junit.Assert.fail; @@ -48,13 +47,12 @@ import org.apache.flink.types.StringValue; import org.junit.Assert; import org.junit.Test; - /** * This test case has been created to validate that correct strategies are used if orders within groups are * requested. */ -@SuppressWarnings("serial") -public class GroupOrderTest extends CompilerTestBase { +@SuppressWarnings({"serial", "deprecation"}) +public class GroupOrderTest extends CompilerTestBase { @Test public void testReduceWithGroupOrder() { diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/HardPlansCompilationTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/HardPlansCompilationTest.java index 6eb111f0e11..4450dacb1ed 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/HardPlansCompilationTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/HardPlansCompilationTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler; import org.apache.flink.api.common.Plan; @@ -41,9 +40,8 @@ import org.junit.Test; *
  • Ticket 158 * */ -@SuppressWarnings("serial") -public class HardPlansCompilationTest extends CompilerTestBase -{ +@SuppressWarnings({"serial", "deprecation"}) +public class HardPlansCompilationTest extends CompilerTestBase { /** * Source -> Map -> Reduce -> Cross -> Reduce -> Cross -> Reduce -> diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/ReduceAllTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/ReduceAllTest.java index 5b799e5860d..1c99f79a096 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/ReduceAllTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/ReduceAllTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler; import static org.junit.Assert.fail; @@ -37,7 +36,7 @@ import org.junit.Test; * This test case has been created to validate a bug that occurred when * the ReduceOperator was used without a grouping key. */ -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class ReduceAllTest extends CompilerTestBase { @Test diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/UnionPropertyPropagationTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/UnionPropertyPropagationTest.java index cb25a245676..0404d507645 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/UnionPropertyPropagationTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/UnionPropertyPropagationTest.java @@ -49,10 +49,10 @@ import org.apache.flink.compiler.util.DummyOutputFormat; import org.apache.flink.compiler.util.IdentityReduce; -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class UnionPropertyPropagationTest extends CompilerTestBase { - @SuppressWarnings({ "deprecation", "unchecked" }) + @SuppressWarnings("unchecked") @Test public void testUnionPropertyOldApiPropagation() { // construct the plan diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/WorksetIterationsRecordApiCompilerTest.java b/flink-compiler/src/test/java/org/apache/flink/compiler/WorksetIterationsRecordApiCompilerTest.java index 62c5d844a47..8c2d584cc70 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/WorksetIterationsRecordApiCompilerTest.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/WorksetIterationsRecordApiCompilerTest.java @@ -51,6 +51,7 @@ import org.junit.Test; * Tests that validate optimizer choices when using operators that are requesting certain specific execution * strategies. */ +@SuppressWarnings("deprecation") public class WorksetIterationsRecordApiCompilerTest extends CompilerTestBase { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCoGroupStub.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCoGroupStub.java index 3528edaac0f..ffca567cd33 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCoGroupStub.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCoGroupStub.java @@ -25,6 +25,7 @@ import org.apache.flink.api.java.record.functions.CoGroupFunction; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class DummyCoGroupStub extends CoGroupFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCrossStub.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCrossStub.java index bb2e724bf10..f987d7c858d 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCrossStub.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCrossStub.java @@ -21,6 +21,7 @@ package org.apache.flink.compiler.util; import org.apache.flink.api.java.record.functions.CrossFunction; import org.apache.flink.types.Record; +@SuppressWarnings("deprecation") public class DummyCrossStub extends CrossFunction { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyInputFormat.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyInputFormat.java index 344ebaed83d..d54f10864f9 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyInputFormat.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyInputFormat.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler.util; import org.apache.flink.api.common.io.statistics.BaseStatistics; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyMatchStub.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyMatchStub.java index 0b7333d752f..902fce7c61d 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyMatchStub.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyMatchStub.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler.util; import java.io.Serializable; @@ -26,6 +25,7 @@ import org.apache.flink.api.java.record.functions.FunctionAnnotation.ConstantFie import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") @ConstantFieldsFirstExcept({}) public class DummyMatchStub extends JoinFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyNonPreservingMatchStub.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyNonPreservingMatchStub.java index 234b676aa60..144326f4d7d 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyNonPreservingMatchStub.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyNonPreservingMatchStub.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler.util; import java.io.Serializable; @@ -25,7 +24,7 @@ import org.apache.flink.api.java.record.functions.JoinFunction; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; - +@SuppressWarnings("deprecation") public class DummyNonPreservingMatchStub extends JoinFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityMap.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityMap.java index 35674f3d0e0..0a80a7fb842 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityMap.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityMap.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.compiler.util; import java.io.Serializable; @@ -26,6 +25,7 @@ import org.apache.flink.api.java.record.functions.FunctionAnnotation.ConstantFie import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") @ConstantFieldsExcept({}) public final class IdentityMap extends MapFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityReduce.java b/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityReduce.java index 28dc9461655..b98500da17b 100644 --- a/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityReduce.java +++ b/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityReduce.java @@ -26,6 +26,7 @@ import org.apache.flink.api.java.record.functions.FunctionAnnotation.ConstantFie import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") @ConstantFieldsExcept({}) public final class IdentityReduce extends ReduceFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorIterativeITCase.java b/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorIterativeITCase.java index c2eb7b2076a..51cbd874a9c 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorIterativeITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorIterativeITCase.java @@ -45,6 +45,7 @@ import org.junit.runners.Parameterized.Parameters; /** * To be finished !!! Didn't test with iterations yet;-( */ +@SuppressWarnings("deprecation") @RunWith(Parameterized.class) public class AccumulatorIterativeITCase extends RecordAPITestBase { diff --git a/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastBranchingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastBranchingITCase.java index fc1292655d9..daf5181adbf 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastBranchingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastBranchingITCase.java @@ -36,6 +36,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class BroadcastBranchingITCase extends RecordAPITestBase { private static final String SC1_ID_ABC = "1 61 6 29\n2 7 13 10\n3 8 13 27\n"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java b/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java index 31cca7bf7f8..944d99955c5 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java @@ -53,6 +53,7 @@ import org.apache.flink.types.Record; import org.apache.flink.util.Collector; import org.junit.Assert; +@SuppressWarnings("deprecation") public class BroadcastVarsNepheleITCase extends RecordAPITestBase { private static final long SEED_POINTS = 0xBADC0FFEEBEEFL; diff --git a/flink-tests/src/test/java/org/apache/flink/test/cancelling/MapCancelingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/cancelling/MapCancelingITCase.java index e082d006fb5..9bbd282c21d 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/cancelling/MapCancelingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/cancelling/MapCancelingITCase.java @@ -31,6 +31,7 @@ import org.apache.flink.test.recordJobs.util.InfiniteIntegerInputFormat; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class MapCancelingITCase extends CancellingTestBase { private static final int DOP = 4; diff --git a/flink-tests/src/test/java/org/apache/flink/test/cancelling/MatchJoinCancelingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/cancelling/MatchJoinCancelingITCase.java index c6391ee385d..8a324a3734c 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/cancelling/MatchJoinCancelingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/cancelling/MatchJoinCancelingITCase.java @@ -35,6 +35,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class MatchJoinCancelingITCase extends CancellingTestBase { private static final int DOP = 4; diff --git a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/KMeansSingleStepTest.java b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/KMeansSingleStepTest.java index 422a8ffe604..b1f9a79dd81 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/KMeansSingleStepTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/KMeansSingleStepTest.java @@ -37,7 +37,7 @@ import org.apache.flink.test.recordJobs.kmeans.KMeansSingleStep; import org.junit.Assert; import org.junit.Test; - +@SuppressWarnings("deprecation") public class KMeansSingleStepTest extends CompilerTestBase { private static final String DATAPOINTS = "Data Points"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/RelationalQueryCompilerTest.java b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/RelationalQueryCompilerTest.java index c4296552b3b..11970a362bb 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/RelationalQueryCompilerTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/RelationalQueryCompilerTest.java @@ -41,6 +41,7 @@ import org.junit.Test; /** * Tests TPCH Q3 (simplified) under various input conditions. */ +@SuppressWarnings("deprecation") public class RelationalQueryCompilerTest extends CompilerTestBase { private static final String ORDERS = "Orders"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/WordCountCompilerTest.java b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/WordCountCompilerTest.java index b345a45951c..cc96f920a86 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/WordCountCompilerTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/WordCountCompilerTest.java @@ -47,9 +47,7 @@ import org.apache.flink.types.StringValue; import org.junit.Assert; import org.junit.Test; -/** - * - */ +@SuppressWarnings("deprecation") public class WordCountCompilerTest extends CompilerTestBase { /** diff --git a/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/ConnectedComponentsTest.java b/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/ConnectedComponentsTest.java index 83afb5e4f82..2a43c640b39 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/ConnectedComponentsTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/ConnectedComponentsTest.java @@ -55,9 +55,7 @@ import org.apache.flink.util.Collector; import org.junit.Assert; import org.junit.Test; -/** - * - */ +@SuppressWarnings("deprecation") public class ConnectedComponentsTest extends CompilerTestBase { private static final String VERTEX_SOURCE = "Vertices"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java b/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java index d7d429af239..2bf2851938f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java @@ -42,7 +42,7 @@ import org.apache.flink.test.recordJobs.kmeans.KMeansBroadcast; import org.junit.Assert; import org.junit.Test; - +@SuppressWarnings("deprecation") public class IterativeKMeansTest extends CompilerTestBase { private static final String DATAPOINTS = "Data Points"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/distributedCache/DistributedCacheTest.java b/flink-tests/src/test/java/org/apache/flink/test/distributedCache/DistributedCacheTest.java index 5ca89cd1fd3..29cc93d572a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/distributedCache/DistributedCacheTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/distributedCache/DistributedCacheTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.distributedCache; import java.io.BufferedReader; @@ -42,10 +41,10 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; - /** * Test the distributed cache via using the cache file to do a selection on the input */ +@SuppressWarnings("deprecation") public class DistributedCacheTest extends RecordAPITestBase { public static final String cacheData = "machen\n" + "zeit\n" + "heerscharen\n" + "keiner\n" + "meine\n" diff --git a/flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountNestedPOJOITCase.java b/flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountNestedPOJOITCase.java index bdd5a7dc73a..f1e75febbc3 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountNestedPOJOITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountNestedPOJOITCase.java @@ -30,7 +30,7 @@ import org.apache.flink.util.Collector; import java.io.Serializable; import java.util.Date; - +@SuppressWarnings("serial") public class WordCountNestedPOJOITCase extends JavaProgramTestBase implements Serializable { private static final long serialVersionUID = 1L; protected String textPath; diff --git a/flink-tests/src/test/java/org/apache/flink/test/failingPrograms/TaskFailureITCase.java b/flink-tests/src/test/java/org/apache/flink/test/failingPrograms/TaskFailureITCase.java index 97eec6ac497..551b8adbe7e 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/failingPrograms/TaskFailureITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/failingPrograms/TaskFailureITCase.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.failingPrograms; import org.apache.flink.api.common.Plan; @@ -40,6 +39,7 @@ import org.apache.flink.util.Collector; /** * Tests whether the system recovers from a runtime exception from the user code. */ +@SuppressWarnings("deprecation") public class TaskFailureITCase extends FailingTestBase { private static final int DOP = 4; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/CoGroupConnectedComponentsITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/CoGroupConnectedComponentsITCase.java index 8aac83db3be..60328fe8422 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/CoGroupConnectedComponentsITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/CoGroupConnectedComponentsITCase.java @@ -43,6 +43,7 @@ import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class CoGroupConnectedComponentsITCase extends RecordAPITestBase { private static final long SEED = 0xBADC0FFEEBEEFL; 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 edd9e8c9023..0b1e37239d4 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 @@ -47,6 +47,7 @@ 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 RecordAPITestBase { 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 51ebf83f287..33650c51e95 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 @@ -45,6 +45,7 @@ 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 RecordAPITestBase { private static final long SEED = 0xBADC0FFEEBEEFL; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTerminationTail.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTerminationTail.java index 3a1d4c37b29..7b6cf11654a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTerminationTail.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTerminationTail.java @@ -37,6 +37,7 @@ import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; import org.junit.Assert; +@SuppressWarnings("deprecation") public class IterationTerminationWithTerminationTail extends RecordAPITestBase { private static final String INPUT = "1\n" + "2\n" + "3\n" + "4\n" + "5\n"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java index 973254946f5..f05b1c25cb6 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java @@ -37,7 +37,7 @@ import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; import org.junit.Assert; - +@SuppressWarnings("deprecation") public class IterationTerminationWithTwoTails extends RecordAPITestBase { private static final String INPUT = "1\n" + "2\n" + "3\n" + "4\n" + "5\n"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithAllReducerITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithAllReducerITCase.java index 612427546ce..3116a9df06a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithAllReducerITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithAllReducerITCase.java @@ -35,7 +35,7 @@ import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; import org.junit.Assert; - +@SuppressWarnings("deprecation") public class IterationWithAllReducerITCase extends RecordAPITestBase { private static final String INPUT = "1\n" + "1\n" + "1\n" + "1\n" + "1\n" + "1\n" + "1\n" + "1\n"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithChainingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithChainingITCase.java index 06c0f029ac2..ef8f3430fa6 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithChainingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithChainingITCase.java @@ -41,6 +41,7 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameters; +@SuppressWarnings("deprecation") @RunWith(Parameterized.class) public class IterationWithChainingITCase extends RecordAPITestBase { -- GitLab