diff --git a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java index 3045031efa5962e9dcbbaf130ed513add668681e..9c861ed07a15cf06cb64b55abc711b46fdf9f71a 100755 --- a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java +++ b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java @@ -71,7 +71,7 @@ public abstract class TableInputFormat implements InputFormat The type of the build side records. + * @param The type of the probe side records. */ public class HashPartition extends AbstractPagedInputView implements SeekableDataInputView { @@ -117,7 +117,6 @@ public class HashPartition extends AbstractPagedInputView implements See * @param recursionLevel The recursion level - zero for partitions from the initial build, n + 1 for * partitions that are created from spilled partition with recursion level n. * @param initialBuffer The initial buffer for this partition. - * @param writeBehindBuffers The queue from which to pop buffers for writing, once the partition is spilled. */ HashPartition(TypeSerializer buildSideAccessors, TypeSerializer probeSideAccessors, int partitionNumber, int recursionLevel, MemorySegment initialBuffer, MemorySegmentSource memSource, diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java index e99265be62b7e1fbe5969abbb460cb2e0ab27374..ca3eb4ebdc353337fc61236c93e5a012720ba8dd 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java @@ -35,7 +35,7 @@ import org.apache.flink.runtime.memorymanager.ListMemorySegmentSource; /** * In-memory partition with overflow buckets for {@link CompactingHashTable} * - * @param T record type + * @param record type */ public class InMemoryPartition { diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java index 1bbf24630ac85ffae15e83b9bf6aac16150d7f58..67f1ea25ea6ea23b5a6fecba637e5d4a90a1cb34 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java @@ -1129,9 +1129,6 @@ public class MutableHashTable implements MemorySegmentSource { * may free new buffers then. * * @return The next buffer to be used by the hash-table, or null, if no buffer remains. - * @throws IOException Thrown, if the thread is interrupted while grabbing the next buffer. The I/O - * exception replaces the InterruptedException to consolidate the exception - * signatures. */ final MemorySegment getNextBuffer() { // check if the list directly offers memory diff --git a/flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java b/flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java index 97cbd5ca981d2f898de6b35be7ef15bdac9b02ae..2ee10092b590051064c27cd7f82ec141404f6d18 100644 --- a/flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java +++ b/flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java @@ -71,7 +71,7 @@ public class ScalaCsvInputFormat extends GenericCsvInputFor TupleTypeInfoBase tupleType = (TupleTypeInfoBase) typeInfo; serializer = (TupleSerializerBase)tupleType.createSerializer(); - Class[] classes = new Class[tupleType.getArity()]; + Class[] classes = new Class[tupleType.getArity()]; for (int i = 0; i < tupleType.getArity(); i++) { classes[i] = tupleType.getTypeAt(i).getTypeClass(); } diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java index 4a36fb8e820c144f1d8b30c72e424d2172dc82dc..60a0d891783be8c5ad32c14ba13afe43d61b362c 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java @@ -94,6 +94,7 @@ public class GroupReduceITCase extends JavaProgramTestBase { return toParameterList(tConfigs); } + @SuppressWarnings("unused") private static class GroupReduceProgs { public static String runProgram(int progId, String resultPath, boolean collectionExecution) throws Exception { @@ -555,6 +556,7 @@ public class GroupReduceITCase extends JavaProgramTestBase { DataSet reduceDs = ds.groupBy("hadoopFan", "theTuple.*") // full tuple selection .reduceGroup(new GroupReduceFunction() { private static final long serialVersionUID = 1L; + @Override public void reduce(Iterable values, Collector out) diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ReduceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ReduceITCase.java index 20cbb4ab26a02d285d8b496e2f6caa73e303320f..1fcacb9d4663b806ffaf2ee903b3b7549067ff35 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ReduceITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ReduceITCase.java @@ -45,6 +45,7 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameters; +@SuppressWarnings("serial") @RunWith(Parameterized.class) public class ReduceITCase extends JavaProgramTestBase { diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java index 731f036fa0df854d0d618ddadaf066f5921f8d24..1f812d995aa04d31558b0f6706cf55f41ed163b7 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java +++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java @@ -422,8 +422,10 @@ public class CollectionDataSets { } public static class FromTupleWithCTor extends FromTuple { - public FromTupleWithCTor() { - } + + private static final long serialVersionUID = 1L; + + public FromTupleWithCTor() {} public FromTupleWithCTor(int special, long tupleField) { this.special = special; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionSourceTest.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionSourceTest.java index 55ffeae6e05a3b9c9a4c7040af222fcddd5645a7..16d25176839e8f60c2e6c74c252ab42bb37b6dad 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionSourceTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionSourceTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobTests; import java.io.Serializable; @@ -40,6 +39,7 @@ import org.apache.flink.util.Collector; /** * test the collection and iterator data input using join operator */ +@SuppressWarnings("deprecation") public class CollectionSourceTest extends RecordAPITestBase { private static final int DOP = 4; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionValidationTest.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionValidationTest.java index 10736052f4167249f3e00527a60e36c8cf147d5a..1ce7a73a38840653add962bf6e29449c3ac08a56 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionValidationTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/CollectionValidationTest.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobTests; import org.apache.flink.api.java.record.operators.CollectionDataSource; @@ -29,6 +28,7 @@ import java.util.List; /** * Test the input field validation of CollectionDataSource */ +@SuppressWarnings("deprecation") public class CollectionValidationTest { @Test diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingITCase.java index 73aceed96465367a79067f7a3e9ff468e994ae08..f23b12944b4f7bd56e845c44ff87f7aa49d96000 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingITCase.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobTests; import java.util.ArrayList; @@ -35,6 +34,7 @@ import org.apache.flink.api.java.record.operators.FileDataSource; import org.apache.flink.test.util.RecordAPITestBase; import org.apache.flink.types.IntValue; +@SuppressWarnings("deprecation") public class GlobalSortingITCase extends RecordAPITestBase { private static final int NUM_RECORDS = 100000; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingMixedOrderITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingMixedOrderITCase.java index dfed3096ae02dff8a9dc7f4c41dac25751cdf966..b6b8b9d8b43794e9ea997175ee436aca05aa084b 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingMixedOrderITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GlobalSortingMixedOrderITCase.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobTests; import java.io.IOException; @@ -39,6 +38,7 @@ import org.apache.flink.test.util.RecordAPITestBase; import org.apache.flink.types.IntValue; import org.apache.flink.types.Key; +@SuppressWarnings("deprecation") public class GlobalSortingMixedOrderITCase extends RecordAPITestBase { private static final int NUM_RECORDS = 100000; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GroupOrderReduceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GroupOrderReduceITCase.java index 1f2d1dfc56b3a7eb391c05685777abad1ffe897e..368f9af837811b0561762337b12e2f2db75f0a27 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GroupOrderReduceITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/GroupOrderReduceITCase.java @@ -41,6 +41,7 @@ import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameters; @RunWith(Parameterized.class) +@SuppressWarnings("deprecation") public class GroupOrderReduceITCase extends RecordAPITestBase { private static final String INPUT = "1,3\n" + "2,1\n" + "5,1\n" + "3,1\n" + "1,8\n" + "1,9\n" + diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/WordCountUnionReduceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/WordCountUnionReduceITCase.java index 2c09636836ee775cc05f4499a011c6ae7a2966fe..52c815b071860cc3996357477c38ff29bb376d1e 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/WordCountUnionReduceITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/WordCountUnionReduceITCase.java @@ -41,6 +41,7 @@ import org.apache.flink.types.StringValue; * This test case is an adaption of issue #192 (and #124), which revealed problems with the union readers in Nephele. * The problems have been fixed with commit 1228a5e. Without this commit the test will deadlock. */ +@SuppressWarnings("deprecation") public class WordCountUnionReduceITCase extends RecordAPITestBase { private static final int MULTIPLY = 1000; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ComputeEdgeDegrees.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ComputeEdgeDegrees.java index c3c8205aa6cd6c2e887b2b24e920e9de7a5348a0..9ec8c7366c38c105bde024c1507a67af31760f66 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ComputeEdgeDegrees.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ComputeEdgeDegrees.java @@ -38,7 +38,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; - +@SuppressWarnings("deprecation") public class ComputeEdgeDegrees implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ConnectedComponentsWithCoGroup.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ConnectedComponentsWithCoGroup.java index 27c34c5789e0f96e3358cdefc25a6344142f0349..cc6fd01ce8ea2fdbec30d8c1ae3c2cf10f2dc9e2 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ConnectedComponentsWithCoGroup.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/ConnectedComponentsWithCoGroup.java @@ -41,10 +41,7 @@ import org.apache.flink.types.LongValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; - -/** - * - */ +@SuppressWarnings("deprecation") public class ConnectedComponentsWithCoGroup implements Program { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DanglingPageRank.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DanglingPageRank.java index 049c9c4a1052504297b6ebf0d5d3fcad5bdde1f7..c87dd643fef7c58e968680ad90c526b71514c1ec 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DanglingPageRank.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DanglingPageRank.java @@ -36,7 +36,7 @@ import org.apache.flink.test.recordJobs.graph.pageRankUtil.PageRankStatsAggregat import org.apache.flink.test.recordJobs.graph.pageRankUtil.PageWithRankOutFormat; import org.apache.flink.types.LongValue; - +@SuppressWarnings("deprecation") public class DanglingPageRank implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DeltaPageRankWithInitialDeltas.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DeltaPageRankWithInitialDeltas.java index bb5343e3d9b925ecd1ea6f0eccbad2d76dc6541c..81adbf565589a7887aef64ee00e8f9a82c47cb9e 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DeltaPageRankWithInitialDeltas.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/DeltaPageRankWithInitialDeltas.java @@ -41,6 +41,7 @@ import org.apache.flink.types.LongValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class DeltaPageRankWithInitialDeltas implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesOnEdgesWithDegrees.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesOnEdgesWithDegrees.java index 7e8f8588bcf7ececb135313a439e2a60a1deff86..b2328bae9537501bc7e3b20ebff4724662314949 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesOnEdgesWithDegrees.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesOnEdgesWithDegrees.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import java.io.Serializable; @@ -39,12 +38,12 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; - /** * An implementation of the triangle enumeration, which expects its input to * encode the degrees of the vertices. The algorithm selects the lower-degree vertex for the * enumeration of open triads. */ +@SuppressWarnings("deprecation") public class EnumTrianglesOnEdgesWithDegrees implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesRdfFoaf.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesRdfFoaf.java index 5662400d6ece47aec5291b9c110e12df3feb3903..ba8b54a8fb2dc06c7424dfb78385ab95abf6835c 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesRdfFoaf.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesRdfFoaf.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import java.io.Serializable; @@ -52,6 +51,7 @@ import org.apache.flink.util.Collector; * The algorithm was published as MapReduce job by J. Cohen in "Graph Twiddling in a MapReduce World". * The Pact version was described in "MapReduce and PACT - Comparing Data Parallel Programming Models" (BTW 2011). */ +@SuppressWarnings("deprecation") public class EnumTrianglesRdfFoaf implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java index 66990308b0fd3d4df10e181535081dea83c44ef7..dc521584236acb42ba862ebe832fbedf0c565572 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import org.apache.flink.api.common.Plan; @@ -43,6 +42,7 @@ import org.apache.flink.types.IntValue; * to compute the degrees of the vertices and to select the lower-degree vertex for the * enumeration of open triads. */ +@SuppressWarnings("deprecation") public class EnumTrianglesWithDegrees implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/PairwiseSP.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/PairwiseSP.java index 0886dbb18a44b5d64f6c0308e6adad43ea9bc36f..55e2f57a207168dbbb9a8052c60cbc26980d3589 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/PairwiseSP.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/PairwiseSP.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import java.io.IOException; @@ -58,9 +57,8 @@ import org.apache.flink.util.Collector; * 2) The programs text-serialization for paths (see @see PathInFormat and @see PathOutFormat). * * The RDF input format is used if the 4th parameter of the getPlan() method is set to "true". If set to "false" the path input format is used. - * - * */ +@SuppressWarnings("deprecation") public class PairwiseSP implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/SimplePageRank.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/SimplePageRank.java index ccd321368a31a74fb238c33bc58f1738c44f74c5..3abf743f7a47498b2700d0a83c173b398d0b70e5 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/SimplePageRank.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/SimplePageRank.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import java.io.Serializable; @@ -44,7 +43,7 @@ import org.apache.flink.types.LongValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; - +@SuppressWarnings("deprecation") public class SimplePageRank implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java index 2f6f74031f9719979c9c0c25a612a4d9eb165d4a..0dbb20a770a90acd93b5b7bbcd0ca58fb59c290a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/WorksetConnectedComponents.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph; import java.io.Serializable; @@ -43,9 +42,7 @@ import org.apache.flink.types.LongValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -/** - * - */ +@SuppressWarnings("deprecation") public class WorksetConnectedComponents implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductCoGroup.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductCoGroup.java index a1bcba6d4fa4f5d168de2a659a4356ac0931f3b0..d4f7a5c6793e9c3bdc1ed55dcd08c369299398c5 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductCoGroup.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductCoGroup.java @@ -37,6 +37,7 @@ import org.apache.flink.util.Collector; * INPUT = (pageId, currentRank, dangling), (pageId, partialRank). * OUTPUT = (pageId, newRank, dangling) */ +@SuppressWarnings("deprecation") @ConstantFieldsFirst(0) public class DotProductCoGroup extends CoGroupFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductMatch.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductMatch.java index b52d9eb00ae1799e3ff3808e64effde6da362258..339cef52aba85401d663af4b81d97c74610c57af 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductMatch.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/pageRankUtil/DotProductMatch.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.graph.pageRankUtil; import java.io.Serializable; @@ -32,6 +31,7 @@ import org.apache.flink.util.Collector; * INPUT = (pageId, rank, dangling), (pageId, neighbors-list). * OUTPUT = (targetPageId, partialRank) */ +@SuppressWarnings("deprecation") public class DotProductMatch extends JoinFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansCross.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansCross.java index d5d71ad1d0cb981aa7653effbd3a3ea0503d238f..4069f9a161cf405220ae4364b9957b0d87c87587 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansCross.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansCross.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.kmeans; import java.util.ArrayList; @@ -38,7 +37,7 @@ import org.apache.flink.test.recordJobs.kmeans.udfs.PointOutFormat; import org.apache.flink.test.recordJobs.kmeans.udfs.RecomputeClusterCenter; import org.apache.flink.types.IntValue; - +@SuppressWarnings("deprecation") public class KMeansCross implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansSingleStep.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansSingleStep.java index f937ca8243125bc0ee3664c2f07bc43ec0510234..bdf74663976ac8ebff85966eeb8fab144e134452 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansSingleStep.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/KMeansSingleStep.java @@ -16,10 +16,8 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.kmeans; - import java.io.IOException; import java.util.ArrayList; import java.util.Collection; @@ -47,7 +45,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.Value; import org.apache.flink.util.Collector; - +@SuppressWarnings("deprecation") public class KMeansSingleStep implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistance.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistance.java index 16267f65512eccfa05d3db8c5acbe48e49f93e3d..ee33113d046b55bdb835b2db09c9503041867fa2 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistance.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistance.java @@ -30,6 +30,7 @@ import org.apache.flink.types.Record; * Cross PACT computes the distance of all data points to all cluster * centers. */ +@SuppressWarnings("deprecation") @ConstantFieldsFirst({0,1}) public class ComputeDistance extends CrossFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistanceParameterized.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistanceParameterized.java index fea14689edf519cb8cc7124369d76a8148823dcd..78b60efcba87d9a64a06d850d1c693d80d83a2c6 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistanceParameterized.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/ComputeDistanceParameterized.java @@ -33,6 +33,7 @@ import org.apache.flink.util.Collector; * Cross PACT computes the distance of all data points to all cluster * centers. */ +@SuppressWarnings("deprecation") @ConstantFieldsFirst({0,1}) public class ComputeDistanceParameterized extends MapFunction implements Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/FindNearestCenter.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/FindNearestCenter.java index 9e7fcf0abb320027d953476fe23aa5d0104acfa1..1e893ce80f9a5e0791403378f93d8d800ef49d0e 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/FindNearestCenter.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/FindNearestCenter.java @@ -33,6 +33,7 @@ import org.apache.flink.util.Collector; * Reduce PACT determines the closes cluster center for a data point. This * is a minimum aggregation. Hence, a Combiner can be easily implemented. */ +@SuppressWarnings("deprecation") @Combinable @ConstantFields(1) public class FindNearestCenter extends ReduceFunction implements Serializable { diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/RecomputeClusterCenter.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/RecomputeClusterCenter.java index fd842c3730bd795083f4801dac49f87784df2836..89e222b64c93d33b8489f1aadbc3cc22f25e223f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/RecomputeClusterCenter.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/RecomputeClusterCenter.java @@ -37,6 +37,7 @@ import org.apache.flink.util.Collector; * 0: clusterID * 1: clusterVector */ +@SuppressWarnings("deprecation") @Combinable @ConstantFields(0) public class RecomputeClusterCenter extends ReduceFunction implements Serializable { diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/MergeOnlyJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/MergeOnlyJoin.java index 8413a47c403490cab1202e69df84e3261722a5ff..74b8f4c74d61674a419495c4f7b41b42a1d2f9b4 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/MergeOnlyJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/MergeOnlyJoin.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import java.util.Iterator; @@ -37,6 +36,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class MergeOnlyJoin implements Program { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery1.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery1.java index 48103d1f2b83601dba153368ffe02e951bab7fb7..a3c4c74fb9a717b4b26dc41d93d51bb25e91b8f2 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery1.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery1.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import org.apache.flink.api.common.Plan; @@ -32,7 +31,7 @@ import org.apache.flink.test.recordJobs.util.IntTupleDataInFormat; import org.apache.flink.test.recordJobs.util.StringTupleDataOutFormat; import org.apache.flink.types.StringValue; - +@SuppressWarnings("deprecation") public class TPCHQuery1 implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery10.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery10.java index f4afb9d509762457f99a54c4df12da703764b6f0..7a8ffc6842b87ea5d7f787df23cb0d298a74c9c1 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery10.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery10.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import java.io.IOException; @@ -44,7 +43,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class TPCHQuery10 implements Program, ProgramDescription { // -------------------------------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3.java index 500e160119b73d027ec5600408c91667ba06af92..cebe6f94e15d53c16642058f64a9dd2d6ada6d6f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import java.io.Serializable; @@ -64,6 +63,7 @@ import org.apache.flink.util.Collector; * AND o_orderpriority LIKE "Z%" * GROUP BY l_orderkey, o_shippriority; */ +@SuppressWarnings("deprecation") public class TPCHQuery3 implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3Unioned.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3Unioned.java index cc48949eafaee9944288e4547a4f2e507efd0299..157e3cf95e8fe8c75a05357231c9a4890b5adb65 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3Unioned.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery3Unioned.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import org.apache.flink.api.common.Plan; @@ -54,6 +53,7 @@ import org.apache.flink.types.StringValue; * AND o_orderpriority LIKE "Z%" * GROUP BY l_orderkey, o_shippriority; */ +@SuppressWarnings("deprecation") public class TPCHQuery3Unioned implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery4.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery4.java index 6e5ee39e091ffa070ab929007faba14ee8a90510..2103747fecac328ef18e7da4f0b7b1da035f8341 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery4.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery4.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import java.text.ParseException; @@ -51,7 +50,8 @@ import org.slf4j.LoggerFactory; /** * Implementation of the TPC-H Query 4 as a Flink program. */ -@SuppressWarnings("serial") + +@SuppressWarnings({"serial", "deprecation"}) public class TPCHQuery4 implements Program, ProgramDescription { private static Logger LOG = LoggerFactory.getLogger(TPCHQuery4.class); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery9.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery9.java index 3d87f6621b8237339291125b2b16edd7f3084636..925ed5c4224a474f3506b5b873ee5b6d0e12c414 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery9.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQuery9.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import org.apache.flink.api.common.Plan; @@ -80,7 +79,7 @@ import org.slf4j.LoggerFactory; * Attention: The "order by" part is not implemented! * */ -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class TPCHQuery9 implements Program, ProgramDescription { public final String ARGUMENTS = "dop partInputPath partSuppInputPath ordersInputPath lineItemInputPath supplierInputPath nationInputPath outputPath"; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQueryAsterix.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQueryAsterix.java index 0c5bad735a28ebb657b66a3d08d01180a3e1c44a..415fde99bb47707b38b51e61c9a2c6dc9d0bc4a9 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQueryAsterix.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/TPCHQueryAsterix.java @@ -57,7 +57,7 @@ import org.apache.flink.util.Collector; * GROUP BY c_mktsegment; * */ - +@SuppressWarnings("deprecation") public class TPCHQueryAsterix implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java index b02a686158da35c6af0304dd136322cc1a13f8be..45889ead7565b3c52269a7e003d30e7578f41341 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational; import java.io.Serializable; @@ -81,6 +80,7 @@ import org.apache.flink.util.Collector; * * */ +@SuppressWarnings("deprecation") public class WebLogAnalysis implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/GroupByReturnFlag.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/GroupByReturnFlag.java index bad78789451455496d24000fa315d2650934c05c..d7aab4baf04cb76b013e80ed45be7d729754ab79 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/GroupByReturnFlag.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/GroupByReturnFlag.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query1Util; import java.util.Iterator; @@ -28,6 +27,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; +@SuppressWarnings("deprecation") public class GroupByReturnFlag extends ReduceFunction { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/LineItemFilter.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/LineItemFilter.java index 4d1c8302da9d2603bdf4fd189bba845285b5b278..be5452427b6dc70e3c9789e36954b59cb78b785d 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/LineItemFilter.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query1Util/LineItemFilter.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query1Util; import java.text.DateFormat; @@ -38,8 +37,8 @@ import org.slf4j.LoggerFactory; * TODO: add parametrisation; first version uses a static interval = 90 * * In prepration of the following reduce step (see {@link GroupByReturnFlag}) the key has to be set to "return flag" - * */ +@SuppressWarnings("deprecation") public class LineItemFilter extends MapFunction { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/AmountAggregate.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/AmountAggregate.java index 564675dcf3b52f788da93280c286eab4aeb950ea..638877f326681dbd9c42f6cc79204b692d3ff681 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/AmountAggregate.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/AmountAggregate.java @@ -16,10 +16,8 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; - import java.util.Iterator; import org.apache.flink.api.java.record.functions.ReduceFunction; @@ -27,7 +25,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({"serial", "deprecation"}) public class AmountAggregate extends ReduceFunction { private StringValue value = new StringValue(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/FilteredPartsJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/FilteredPartsJoin.java index 28d7257cc50537cb31260fee45cf479385e7961d..a391684322c5a7558283ba56c54196ad0c9a2104 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/FilteredPartsJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/FilteredPartsJoin.java @@ -16,10 +16,8 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; - import org.apache.flink.api.java.record.functions.JoinFunction; import org.apache.flink.test.recordJobs.util.Tuple; import org.apache.flink.types.IntValue; @@ -27,7 +25,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "serial", "deprecation" }) public class FilteredPartsJoin extends JoinFunction { private final IntPair partAndSupplierKey = new IntPair(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/LineItemMap.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/LineItemMap.java index f1055a77a11eef5d15af654d29188057c658cc41..6a862b80eebd36c22f52304ac9e3c497dcc4f2a9 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/LineItemMap.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/LineItemMap.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.MapFunction; @@ -24,7 +23,7 @@ import org.apache.flink.test.recordJobs.util.Tuple; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class LineItemMap extends MapFunction { /** diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderMap.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderMap.java index d3b46e657da773c5271041ef913a250f9c6f6821..ee10333816983cefef263d304802b654397887fd 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderMap.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderMap.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.MapFunction; @@ -25,7 +24,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class OrderMap extends MapFunction { private final Tuple inputTuple = new Tuple(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderedPartsJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderedPartsJoin.java index 59a5f3bf4ca73ef1981070613fa12e555e047e00..2e6453c411aa888013500ffcea48df3fc64d19b3 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderedPartsJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/OrderedPartsJoin.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.JoinFunction; @@ -25,7 +24,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class OrderedPartsJoin extends JoinFunction { /** diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartFilter.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartFilter.java index b5be55bff565459f754471933c935a8adfbe985c..1e9a9208b99b3d354668fb3d1c4a0752ff1382d1 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartFilter.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartFilter.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.MapFunction; @@ -25,7 +24,7 @@ import org.apache.flink.types.NullValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class PartFilter extends MapFunction { private final Tuple inputTuple = new Tuple(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartJoin.java index f424c83bd108f6d5e39f31b4e72238698ef07f73..67f2f6a4812b4034fcbde7d1e051472a07156a89 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartJoin.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.JoinFunction; @@ -26,7 +25,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class PartJoin extends JoinFunction { private final Tuple partSuppValue = new Tuple(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartListJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartListJoin.java index 65b45954c8288f89ecd355122f822a74f1c4ba38..66860cec17746c5e6a5d44925a625207aeed397a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartListJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartListJoin.java @@ -16,17 +16,15 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; - import org.apache.flink.api.java.record.functions.JoinFunction; import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class PartListJoin extends JoinFunction { private final StringIntPair amountYearPair = new StringIntPair(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartsuppMap.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartsuppMap.java index 399fec4c0942e133d08bb142fde54b58034cf57c..32c1d6433f8605fd3c28c51b596adcf35b778446 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartsuppMap.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/PartsuppMap.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.MapFunction; @@ -24,7 +23,7 @@ import org.apache.flink.test.recordJobs.util.Tuple; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class PartsuppMap extends MapFunction { private Tuple inputTuple = new Tuple(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SupplierMap.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SupplierMap.java index 1679226cfed5303591012c77f4e5fc18087b35bb..2b435315fcf84b9ddadfddd867a87aad2297a996 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SupplierMap.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SupplierMap.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; import org.apache.flink.api.java.record.functions.MapFunction; @@ -25,7 +24,7 @@ import org.apache.flink.types.IntValue; import org.apache.flink.types.Record; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class SupplierMap extends MapFunction { private IntValue suppKey = new IntValue(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SuppliersJoin.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SuppliersJoin.java index 4103c45319d7574c59b3b384338fd6c668114b36..f1252373cc4feefaec2cd10a6819f86c3804be00 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SuppliersJoin.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/query9Util/SuppliersJoin.java @@ -16,10 +16,8 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.relational.query9Util; - import org.apache.flink.api.java.record.functions.JoinFunction; import org.apache.flink.test.recordJobs.util.Tuple; import org.apache.flink.types.IntValue; @@ -27,7 +25,7 @@ import org.apache.flink.types.Record; import org.apache.flink.types.StringValue; import org.apache.flink.util.Collector; -@SuppressWarnings("serial") +@SuppressWarnings({ "deprecation", "serial" }) public class SuppliersJoin extends JoinFunction { private IntValue suppKey = new IntValue(); diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/ReduceGroupSort.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/ReduceGroupSort.java index 4065d4ab097817adfbfb35ad3b8615e5760db261..b4dc1b494f669f0df870315d235a3a0ab5af9fae 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/ReduceGroupSort.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/ReduceGroupSort.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.sort; import java.io.Serializable; @@ -42,6 +41,7 @@ import org.apache.flink.util.Collector; * This job shows how to define ordered input for a Reduce contract. * The inputs for CoGroups can be (individually) ordered as well. */ +@SuppressWarnings("deprecation") public class ReduceGroupSort implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/TeraSort.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/TeraSort.java index 7207c78fe1cd125b19c28622a20974922a121ac9..860e6b9c8343e7aa80061d1b4911b0b7d2a8d88f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/TeraSort.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/TeraSort.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.sort; import org.apache.flink.api.common.Plan; @@ -38,6 +37,7 @@ import org.apache.flink.test.recordJobs.sort.tsUtil.TeraOutputFormat; * href="http://hadoop.apache.org/common/docs/current/api/org/apache/hadoop/examples/terasort/TeraGen.html"> * http://hadoop.apache.org/common/docs/current/api/org/apache/hadoop/examples/terasort/TeraGen.html. */ +@SuppressWarnings("deprecation") public final class TeraSort implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCount.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCount.java index 49a73a1049ee2b67c936b2425d1ac5f9f8d60648..53b26637d202ca71644f974afdaa16d867867b0f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCount.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCount.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.wordcount; import java.util.Iterator; @@ -46,6 +45,7 @@ import org.apache.flink.util.Collector; * Implements a word count which takes the input file and counts the number of * the occurrences of each word in the file. */ +@SuppressWarnings("deprecation") public class WordCount implements Program, ProgramDescription { private static final long serialVersionUID = 1L; diff --git a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCountAccumulators.java b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCountAccumulators.java index cf21d067932e5d9fbf616acbe6b852cf48828638..9054a873b63b7518ab1f8ffb43f2cd21b2c58831 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCountAccumulators.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recordJobs/wordcount/WordCountAccumulators.java @@ -16,7 +16,6 @@ * limitations under the License. */ - package org.apache.flink.test.recordJobs.wordcount; import java.io.IOException; @@ -57,6 +56,7 @@ import org.apache.flink.util.Collector; * This is similar to the WordCount example and additionally demonstrates how to * use custom accumulators (built-in or custom). */ +@SuppressWarnings("deprecation") public class WordCountAccumulators implements Program, ProgramDescription { private static final long serialVersionUID = 1L;