flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [3/5] git commit: Fix various deprecation warnings in tests
Date Tue, 14 Oct 2014 13:53:43 GMT
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 <sewen@apache.org>
Authored: Mon Oct 13 20:24:35 2014 +0200
Committer: Stephan Ewen <sewen@apache.org>
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 <T> TypeSerializerFactory<?> createSerializer(TypeInformation<T>
typeInfo) {
 		TypeSerializer<T> serializer = typeInfo.createSerializer();
@@ -287,8 +286,6 @@ public class JavaApiPostPass implements OptimizerPostPass {
 		}
 	}
 	
-	
-	@SuppressWarnings("unchecked")
 	private static <T> TypeComparatorFactory<?> createComparator(TypeInformation<T>
typeInfo, FieldList keys, boolean[] sortOrder) {
 		
 		TypeComparator<T> 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.
  * </ul>
  */
-@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;
  *   <li> Ticket 158
  * </ul>
  */
-@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 {
 


Mime
View raw message