Return-Path: X-Original-To: apmail-flink-commits-archive@minotaur.apache.org Delivered-To: apmail-flink-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 562331765A for ; Tue, 14 Oct 2014 13:54:13 +0000 (UTC) Received: (qmail 35417 invoked by uid 500); 14 Oct 2014 13:54:13 -0000 Delivered-To: apmail-flink-commits-archive@flink.apache.org Received: (qmail 35392 invoked by uid 500); 14 Oct 2014 13:54:13 -0000 Mailing-List: contact commits-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list commits@flink.incubator.apache.org Received: (qmail 35382 invoked by uid 99); 14 Oct 2014 13:54:13 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Oct 2014 13:54:13 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 14 Oct 2014 13:53:45 +0000 Received: (qmail 34894 invoked by uid 99); 14 Oct 2014 13:53:41 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Oct 2014 13:53:41 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 4CDF992D6AF; Tue, 14 Oct 2014 13:53:41 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sewen@apache.org To: commits@flink.incubator.apache.org Date: Tue, 14 Oct 2014 13:53:43 -0000 Message-Id: <3f8322eac03a4e55b25580c884772470@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [3/5] git commit: Fix various deprecation warnings in tests X-Virus-Checked: Checked by ClamAV on apache.org Fix various deprecation warnings in tests Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/7a5e3e40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/7a5e3e40 Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/7a5e3e40 Branch: refs/heads/master Commit: 7a5e3e406eadb35fcc66f71c827d618dbbcc4415 Parents: 624fe95 Author: Stephan Ewen Authored: Mon Oct 13 20:24:35 2014 +0200 Committer: Stephan Ewen Committed: Tue Oct 14 14:41:22 2014 +0200 ---------------------------------------------------------------------- .../org/apache/flink/compiler/postpass/JavaApiPostPass.java | 3 --- .../org/apache/flink/compiler/AdditionalOperatorsTest.java | 2 +- .../org/apache/flink/compiler/BranchingPlansCompilerTest.java | 4 ++-- .../test/java/org/apache/flink/compiler/CompilerTestBase.java | 1 + .../src/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 ++---- .../src/test/java/org/apache/flink/compiler/ReduceAllTest.java | 3 +-- .../apache/flink/compiler/UnionPropertyPropagationTest.java | 4 ++-- .../flink/compiler/WorksetIterationsRecordApiCompilerTest.java | 1 + .../java/org/apache/flink/compiler/util/DummyCoGroupStub.java | 1 + .../java/org/apache/flink/compiler/util/DummyCrossStub.java | 1 + .../java/org/apache/flink/compiler/util/DummyInputFormat.java | 1 - .../java/org/apache/flink/compiler/util/DummyMatchStub.java | 2 +- .../flink/compiler/util/DummyNonPreservingMatchStub.java | 3 +-- .../test/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 + .../flink/test/broadcastvars/BroadcastVarsNepheleITCase.java | 1 + .../org/apache/flink/test/cancelling/MapCancelingITCase.java | 1 + .../apache/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 +- .../apache/flink/test/failingPrograms/TaskFailureITCase.java | 2 +- .../flink/test/iterative/CoGroupConnectedComponentsITCase.java | 1 + .../iterative/ConnectedComponentsWithDeferredUpdateITCase.java | 1 + .../ConnectedComponentsWithSolutionSetFirstITCase.java | 1 + .../iterative/IterationTerminationWithTerminationTail.java | 1 + .../flink/test/iterative/IterationTerminationWithTwoTails.java | 2 +- .../flink/test/iterative/IterationWithAllReducerITCase.java | 2 +- .../flink/test/iterative/IterationWithChainingITCase.java | 1 + 37 files changed, 39 insertions(+), 39 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java ---------------------------------------------------------------------- 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 acce51f..2273461 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/AdditionalOperatorsTest.java ---------------------------------------------------------------------- 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 98e838b..cf32126 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 http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/BranchingPlansCompilerTest.java ---------------------------------------------------------------------- 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 7204b73..196f602 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 { http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/CompilerTestBase.java ---------------------------------------------------------------------- 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 f7d2fd6..c6a9b55 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/DOPChangeTest.java ---------------------------------------------------------------------- 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 98a9bb7..6eb4c49 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 { /** http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/GroupOrderTest.java ---------------------------------------------------------------------- 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 5009edd..1bb800d 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() { http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/HardPlansCompilationTest.java ---------------------------------------------------------------------- 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 6eb111f..4450dac 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 -> http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/ReduceAllTest.java ---------------------------------------------------------------------- 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 5b799e5..1c99f79 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 http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/UnionPropertyPropagationTest.java ---------------------------------------------------------------------- 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 cb25a24..0404d50 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 http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/WorksetIterationsRecordApiCompilerTest.java ---------------------------------------------------------------------- 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 62c5d84..8c2d584 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCoGroupStub.java ---------------------------------------------------------------------- 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 3528eda..ffca567 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyCrossStub.java ---------------------------------------------------------------------- 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 bb2e724..f987d7c 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyInputFormat.java ---------------------------------------------------------------------- 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 344ebae..d54f108 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyMatchStub.java ---------------------------------------------------------------------- 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 0b7333d..902fce7 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/DummyNonPreservingMatchStub.java ---------------------------------------------------------------------- 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 234b676..144326f 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityMap.java ---------------------------------------------------------------------- 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 35674f3..0a80a7f 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-compiler/src/test/java/org/apache/flink/compiler/util/IdentityReduce.java ---------------------------------------------------------------------- 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 28dc946..b98500d 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorIterativeITCase.java ---------------------------------------------------------------------- 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 c2eb7b2..51cbd87 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 { http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastBranchingITCase.java ---------------------------------------------------------------------- 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 fc12926..daf5181 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java ---------------------------------------------------------------------- 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 31cca7b..944d999 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/cancelling/MapCancelingITCase.java ---------------------------------------------------------------------- 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 e082d00..9bbd282 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/cancelling/MatchJoinCancelingITCase.java ---------------------------------------------------------------------- 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 c6391ee..8a324a3 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/KMeansSingleStepTest.java ---------------------------------------------------------------------- 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 422a8ff..b1f9a79 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/RelationalQueryCompilerTest.java ---------------------------------------------------------------------- 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 c429655..11970a3 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/compiler/examples/WordCountCompilerTest.java ---------------------------------------------------------------------- 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 b345a45..cc96f92 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 { /** http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/ConnectedComponentsTest.java ---------------------------------------------------------------------- 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 83afb5e..2a43c64 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java ---------------------------------------------------------------------- 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 d7d429a..2bf2851 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/distributedCache/DistributedCacheTest.java ---------------------------------------------------------------------- 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 5ca89cd..29cc93d 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" http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountNestedPOJOITCase.java ---------------------------------------------------------------------- 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 bdd5a7d..f1e75fe 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/failingPrograms/TaskFailureITCase.java ---------------------------------------------------------------------- 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 97eec6a..551b8ad 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/CoGroupConnectedComponentsITCase.java ---------------------------------------------------------------------- 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 8aac83d..60328fe 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithDeferredUpdateITCase.java ---------------------------------------------------------------------- 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 edd9e8c..0b1e372 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 { http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/ConnectedComponentsWithSolutionSetFirstITCase.java ---------------------------------------------------------------------- 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 51ebf83..33650c5 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; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTerminationTail.java ---------------------------------------------------------------------- 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 3a1d4c3..7b6cf11 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java ---------------------------------------------------------------------- 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 9732549..f05b1c2 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithAllReducerITCase.java ---------------------------------------------------------------------- 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 6124275..3116a9d 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"; http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7a5e3e40/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationWithChainingITCase.java ---------------------------------------------------------------------- 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 06c0f02..ef8f343 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 {