You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/07/12 14:48:30 UTC
[51/73] [abbrv] [partial] git commit: Update license header for java,
sh and xml files
Update license header for java, sh and xml files
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/ebe6b90f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/ebe6b90f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/ebe6b90f
Branch: refs/heads/master
Commit: ebe6b90f054dcbdae45c340bb2f01026292e097d
Parents: 7e62878
Author: Robert Metzger <rm...@apache.org>
Authored: Fri Jul 11 16:25:15 2014 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Fri Jul 11 16:53:43 2014 +0200
----------------------------------------------------------------------
NOTICE | 2 -
README.md | 4 +-
deploysettings.xml | 17 +-
docs/build_docs.sh | 26 ++-
flink-addons/avro/pom.xml | 13 ++
.../apache/flink/api/avro/AvroBaseValue.java | 26 +--
.../apache/flink/api/avro/DataInputDecoder.java | 26 +--
.../flink/api/avro/DataOutputEncoder.java | 26 +--
.../api/avro/FSDataInputStreamWrapper.java | 24 ++-
.../flink/api/java/io/AvroInputFormat.java | 26 +--
.../flink/api/java/io/AvroOutputFormat.java | 26 +--
.../java/record/io/avro/AvroInputFormat.java | 26 +--
.../record/io/avro/AvroRecordInputFormat.java | 26 +--
.../avro/example/ReflectiveAvroTypeExample.java | 26 +--
.../api/java/record/io/avro/example/SUser.java | 26 +--
.../api/java/record/io/avro/example/User.java | 24 ++-
.../avro/src/test/assembly/test-assembly.xml | 17 +-
.../api/avro/AvroExternalJarProgramITCase.java | 26 +--
.../flink/api/avro/AvroOutputFormatTest.java | 26 +--
.../api/avro/AvroWithEmptyArrayITCase.java | 26 +--
.../flink/api/avro/EncoderDecoderTest.java | 26 +--
.../avro/testjar/AvroExternalJarProgram.java | 26 +--
.../io/AvroInputFormatTypeExtractionTest.java | 26 +--
.../io/avro/AvroRecordInputFormatTest.java | 24 ++-
.../java/record/io/avro/generated/Colors.java | 24 ++-
.../api/java/record/io/avro/generated/User.java | 24 ++-
flink-addons/hadoop-compatibility/pom.xml | 13 ++
.../mapred/HadoopInputFormat.java | 24 ++-
.../mapred/HadoopOutputFormat.java | 24 ++-
.../mapred/example/WordCount.java | 24 ++-
.../mapred/record/HadoopDataSink.java | 24 ++-
.../mapred/record/HadoopDataSource.java | 24 ++-
.../mapred/record/HadoopRecordInputFormat.java | 24 ++-
.../mapred/record/HadoopRecordOutputFormat.java | 24 ++-
.../datatypes/DefaultFlinkTypeConverter.java | 24 ++-
.../datatypes/DefaultHadoopTypeConverter.java | 24 ++-
.../record/datatypes/FlinkTypeConverter.java | 24 ++-
.../datatypes/HadoopFileOutputCommitter.java | 24 ++-
.../record/datatypes/HadoopTypeConverter.java | 24 ++-
.../datatypes/WritableComparableWrapper.java | 24 ++-
.../record/datatypes/WritableWrapper.java | 24 ++-
.../datatypes/WritableWrapperConverter.java | 24 ++-
.../mapred/record/example/WordCount.java | 24 ++-
.../example/WordCountWithOutputFormat.java | 24 ++-
.../mapred/utils/HadoopUtils.java | 24 ++-
.../mapred/wrapper/HadoopDummyProgressable.java | 24 ++-
.../mapred/wrapper/HadoopDummyReporter.java | 24 ++-
.../mapred/wrapper/HadoopInputSplit.java | 24 ++-
.../mapreduce/HadoopInputFormat.java | 24 ++-
.../mapreduce/HadoopOutputFormat.java | 24 ++-
.../mapreduce/example/WordCount.java | 24 ++-
.../mapreduce/utils/HadoopUtils.java | 24 ++-
.../mapreduce/wrapper/HadoopInputSplit.java | 24 ++-
.../mapred/HadoopInputOutputITCase.java | 24 ++-
.../record/HadoopRecordInputOutputITCase.java | 24 ++-
.../mapreduce/HadoopInputOutputITCase.java | 24 ++-
flink-addons/hbase/pom.xml | 13 ++
.../addons/hbase/GenericTableOutputFormat.java | 24 ++-
.../flink/addons/hbase/HBaseDataSink.java | 24 ++-
.../flink/addons/hbase/TableInputFormat.java | 24 ++-
.../flink/addons/hbase/TableInputSplit.java | 24 ++-
.../flink/addons/hbase/common/HBaseKey.java | 24 ++-
.../flink/addons/hbase/common/HBaseResult.java | 24 ++-
.../flink/addons/hbase/common/HBaseUtil.java | 24 ++-
.../addons/hbase/example/HBaseReadExample.java | 26 +--
flink-addons/jdbc/pom.xml | 13 ++
.../flink/api/java/io/jdbc/JDBCInputFormat.java | 26 +--
.../api/java/io/jdbc/JDBCOutputFormat.java | 26 +--
.../api/java/io/jdbc/example/JDBCExample.java | 26 +--
.../java/record/io/jdbc/JDBCInputFormat.java | 24 ++-
.../java/record/io/jdbc/JDBCOutputFormat.java | 26 +--
.../record/io/jdbc/example/JDBCExample.java | 26 +--
.../api/java/io/jdbc/JDBCInputFormatTest.java | 26 +--
.../api/java/io/jdbc/JDBCOutputFormatTest.java | 26 +--
.../java/record/io/jdbc/DevNullLogStream.java | 24 ++-
.../record/io/jdbc/JDBCOutputFormatTest.java | 26 +--
flink-addons/pom.xml | 13 ++
flink-addons/spargel/pom.xml | 13 ++
.../flink/spargel/java/MessageIterator.java | 24 ++-
.../flink/spargel/java/MessagingFunction.java | 24 ++-
.../apache/flink/spargel/java/OutgoingEdge.java | 24 ++-
.../spargel/java/VertexCentricIteration.java | 24 ++-
.../spargel/java/VertexUpdateFunction.java | 24 ++-
.../examples/SpargelConnectedComponents.java | 24 ++-
.../spargel/java/examples/SpargelPageRank.java | 24 ++-
.../SpargelPageRankCountingVertices.java | 24 ++-
.../apache/flink/spargel/java/record/Edge.java | 24 ++-
.../spargel/java/record/MessageIterator.java | 24 ++-
.../spargel/java/record/MessagingFunction.java | 24 ++-
.../spargel/java/record/SpargelIteration.java | 24 ++-
.../java/record/VertexUpdateFunction.java | 24 ++-
.../flink/spargel/java/SpargelCompilerTest.java | 26 +--
.../spargel/java/SpargelTranslationTest.java | 26 +--
.../SpargelConnectedComponentsITCase.java | 24 ++-
.../apache/flink/yarn/ApplicationMaster.java | 24 ++-
.../main/java/org/apache/flink/yarn/Client.java | 24 ++-
.../main/java/org/apache/flink/yarn/Utils.java | 24 ++-
.../flink/yarn/YarnTaskManagerRunner.java | 24 ++-
flink-clients/pom.xml | 13 ++
.../org/apache/flink/client/CliFrontend.java | 24 ++-
.../org/apache/flink/client/LocalExecutor.java | 24 ++-
.../org/apache/flink/client/RemoteExecutor.java | 24 ++-
.../org/apache/flink/client/WebFrontend.java | 24 ++-
.../client/minicluster/NepheleMiniCluster.java | 24 ++-
.../org/apache/flink/client/program/Client.java | 24 ++-
.../client/program/ContextEnvironment.java | 26 +--
.../flink/client/program/JobWithJars.java | 24 ++-
.../flink/client/program/PackagedProgram.java | 24 ++-
.../program/ProgramInvocationException.java | 24 ++-
.../apache/flink/client/web/GUIServletStub.java | 58 +++---
.../flink/client/web/JobSubmissionServlet.java | 188 ++++++++++---------
.../flink/client/web/JobsInfoServlet.java | 104 +++++-----
.../apache/flink/client/web/JobsServlet.java | 70 +++----
.../flink/client/web/PactJobJSONServlet.java | 176 ++++++++---------
.../flink/client/web/PlanDisplayServlet.java | 112 +++++------
.../flink/client/web/WebInterfaceServer.java | 24 ++-
.../flink/client/CliFrontendInfoTest.java | 26 +--
.../CliFrontendJobManagerConnectionTest.java | 26 +--
.../flink/client/CliFrontendListCancelTest.java | 26 +--
.../client/CliFrontendPackageProgramTest.java | 26 +--
.../apache/flink/client/CliFrontendRunTest.java | 26 +--
.../flink/client/CliFrontendTestUtils.java | 26 +--
.../apache/flink/client/program/ClientTest.java | 24 ++-
.../client/program/PackagedProgramTest.java | 26 +--
.../testjar/JobWithExternalDependency.java | 26 +--
.../apache/flink/client/testjar/WordCount.java | 26 +--
flink-compiler/pom.xml | 13 ++
.../flink/compiler/CompilerException.java | 24 ++-
.../compiler/CompilerPostPassException.java | 24 ++-
.../apache/flink/compiler/DataStatistics.java | 24 ++-
.../compiler/NonCachingDataStatistics.java | 24 ++-
.../org/apache/flink/compiler/PactCompiler.java | 24 ++-
.../compiler/contextcheck/ContextChecker.java | 24 ++-
.../contextcheck/MissingChildException.java | 24 ++-
.../compiler/contextcheck/Validatable.java | 24 ++-
.../flink/compiler/costs/CostEstimator.java | 24 ++-
.../org/apache/flink/compiler/costs/Costs.java | 24 ++-
.../compiler/costs/DefaultCostEstimator.java | 24 ++-
.../dag/AbstractPartialSolutionNode.java | 24 ++-
.../flink/compiler/dag/BinaryUnionNode.java | 24 ++-
.../flink/compiler/dag/BulkIterationNode.java | 24 ++-
.../compiler/dag/BulkPartialSolutionNode.java | 24 ++-
.../apache/flink/compiler/dag/CoGroupNode.java | 24 ++-
.../flink/compiler/dag/CollectorMapNode.java | 24 ++-
.../apache/flink/compiler/dag/CrossNode.java | 24 ++-
.../apache/flink/compiler/dag/DataSinkNode.java | 24 ++-
.../flink/compiler/dag/DataSourceNode.java | 24 ++-
.../flink/compiler/dag/EstimateProvider.java | 24 ++-
.../apache/flink/compiler/dag/FilterNode.java | 24 ++-
.../apache/flink/compiler/dag/FlatMapNode.java | 24 ++-
.../flink/compiler/dag/GroupReduceNode.java | 24 ++-
.../dag/InterestingPropertiesClearer.java | 24 ++-
.../flink/compiler/dag/IterationNode.java | 24 ++-
.../org/apache/flink/compiler/dag/MapNode.java | 24 ++-
.../apache/flink/compiler/dag/MatchNode.java | 24 ++-
.../org/apache/flink/compiler/dag/NoOpNode.java | 24 ++-
.../flink/compiler/dag/OptimizerNode.java | 24 ++-
.../flink/compiler/dag/PactConnection.java | 24 ++-
.../flink/compiler/dag/PlanCacheCleaner.java | 24 ++-
.../apache/flink/compiler/dag/ReduceNode.java | 24 ++-
.../flink/compiler/dag/SingleInputNode.java | 24 ++-
.../apache/flink/compiler/dag/SinkJoiner.java | 24 ++-
.../flink/compiler/dag/SolutionSetNode.java | 24 ++-
.../org/apache/flink/compiler/dag/TempMode.java | 24 ++-
.../apache/flink/compiler/dag/TwoInputNode.java | 24 ++-
.../flink/compiler/dag/UnaryOperatorNode.java | 24 ++-
.../compiler/dag/WorksetIterationNode.java | 24 ++-
.../apache/flink/compiler/dag/WorksetNode.java | 24 ++-
.../dataproperties/GlobalProperties.java | 24 ++-
.../dataproperties/InterestingProperties.java | 24 ++-
.../dataproperties/LocalProperties.java | 24 ++-
.../dataproperties/PartitioningProperty.java | 24 ++-
.../RequestedGlobalProperties.java | 24 ++-
.../RequestedLocalProperties.java | 24 ++-
.../compiler/deadlockdetect/DeadlockEdge.java | 24 ++-
.../compiler/deadlockdetect/DeadlockGraph.java | 24 ++-
.../deadlockdetect/DeadlockPreventer.java | 24 ++-
.../compiler/deadlockdetect/DeadlockVertex.java | 24 ++-
.../operators/AbstractJoinDescriptor.java | 24 ++-
.../operators/AbstractOperatorDescriptor.java | 24 ++-
.../operators/AllGroupReduceProperties.java | 24 ++-
.../AllGroupWithPartialPreGroupProperties.java | 24 ++-
.../compiler/operators/AllReduceProperties.java | 24 ++-
.../operators/BinaryUnionOpDescriptor.java | 24 ++-
.../operators/CartesianProductDescriptor.java | 24 ++-
.../compiler/operators/CoGroupDescriptor.java | 24 ++-
.../CoGroupWithSolutionSetFirstDescriptor.java | 24 ++-
.../CoGroupWithSolutionSetSecondDescriptor.java | 24 ++-
.../operators/CollectorMapDescriptor.java | 24 ++-
.../CrossBlockOuterFirstDescriptor.java | 24 ++-
.../CrossBlockOuterSecondDescriptor.java | 24 ++-
.../CrossStreamOuterFirstDescriptor.java | 24 ++-
.../CrossStreamOuterSecondDescriptor.java | 24 ++-
.../compiler/operators/FilterDescriptor.java | 24 ++-
.../compiler/operators/FlatMapDescriptor.java | 24 ++-
.../operators/GroupReduceProperties.java | 24 ++-
.../GroupReduceWithCombineProperties.java | 24 ++-
.../operators/HashJoinBuildFirstProperties.java | 24 ++-
.../HashJoinBuildSecondProperties.java | 24 ++-
.../flink/compiler/operators/MapDescriptor.java | 24 ++-
.../compiler/operators/NoOpDescriptor.java | 24 ++-
.../operators/OperatorDescriptorDual.java | 24 ++-
.../operators/OperatorDescriptorSingle.java | 24 ++-
.../operators/PartialGroupProperties.java | 24 ++-
.../compiler/operators/ReduceProperties.java | 24 ++-
.../operators/SolutionSetDeltaOperator.java | 24 ++-
.../operators/SortMergeJoinDescriptor.java | 24 ++-
.../operators/UtilSinkJoinOpDescriptor.java | 24 ++-
.../compiler/plan/BinaryUnionPlanNode.java | 24 ++-
.../compiler/plan/BulkIterationPlanNode.java | 24 ++-
.../plan/BulkPartialSolutionPlanNode.java | 24 ++-
.../org/apache/flink/compiler/plan/Channel.java | 24 ++-
.../flink/compiler/plan/DualInputPlanNode.java | 24 ++-
.../flink/compiler/plan/IterationPlanNode.java | 24 ++-
.../flink/compiler/plan/NAryUnionPlanNode.java | 24 ++-
.../flink/compiler/plan/NamedChannel.java | 24 ++-
.../flink/compiler/plan/OptimizedPlan.java | 24 ++-
.../apache/flink/compiler/plan/PlanNode.java | 24 ++-
.../compiler/plan/SingleInputPlanNode.java | 24 ++-
.../flink/compiler/plan/SinkJoinerPlanNode.java | 24 ++-
.../flink/compiler/plan/SinkPlanNode.java | 24 ++-
.../compiler/plan/SolutionSetPlanNode.java | 24 ++-
.../flink/compiler/plan/SourcePlanNode.java | 24 ++-
.../compiler/plan/WorksetIterationPlanNode.java | 24 ++-
.../flink/compiler/plan/WorksetPlanNode.java | 24 ++-
.../compiler/plandump/DumpableConnection.java | 24 ++-
.../flink/compiler/plandump/DumpableNode.java | 24 ++-
.../plandump/PlanJSONDumpGenerator.java | 24 ++-
.../plantranslate/NepheleJobGraphGenerator.java | 24 ++-
.../flink/compiler/postpass/AbstractSchema.java | 24 ++-
.../ConflictingFieldTypeInfoException.java | 24 ++-
.../compiler/postpass/DenseValueSchema.java | 24 ++-
.../postpass/GenericFlatTypePostPass.java | 24 ++-
.../compiler/postpass/JavaApiPostPass.java | 26 +--
.../postpass/MissingFieldTypeInfoException.java | 24 ++-
.../compiler/postpass/OptimizerPostPass.java | 24 ++-
.../flink/compiler/postpass/PostPassUtils.java | 24 ++-
.../compiler/postpass/RecordModelPostPass.java | 24 ++-
.../compiler/postpass/SparseKeySchema.java | 24 ++-
.../flink/compiler/util/NoOpBinaryUdfOp.java | 24 ++-
.../flink/compiler/util/NoOpFunction.java | 24 ++-
.../flink/compiler/util/NoOpUnaryUdfOp.java | 24 ++-
.../org/apache/flink/compiler/util/Utils.java | 24 ++-
.../flink/compiler/AdditionalOperatorsTest.java | 32 ++--
.../compiler/BranchingPlansCompilerTest.java | 24 ++-
.../BroadcastVariablePipelinebreakerTest.java | 26 +--
.../CachedMatchStrategyCompilerTest.java | 32 ++--
.../compiler/CoGroupSolutionSetFirstTest.java | 24 ++-
.../apache/flink/compiler/CompilerTestBase.java | 24 ++-
.../apache/flink/compiler/DOPChangeTest.java | 24 ++-
.../compiler/FeedbackPropertiesMatchTest.java | 26 +--
.../apache/flink/compiler/GroupOrderTest.java | 24 ++-
.../compiler/GroupReduceCompilationTest.java | 26 +--
.../compiler/HardPlansCompilationTest.java | 24 ++-
.../flink/compiler/IterationsCompilerTest.java | 26 +--
.../apache/flink/compiler/ReduceAllTest.java | 24 ++-
.../flink/compiler/ReduceCompilationTest.java | 26 +--
.../compiler/UnionPropertyPropagationTest.java | 24 ++-
.../flink/compiler/UnionReplacementTest.java | 21 ++-
.../WorksetIterationsJavaApiCompilerTest.java | 32 ++--
.../WorksetIterationsRecordApiCompilerTest.java | 32 ++--
.../costs/DefaultCostEstimatorTest.java | 26 +--
.../apache/flink/compiler/plan/ChannelTest.java | 26 +--
.../compiler/plandump/NumberFormattingTest.java | 26 +--
.../testfunctions/DummyJoinFunction.java | 26 +--
.../testfunctions/IdentityGroupReducer.java | 26 +--
.../testfunctions/IdentityKeyExtractor.java | 26 +--
.../compiler/testfunctions/IdentityMapper.java | 26 +--
.../testfunctions/Top1GroupReducer.java | 26 +--
.../flink/compiler/util/DummyCoGroupStub.java | 24 ++-
.../flink/compiler/util/DummyCrossStub.java | 24 ++-
.../flink/compiler/util/DummyInputFormat.java | 24 ++-
.../flink/compiler/util/DummyMatchStub.java | 24 ++-
.../util/DummyNonPreservingMatchStub.java | 24 ++-
.../flink/compiler/util/DummyOutputFormat.java | 24 ++-
.../apache/flink/compiler/util/IdentityMap.java | 24 ++-
.../flink/compiler/util/IdentityReduce.java | 24 ++-
flink-core/pom.xml | 13 ++
.../api/common/InvalidProgramException.java | 24 ++-
.../flink/api/common/JobExecutionResult.java | 24 ++-
.../NonSerializableUserCodeException.java | 24 ++-
.../java/org/apache/flink/api/common/Plan.java | 24 ++-
.../apache/flink/api/common/PlanExecutor.java | 24 ++-
.../org/apache/flink/api/common/Program.java | 24 ++-
.../flink/api/common/ProgramDescription.java | 24 ++-
.../api/common/accumulators/Accumulator.java | 24 ++-
.../common/accumulators/AccumulatorHelper.java | 24 ++-
.../api/common/accumulators/DoubleCounter.java | 24 ++-
.../api/common/accumulators/Histogram.java | 24 ++-
.../api/common/accumulators/IntCounter.java | 24 ++-
.../api/common/accumulators/LongCounter.java | 24 ++-
.../common/accumulators/SimpleAccumulator.java | 24 ++-
.../api/common/aggregators/Aggregator.java | 24 ++-
.../common/aggregators/AggregatorRegistry.java | 24 ++-
.../common/aggregators/AggregatorWithName.java | 24 ++-
.../aggregators/ConvergenceCriterion.java | 24 ++-
.../common/aggregators/DoubleSumAggregator.java | 24 ++-
.../aggregators/DoubleZeroConvergence.java | 26 +--
.../common/aggregators/LongSumAggregator.java | 24 ++-
.../common/aggregators/LongZeroConvergence.java | 26 +--
.../api/common/cache/DistributedCache.java | 24 ++-
.../common/distributions/DataDistribution.java | 24 ++-
.../distributions/SimpleDistribution.java | 24 ++-
.../SimpleIntegerDistribution.java | 24 ++-
.../UniformDoubleDistribution.java | 24 ++-
.../UniformIntegerDistribution.java | 24 ++-
.../api/common/functions/AbstractFunction.java | 24 ++-
.../api/common/functions/ExecutionContext.java | 24 ++-
.../flink/api/common/functions/Function.java | 24 ++-
.../api/common/functions/GenericCoGrouper.java | 24 ++-
.../common/functions/GenericCollectorMap.java | 24 ++-
.../api/common/functions/GenericCombine.java | 24 ++-
.../api/common/functions/GenericCrosser.java | 24 ++-
.../api/common/functions/GenericFilter.java | 24 ++-
.../api/common/functions/GenericFlatMap.java | 24 ++-
.../common/functions/GenericGroupReduce.java | 24 ++-
.../api/common/functions/GenericJoiner.java | 24 ++-
.../flink/api/common/functions/GenericMap.java | 24 ++-
.../api/common/functions/GenericReduce.java | 24 ++-
.../functions/IterationRuntimeContext.java | 24 ++-
.../api/common/functions/RuntimeContext.java | 24 ++-
.../flink/api/common/io/BinaryInputFormat.java | 24 ++-
.../flink/api/common/io/BinaryOutputFormat.java | 24 ++-
.../apache/flink/api/common/io/BlockInfo.java | 24 ++-
.../api/common/io/DelimitedInputFormat.java | 24 ++-
.../flink/api/common/io/FileInputFormat.java | 24 ++-
.../flink/api/common/io/FileOutputFormat.java | 24 ++-
.../apache/flink/api/common/io/FormatUtil.java | 24 ++-
.../api/common/io/GenericCsvInputFormat.java | 24 ++-
.../flink/api/common/io/GenericInputFormat.java | 24 ++-
.../io/InflaterInputStreamFSInputWrapper.java | 24 ++-
.../flink/api/common/io/InitializeOnMaster.java | 26 +--
.../apache/flink/api/common/io/InputFormat.java | 24 ++-
.../flink/api/common/io/NonParallelInput.java | 24 ++-
.../flink/api/common/io/OutputFormat.java | 24 ++-
.../flink/api/common/io/ParseException.java | 24 ++-
.../api/common/io/SerializedInputFormat.java | 24 ++-
.../api/common/io/SerializedOutputFormat.java | 24 ++-
.../common/io/statistics/BaseStatistics.java | 24 ++-
.../common/operators/AbstractUdfOperator.java | 24 ++-
.../operators/BinaryOperatorInformation.java | 26 +--
.../api/common/operators/CompilerHints.java | 24 ++-
.../api/common/operators/DualInputOperator.java | 24 ++-
.../operators/DualInputSemanticProperties.java | 24 ++-
.../api/common/operators/IterationOperator.java | 24 ++-
.../flink/api/common/operators/Operator.java | 24 ++-
.../common/operators/OperatorInformation.java | 24 ++-
.../flink/api/common/operators/Order.java | 24 ++-
.../flink/api/common/operators/Ordering.java | 24 ++-
.../api/common/operators/RecordOperator.java | 24 ++-
.../common/operators/SemanticProperties.java | 24 ++-
.../common/operators/SingleInputOperator.java | 24 ++-
.../SingleInputSemanticProperties.java | 24 ++-
.../operators/UnaryOperatorInformation.java | 26 +--
.../flink/api/common/operators/Union.java | 26 +--
.../operators/base/BulkIterationBase.java | 24 ++-
.../operators/base/CoGroupOperatorBase.java | 24 ++-
.../base/CollectorMapOperatorBase.java | 24 ++-
.../operators/base/CrossOperatorBase.java | 24 ++-
.../operators/base/DeltaIterationBase.java | 24 ++-
.../common/operators/base/FileDataSinkBase.java | 24 ++-
.../operators/base/FileDataSourceBase.java | 24 ++-
.../operators/base/FilterOperatorBase.java | 24 ++-
.../operators/base/FlatMapOperatorBase.java | 24 ++-
.../operators/base/GenericDataSinkBase.java | 24 ++-
.../operators/base/GenericDataSourceBase.java | 24 ++-
.../operators/base/GroupReduceOperatorBase.java | 24 ++-
.../common/operators/base/JoinOperatorBase.java | 24 ++-
.../common/operators/base/MapOperatorBase.java | 24 ++-
.../operators/base/ReduceOperatorBase.java | 24 ++-
.../api/common/operators/util/FieldList.java | 24 ++-
.../api/common/operators/util/FieldSet.java | 24 ++-
.../api/common/operators/util/OperatorUtil.java | 24 ++-
.../operators/util/UserCodeClassWrapper.java | 24 ++-
.../operators/util/UserCodeObjectWrapper.java | 24 ++-
.../common/operators/util/UserCodeWrapper.java | 24 ++-
.../api/common/typeutils/TypeComparator.java | 24 ++-
.../common/typeutils/TypeComparatorFactory.java | 24 ++-
.../common/typeutils/TypePairComparator.java | 24 ++-
.../typeutils/TypePairComparatorFactory.java | 24 ++-
.../api/common/typeutils/TypeSerializer.java | 24 ++-
.../common/typeutils/TypeSerializerFactory.java | 24 ++-
.../typeutils/base/BasicTypeComparator.java | 26 +--
.../typeutils/base/BooleanComparator.java | 26 +--
.../typeutils/base/BooleanSerializer.java | 26 +--
.../typeutils/base/BooleanValueSerializer.java | 26 +--
.../common/typeutils/base/ByteComparator.java | 26 +--
.../common/typeutils/base/ByteSerializer.java | 26 +--
.../typeutils/base/ByteValueSerializer.java | 26 +--
.../common/typeutils/base/CharComparator.java | 26 +--
.../common/typeutils/base/CharSerializer.java | 26 +--
.../typeutils/base/CharValueSerializer.java | 26 +--
.../common/typeutils/base/DoubleComparator.java | 26 +--
.../common/typeutils/base/DoubleSerializer.java | 26 +--
.../typeutils/base/DoubleValueSerializer.java | 26 +--
.../common/typeutils/base/FloatComparator.java | 26 +--
.../common/typeutils/base/FloatSerializer.java | 26 +--
.../typeutils/base/FloatValueSerializer.java | 26 +--
.../common/typeutils/base/IntComparator.java | 26 +--
.../common/typeutils/base/IntSerializer.java | 26 +--
.../typeutils/base/IntValueSerializer.java | 26 +--
.../common/typeutils/base/LongComparator.java | 26 +--
.../common/typeutils/base/LongSerializer.java | 26 +--
.../typeutils/base/LongValueSerializer.java | 26 +--
.../common/typeutils/base/ShortComparator.java | 26 +--
.../common/typeutils/base/ShortSerializer.java | 26 +--
.../typeutils/base/ShortValueSerializer.java | 26 +--
.../common/typeutils/base/StringComparator.java | 26 +--
.../common/typeutils/base/StringSerializer.java | 26 +--
.../typeutils/base/StringValueSerializer.java | 26 +--
.../array/BooleanPrimitiveArraySerializer.java | 26 +--
.../array/BytePrimitiveArraySerializer.java | 26 +--
.../array/CharPrimitiveArraySerializer.java | 26 +--
.../array/DoublePrimitiveArraySerializer.java | 26 +--
.../array/FloatPrimitiveArraySerializer.java | 26 +--
.../base/array/IntPrimitiveArraySerializer.java | 26 +--
.../array/LongPrimitiveArraySerializer.java | 26 +--
.../array/ShortPrimitiveArraySerializer.java | 26 +--
.../base/array/StringArraySerializer.java | 26 +--
.../flink/configuration/ConfigConstants.java | 24 ++-
.../flink/configuration/Configuration.java | 24 ++-
.../configuration/GlobalConfiguration.java | 24 ++-
.../IllegalConfigurationException.java | 24 ++-
.../org/apache/flink/core/fs/BlockLocation.java | 24 ++-
.../apache/flink/core/fs/FSDataInputStream.java | 24 ++-
.../flink/core/fs/FSDataOutputStream.java | 24 ++-
.../flink/core/fs/FileChannelWrapper.java | 24 ++-
.../apache/flink/core/fs/FileInputSplit.java | 24 ++-
.../org/apache/flink/core/fs/FileStatus.java | 24 ++-
.../org/apache/flink/core/fs/FileSystem.java | 24 ++-
.../java/org/apache/flink/core/fs/Path.java | 24 ++-
.../flink/core/fs/local/LocalBlockLocation.java | 24 ++-
.../core/fs/local/LocalDataInputStream.java | 24 ++-
.../core/fs/local/LocalDataOutputStream.java | 24 ++-
.../flink/core/fs/local/LocalFileStatus.java | 24 ++-
.../flink/core/fs/local/LocalFileSystem.java | 24 ++-
.../apache/flink/core/io/GenericInputSplit.java | 24 ++-
.../flink/core/io/IOReadableWritable.java | 24 ++-
.../org/apache/flink/core/io/InputSplit.java | 24 ++-
.../flink/core/io/LocatableInputSplit.java | 24 ++-
.../org/apache/flink/core/io/StringRecord.java | 24 ++-
.../apache/flink/core/memory/DataInputView.java | 24 ++-
.../flink/core/memory/DataOutputView.java | 24 ++-
.../memory/InputViewDataInputStreamWrapper.java | 21 ++-
.../InputViewObjectInputStreamWrapper.java | 21 ++-
.../apache/flink/core/memory/MemorySegment.java | 24 ++-
.../flink/core/memory/MemorySegmentSource.java | 24 ++-
.../apache/flink/core/memory/MemoryUtils.java | 24 ++-
.../OutputViewDataOutputStreamWrapper.java | 21 ++-
.../OutputViewObjectOutputStreamWrapper.java | 21 ++-
.../core/memory/SeekableDataInputView.java | 24 ++-
.../core/memory/SeekableDataOutputView.java | 32 ++--
.../flink/core/protocols/VersionedProtocol.java | 24 ++-
.../org/apache/flink/types/BooleanValue.java | 24 ++-
.../java/org/apache/flink/types/ByteValue.java | 24 ++-
.../java/org/apache/flink/types/CharValue.java | 24 ++-
.../org/apache/flink/types/CopyableValue.java | 24 ++-
.../flink/types/DeserializationException.java | 24 ++-
.../org/apache/flink/types/DoubleValue.java | 24 ++-
.../java/org/apache/flink/types/FloatValue.java | 24 ++-
.../java/org/apache/flink/types/IntValue.java | 24 ++-
.../main/java/org/apache/flink/types/Key.java | 24 ++-
.../types/KeyFieldOutOfBoundsException.java | 24 ++-
.../java/org/apache/flink/types/ListValue.java | 24 ++-
.../java/org/apache/flink/types/LongValue.java | 24 ++-
.../java/org/apache/flink/types/MapValue.java | 24 ++-
.../org/apache/flink/types/NormalizableKey.java | 24 ++-
.../java/org/apache/flink/types/Nothing.java | 24 ++-
.../org/apache/flink/types/NothingTypeInfo.java | 24 ++-
.../flink/types/NullKeyFieldException.java | 24 ++-
.../java/org/apache/flink/types/NullValue.java | 24 ++-
.../main/java/org/apache/flink/types/Pair.java | 24 ++-
.../java/org/apache/flink/types/Record.java | 24 ++-
.../org/apache/flink/types/ResettableValue.java | 24 ++-
.../java/org/apache/flink/types/ShortValue.java | 24 ++-
.../org/apache/flink/types/StringValue.java | 24 ++-
.../org/apache/flink/types/TypeInformation.java | 26 +--
.../main/java/org/apache/flink/types/Value.java | 24 ++-
.../java/org/apache/flink/types/ValueUtil.java | 24 ++-
.../apache/flink/types/parser/ByteParser.java | 24 ++-
.../flink/types/parser/ByteValueParser.java | 24 ++-
.../apache/flink/types/parser/DoubleParser.java | 24 ++-
.../flink/types/parser/DoubleValueParser.java | 24 ++-
.../apache/flink/types/parser/FieldParser.java | 24 ++-
.../apache/flink/types/parser/FloatParser.java | 24 ++-
.../flink/types/parser/FloatValueParser.java | 24 ++-
.../apache/flink/types/parser/IntParser.java | 24 ++-
.../flink/types/parser/IntValueParser.java | 24 ++-
.../apache/flink/types/parser/LongParser.java | 24 ++-
.../flink/types/parser/LongValueParser.java | 24 ++-
.../apache/flink/types/parser/ShortParser.java | 24 ++-
.../flink/types/parser/ShortValueParser.java | 24 ++-
.../apache/flink/types/parser/StringParser.java | 24 ++-
.../flink/types/parser/StringValueParser.java | 24 ++-
.../java/org/apache/flink/util/ClassUtils.java | 24 ++-
.../java/org/apache/flink/util/Collector.java | 24 ++-
.../apache/flink/util/InstantiationUtil.java | 24 ++-
.../org/apache/flink/util/IterableIterator.java | 26 +--
.../java/org/apache/flink/util/LogUtils.java | 24 ++-
.../flink/util/MutableObjectIterator.java | 24 ++-
.../flink/util/NumberSequenceIterator.java | 26 +--
.../org/apache/flink/util/OperatingSystem.java | 24 ++-
.../org/apache/flink/util/ReflectionUtil.java | 24 ++-
.../apache/flink/util/SimpleStringUtils.java | 24 ++-
.../apache/flink/util/SplittableIterator.java | 26 +--
.../java/org/apache/flink/util/StringUtils.java | 24 ++-
.../java/org/apache/flink/util/Visitable.java | 24 ++-
.../java/org/apache/flink/util/Visitor.java | 24 ++-
.../api/common/io/BinaryInputFormatTest.java | 24 ++-
.../io/DelimitedInputFormatSamplingTest.java | 24 ++-
.../api/common/io/DelimitedInputFormatTest.java | 24 ++-
.../api/common/io/FileInputFormatTest.java | 24 ++-
.../api/common/io/FileOutputFormatTest.java | 24 ++-
.../common/io/GenericCsvInputFormatTest.java | 24 ++-
.../api/common/io/SequentialFormatTest.java | 24 ++-
.../common/operators/util/FieldListTest.java | 26 +--
.../api/common/operators/util/FieldSetTest.java | 26 +--
.../common/operators/util/OperatorUtilTest.java | 24 ++-
.../common/typeutils/ComparatorTestBase.java | 26 +--
.../common/typeutils/SerializerTestBase.java | 26 +--
.../typeutils/SerializerTestInstance.java | 26 +--
.../typeutils/base/BooleanComparatorTest.java | 26 +--
.../typeutils/base/BooleanSerializerTest.java | 26 +--
.../typeutils/base/ByteComparatorTest.java | 26 +--
.../typeutils/base/ByteSerializerTest.java | 26 +--
.../typeutils/base/CharComparatorTest.java | 26 +--
.../typeutils/base/CharSerializerTest.java | 26 +--
.../typeutils/base/DoubleComparatorTest.java | 26 +--
.../typeutils/base/DoubleSerializerTest.java | 26 +--
.../typeutils/base/FloatComparatorTest.java | 26 +--
.../typeutils/base/FloatSerializerTest.java | 26 +--
.../typeutils/base/IntComparatorTest.java | 26 +--
.../typeutils/base/IntSerializerTest.java | 26 +--
.../typeutils/base/LongComparatorTest.java | 26 +--
.../typeutils/base/LongSerializerTest.java | 26 +--
.../typeutils/base/ShortComparatorTest.java | 26 +--
.../typeutils/base/ShortSerializerTest.java | 26 +--
.../typeutils/base/StringComparatorTest.java | 26 +--
.../typeutils/base/StringSerializerTest.java | 26 +--
.../BooleanPrimitiveArraySerializerTest.java | 26 +--
.../array/BytePrimitiveArraySerializerTest.java | 26 +--
.../array/CharPrimitiveArraySerializerTest.java | 26 +--
.../DoublePrimitiveArraySerializerTest.java | 26 +--
.../FloatPrimitiveArraySerializerTest.java | 26 +--
.../array/IntPrimitiveArraySerializerTest.java | 26 +--
.../array/LongPrimitiveArraySerializerTest.java | 26 +--
.../ShortPrimitiveArraySerializerTest.java | 26 +--
.../base/array/StringArraySerializerTest.java | 26 +--
.../SimpleDataDistributionTest.java | 24 ++-
.../flink/configuration/ConfigurationTest.java | 24 ++-
.../configuration/GlobalConfigurationTest.java | 24 ++-
.../core/fs/local/LocalFileSystemTest.java | 24 ++-
.../flink/core/testutils/CommonTestUtils.java | 24 ++-
.../apache/flink/testutils/TestConfigUtils.java | 24 ++-
.../apache/flink/testutils/TestFileSystem.java | 24 ++-
.../apache/flink/testutils/TestFileUtils.java | 24 ++-
.../flink/types/CollectionsDataTypeTest.java | 24 ++-
.../apache/flink/types/NormalizableKeyTest.java | 24 ++-
.../flink/types/PrimitiveDataTypeTest.java | 24 ++-
.../org/apache/flink/types/RecordITCase.java | 24 ++-
.../java/org/apache/flink/types/RecordTest.java | 24 ++-
.../flink/types/StringSerializationTest.java | 26 +--
.../flink/types/parser/ByteParserTest.java | 24 ++-
.../flink/types/parser/ByteValueParserTest.java | 24 ++-
.../flink/types/parser/DoubleParserTest.java | 24 ++-
.../types/parser/DoubleValueParserTest.java | 24 ++-
.../flink/types/parser/FloatParserTest.java | 24 ++-
.../types/parser/FloatValueParserTest.java | 24 ++-
.../flink/types/parser/IntParserTest.java | 24 ++-
.../flink/types/parser/IntValueParserTest.java | 24 ++-
.../flink/types/parser/LongParserTest.java | 24 ++-
.../flink/types/parser/LongValueParserTest.java | 24 ++-
.../flink/types/parser/ParserTestBase.java | 26 +--
.../flink/types/parser/ShortParserTest.java | 24 ++-
.../types/parser/ShortValueParserTest.java | 24 ++-
.../flink/types/parser/StringParserTest.java | 24 ++-
.../types/parser/StringValueParserTest.java | 24 ++-
.../types/parser/VarLengthStringParserTest.java | 24 ++-
.../flink/util/InstantiationUtilsTest.java | 26 +--
.../flink/util/NumberSequenceIteratorTest.java | 26 +--
.../flink/util/SimpleStringUtilsTest.java | 26 +--
.../org/apache/flink/util/StringUtilsTest.java | 26 +--
flink-dist/pom.xml | 13 ++
flink-dist/src/deb/bin/jobmanager | 25 ++-
flink-dist/src/deb/bin/taskmanager | 25 ++-
flink-dist/src/deb/bin/webclient | 25 ++-
flink-dist/src/deb/control/control | 25 ++-
flink-dist/src/deb/control/postinst | 25 ++-
flink-dist/src/main/assemblies/bin.xml | 26 ++-
flink-dist/src/main/assemblies/yarn-uberjar.xml | 22 ++-
flink-dist/src/main/assemblies/yarn.xml | 22 ++-
flink-dist/src/main/flink-bin/bin/config.sh | 30 +--
flink-dist/src/main/flink-bin/bin/flink | 29 +--
flink-dist/src/main/flink-bin/bin/flink.bat | 29 +--
flink-dist/src/main/flink-bin/bin/jobmanager.sh | 30 +--
.../src/main/flink-bin/bin/start-cluster.sh | 30 +--
.../src/main/flink-bin/bin/start-local.bat | 29 +--
.../src/main/flink-bin/bin/start-local.sh | 30 +--
.../src/main/flink-bin/bin/start-webclient.sh | 30 +--
.../src/main/flink-bin/bin/stop-cluster.sh | 30 +--
flink-dist/src/main/flink-bin/bin/stop-local.sh | 30 +--
.../src/main/flink-bin/bin/stop-webclient.sh | 30 +--
.../src/main/flink-bin/bin/taskmanager.sh | 30 +--
flink-dist/src/main/flink-bin/bin/webclient.sh | 30 +--
.../src/main/flink-bin/conf/flink-conf.yaml | 30 +--
.../main/flink-bin/tools/planVisualizer.html | 22 ++-
.../src/main/flink-bin/yarn-bin/yarn-session.sh | 30 +--
flink-examples/flink-java-examples/pom.xml | 13 ++
.../flink/example/java/clustering/KMeans.java | 26 +--
.../java/clustering/util/KMeansData.java | 24 ++-
.../clustering/util/KMeansDataGenerator.java | 24 ++-
.../example/java/graph/ConnectedComponents.java | 24 ++-
.../example/java/graph/EnumTrianglesBasic.java | 26 +--
.../example/java/graph/EnumTrianglesOpt.java | 26 +--
.../flink/example/java/graph/PageRankBasic.java | 26 +--
.../java/graph/TransitiveClosureNaive.java | 24 ++-
.../graph/util/ConnectedComponentsData.java | 24 ++-
.../java/graph/util/EnumTrianglesData.java | 26 +--
.../java/graph/util/EnumTrianglesDataTypes.java | 26 +--
.../example/java/graph/util/PageRankData.java | 26 +--
.../flink/example/java/ml/LinearRegression.java | 26 +--
.../java/ml/util/LinearRegressionData.java | 24 ++-
.../ml/util/LinearRegressionDataGenerator.java | 24 ++-
.../java/relational/RelationalQuery.java | 26 +--
.../example/java/relational/TPCHQuery10.java | 26 +--
.../example/java/relational/TPCHQuery3.java | 26 +--
.../example/java/relational/WebLogAnalysis.java | 24 ++-
.../java/relational/util/WebLogData.java | 26 +--
.../relational/util/WebLogDataGenerator.java | 24 ++-
.../flink/example/java/wordcount/WordCount.java | 28 +--
.../example/java/wordcount/WordCountPOJO.java | 28 +--
.../java/wordcount/util/WordCountData.java | 26 +--
flink-examples/flink-scala-examples/pom.xml | 13 ++
.../org/apache/flink/examples/scala/Dummy.java | 24 ++-
.../scala/datamining/BatchGradientDescent.scala | 24 ++-
.../examples/scala/datamining/KMeans.scala | 21 ++-
.../scala/graph/ComputeEdgeDegrees.scala | 24 ++-
.../scala/graph/ConnectedComponents.scala | 24 ++-
.../graph/EnumTrianglesOnEdgesWithDegrees.scala | 24 ++-
.../flink/examples/scala/graph/LineRank.scala | 21 ++-
.../flink/examples/scala/graph/PageRank.scala | 21 ++-
.../scala/graph/PageRankWithWeight.scala | 21 ++-
.../scala/graph/TransitiveClosureNaive.scala | 24 ++-
.../scala/iterative/TerminationCriterion.scala | 30 +--
.../scala/relational/RelationalQuery.scala | 24 ++-
.../scala/relational/WebLogAnalysis.scala | 24 ++-
.../examples/scala/testing/KMeansForTest.scala | 24 ++-
.../examples/scala/wordcount/WordCount.scala | 24 ++-
.../scala/wordcount/WordCountWithCount.scala | 24 ++-
.../WordCountWithUserDefinedType.scala | 24 ++-
flink-examples/pom.xml | 13 ++
flink-java/pom.xml | 13 ++
.../flink/api/java/BulkIterationResultSet.java | 26 +--
.../java/org/apache/flink/api/java/DataSet.java | 26 +--
.../apache/flink/api/java/DeltaIteration.java | 26 +--
.../flink/api/java/DeltaIterationResultSet.java | 26 +--
.../flink/api/java/ExecutionEnvironment.java | 26 +--
.../apache/flink/api/java/IterativeDataSet.java | 26 +--
.../apache/flink/api/java/LocalEnvironment.java | 26 +--
.../flink/api/java/RemoteEnvironment.java | 26 +--
.../java/aggregation/AggregationFunction.java | 26 +--
.../aggregation/AggregationFunctionFactory.java | 26 +--
.../api/java/aggregation/Aggregations.java | 26 +--
.../aggregation/AvgAggregationFunction.java | 26 +--
.../aggregation/MaxAggregationFunction.java | 26 +--
.../aggregation/MinAggregationFunction.java | 26 +--
.../aggregation/SumAggregationFunction.java | 26 +--
.../UnsupportedAggregationTypeException.java | 26 +--
.../api/java/functions/CoGroupFunction.java | 26 +--
.../flink/api/java/functions/CrossFunction.java | 26 +--
.../api/java/functions/FilterFunction.java | 26 +--
.../api/java/functions/FlatMapFunction.java | 26 +--
.../api/java/functions/FlatMapIterator.java | 26 +--
.../api/java/functions/FunctionAnnotation.java | 24 ++-
.../api/java/functions/GroupReduceFunction.java | 26 +--
.../api/java/functions/GroupReduceIterator.java | 26 +--
.../java/functions/InvalidTypesException.java | 26 +--
.../flink/api/java/functions/JoinFunction.java | 26 +--
.../flink/api/java/functions/KeySelector.java | 26 +--
.../flink/api/java/functions/MapFunction.java | 26 +--
.../api/java/functions/ReduceFunction.java | 26 +--
.../api/java/functions/SemanticPropUtil.java | 24 ++-
.../api/java/io/CollectionInputFormat.java | 26 +--
.../flink/api/java/io/CsvInputFormat.java | 26 +--
.../flink/api/java/io/CsvOutputFormat.java | 24 ++-
.../org/apache/flink/api/java/io/CsvReader.java | 26 +--
.../api/java/io/DiscardingOuputFormat.java | 26 +--
.../api/java/io/DiscardingOutputFormat.java | 26 +--
.../flink/api/java/io/IteratorInputFormat.java | 26 +--
.../java/io/LocalCollectionOutputFormat.java | 26 +--
.../java/io/ParallelIteratorInputFormat.java | 26 +--
.../flink/api/java/io/PrintingOutputFormat.java | 26 +--
.../flink/api/java/io/TextInputFormat.java | 26 +--
.../flink/api/java/io/TextOutputFormat.java | 26 +--
.../flink/api/java/io/TextValueInputFormat.java | 26 +--
.../api/java/operators/AggregateOperator.java | 26 +--
.../api/java/operators/CoGroupOperator.java | 26 +--
.../flink/api/java/operators/CrossOperator.java | 26 +--
.../java/operators/CustomUnaryOperation.java | 26 +--
.../flink/api/java/operators/DataSink.java | 26 +--
.../flink/api/java/operators/DataSource.java | 26 +--
.../api/java/operators/DistinctOperator.java | 26 +--
.../api/java/operators/FilterOperator.java | 26 +--
.../api/java/operators/FlatMapOperator.java | 26 +--
.../flink/api/java/operators/Grouping.java | 26 +--
.../flink/api/java/operators/JoinOperator.java | 26 +--
.../apache/flink/api/java/operators/Keys.java | 26 +--
.../flink/api/java/operators/MapOperator.java | 26 +--
.../flink/api/java/operators/Operator.java | 26 +--
.../api/java/operators/OperatorTranslation.java | 26 +--
.../api/java/operators/ProjectOperator.java | 26 +--
.../api/java/operators/ReduceGroupOperator.java | 26 +--
.../api/java/operators/ReduceOperator.java | 26 +--
.../api/java/operators/SingleInputOperator.java | 26 +--
.../java/operators/SingleInputUdfOperator.java | 26 +--
.../api/java/operators/SortedGrouping.java | 26 +--
.../api/java/operators/TwoInputOperator.java | 26 +--
.../api/java/operators/TwoInputUdfOperator.java | 26 +--
.../flink/api/java/operators/UdfOperator.java | 26 +--
.../flink/api/java/operators/UnionOperator.java | 26 +--
.../api/java/operators/UnsortedGrouping.java | 26 +--
.../java/operators/translation/JavaPlan.java | 26 +--
.../translation/KeyExtractingMapper.java | 26 +--
.../translation/KeyRemovingMapper.java | 26 +--
.../translation/PlanFilterOperator.java | 26 +--
.../translation/PlanProjectOperator.java | 26 +--
.../PlanUnwrappingCoGroupOperator.java | 26 +--
.../translation/PlanUnwrappingJoinOperator.java | 26 +--
.../PlanUnwrappingReduceGroupOperator.java | 26 +--
.../PlanUnwrappingReduceOperator.java | 26 +--
.../translation/TupleKeyExtractingMapper.java | 26 +--
.../translation/TupleUnwrappingIterator.java | 26 +--
.../translation/TupleWrappingCollector.java | 26 +--
.../operators/translation/WrappingFunction.java | 26 +--
.../java/record/functions/CoGroupFunction.java | 24 ++-
.../java/record/functions/CrossFunction.java | 24 ++-
.../record/functions/FunctionAnnotation.java | 24 ++-
.../api/java/record/functions/JoinFunction.java | 24 ++-
.../api/java/record/functions/MapFunction.java | 24 ++-
.../java/record/functions/ReduceFunction.java | 24 ++-
.../java/record/io/CollectionInputFormat.java | 26 +--
.../api/java/record/io/CsvInputFormat.java | 24 ++-
.../api/java/record/io/CsvOutputFormat.java | 24 ++-
.../java/record/io/DelimitedInputFormat.java | 24 ++-
.../java/record/io/DelimitedOutputFormat.java | 24 ++-
.../ExternalProcessFixedLengthInputFormat.java | 24 ++-
.../record/io/ExternalProcessInputFormat.java | 24 ++-
.../record/io/ExternalProcessInputSplit.java | 24 ++-
.../api/java/record/io/FileInputFormat.java | 24 ++-
.../api/java/record/io/FileOutputFormat.java | 24 ++-
.../java/record/io/FixedLengthInputFormat.java | 24 ++-
.../api/java/record/io/GenericInputFormat.java | 24 ++-
.../api/java/record/io/TextInputFormat.java | 24 ++-
.../java/record/operators/BulkIteration.java | 24 ++-
.../java/record/operators/CoGroupOperator.java | 24 ++-
.../record/operators/CollectionDataSource.java | 24 ++-
.../java/record/operators/CrossOperator.java | 24 ++-
.../operators/CrossWithLargeOperator.java | 24 ++-
.../operators/CrossWithSmallOperator.java | 24 ++-
.../java/record/operators/DeltaIteration.java | 24 ++-
.../api/java/record/operators/FileDataSink.java | 24 ++-
.../java/record/operators/FileDataSource.java | 24 ++-
.../java/record/operators/GenericDataSink.java | 24 ++-
.../record/operators/GenericDataSource.java | 24 ++-
.../api/java/record/operators/JoinOperator.java | 24 ++-
.../api/java/record/operators/MapOperator.java | 24 ++-
.../record/operators/OperatorInfoHelper.java | 24 ++-
.../java/record/operators/ReduceOperator.java | 24 ++-
.../org/apache/flink/api/java/tuple/Tuple.java | 24 ++-
.../org/apache/flink/api/java/tuple/Tuple1.java | 26 +--
.../apache/flink/api/java/tuple/Tuple10.java | 26 +--
.../apache/flink/api/java/tuple/Tuple11.java | 26 +--
.../apache/flink/api/java/tuple/Tuple12.java | 26 +--
.../apache/flink/api/java/tuple/Tuple13.java | 26 +--
.../apache/flink/api/java/tuple/Tuple14.java | 26 +--
.../apache/flink/api/java/tuple/Tuple15.java | 26 +--
.../apache/flink/api/java/tuple/Tuple16.java | 26 +--
.../apache/flink/api/java/tuple/Tuple17.java | 26 +--
.../apache/flink/api/java/tuple/Tuple18.java | 26 +--
.../apache/flink/api/java/tuple/Tuple19.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple2.java | 26 +--
.../apache/flink/api/java/tuple/Tuple20.java | 26 +--
.../apache/flink/api/java/tuple/Tuple21.java | 26 +--
.../apache/flink/api/java/tuple/Tuple22.java | 26 +--
.../apache/flink/api/java/tuple/Tuple23.java | 26 +--
.../apache/flink/api/java/tuple/Tuple24.java | 26 +--
.../apache/flink/api/java/tuple/Tuple25.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple3.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple4.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple5.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple6.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple7.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple8.java | 26 +--
.../org/apache/flink/api/java/tuple/Tuple9.java | 26 +--
.../flink/api/java/tuple/TupleGenerator.java | 171 +++++++++--------
.../api/java/tuple/builder/Tuple10Builder.java | 26 +--
.../api/java/tuple/builder/Tuple11Builder.java | 26 +--
.../api/java/tuple/builder/Tuple12Builder.java | 26 +--
.../api/java/tuple/builder/Tuple13Builder.java | 26 +--
.../api/java/tuple/builder/Tuple14Builder.java | 26 +--
.../api/java/tuple/builder/Tuple15Builder.java | 26 +--
.../api/java/tuple/builder/Tuple16Builder.java | 26 +--
.../api/java/tuple/builder/Tuple17Builder.java | 26 +--
.../api/java/tuple/builder/Tuple18Builder.java | 26 +--
.../api/java/tuple/builder/Tuple19Builder.java | 26 +--
.../api/java/tuple/builder/Tuple1Builder.java | 26 +--
.../api/java/tuple/builder/Tuple20Builder.java | 26 +--
.../api/java/tuple/builder/Tuple21Builder.java | 26 +--
.../api/java/tuple/builder/Tuple22Builder.java | 26 +--
.../api/java/tuple/builder/Tuple23Builder.java | 26 +--
.../api/java/tuple/builder/Tuple24Builder.java | 26 +--
.../api/java/tuple/builder/Tuple25Builder.java | 26 +--
.../api/java/tuple/builder/Tuple2Builder.java | 26 +--
.../api/java/tuple/builder/Tuple3Builder.java | 26 +--
.../api/java/tuple/builder/Tuple4Builder.java | 26 +--
.../api/java/tuple/builder/Tuple5Builder.java | 26 +--
.../api/java/tuple/builder/Tuple6Builder.java | 26 +--
.../api/java/tuple/builder/Tuple7Builder.java | 26 +--
.../api/java/tuple/builder/Tuple8Builder.java | 26 +--
.../api/java/tuple/builder/Tuple9Builder.java | 26 +--
.../flink/api/java/typeutils/AtomicType.java | 26 +--
.../api/java/typeutils/BasicArrayTypeInfo.java | 26 +--
.../flink/api/java/typeutils/BasicTypeInfo.java | 26 +--
.../flink/api/java/typeutils/CompositeType.java | 26 +--
.../api/java/typeutils/GenericTypeInfo.java | 26 +--
.../java/typeutils/InputTypeConfigurable.java | 26 +--
.../api/java/typeutils/ObjectArrayTypeInfo.java | 26 +--
.../flink/api/java/typeutils/PojoField.java | 26 +--
.../flink/api/java/typeutils/PojoTypeInfo.java | 26 +--
.../java/typeutils/PrimitiveArrayTypeInfo.java | 26 +--
.../api/java/typeutils/RecordTypeInfo.java | 26 +--
.../api/java/typeutils/ResultTypeQueryable.java | 26 +--
.../flink/api/java/typeutils/TupleTypeInfo.java | 26 +--
.../flink/api/java/typeutils/TypeExtractor.java | 26 +--
.../api/java/typeutils/TypeInfoParser.java | 24 ++-
.../flink/api/java/typeutils/ValueTypeInfo.java | 26 +--
.../api/java/typeutils/WritableTypeInfo.java | 26 +--
.../java/typeutils/runtime/AvroSerializer.java | 26 +--
.../runtime/CopyableValueComparator.java | 26 +--
.../runtime/CopyableValueSerializer.java | 26 +--
.../typeutils/runtime/DataInputDecoder.java | 26 +--
.../typeutils/runtime/DataOutputEncoder.java | 26 +--
.../runtime/GenericArraySerializer.java | 26 +--
.../runtime/GenericTypeComparator.java | 26 +--
.../java/typeutils/runtime/PojoComparator.java | 26 +--
.../typeutils/runtime/PojoPairComparator.java | 26 +--
.../java/typeutils/runtime/PojoSerializer.java | 26 +--
.../runtime/RuntimeComparatorFactory.java | 24 ++-
.../runtime/RuntimePairComparatorFactory.java | 24 ++-
.../RuntimeStatefulSerializerFactory.java | 24 ++-
.../RuntimeStatelessSerializerFactory.java | 24 ++-
.../java/typeutils/runtime/TupleComparator.java | 26 +--
.../runtime/TupleLeadingFieldComparator.java | 26 +--
.../TupleLeadingFieldPairComparator.java | 26 +--
.../typeutils/runtime/TuplePairComparator.java | 26 +--
.../java/typeutils/runtime/TupleSerializer.java | 26 +--
.../java/typeutils/runtime/ValueComparator.java | 26 +--
.../java/typeutils/runtime/ValueSerializer.java | 26 +--
.../typeutils/runtime/WritableComparator.java | 32 ++--
.../typeutils/runtime/WritableSerializer.java | 26 +--
.../runtime/record/RecordComparator.java | 24 ++-
.../runtime/record/RecordComparatorFactory.java | 24 ++-
.../runtime/record/RecordPairComparator.java | 24 ++-
.../record/RecordPairComparatorFactory.java | 24 ++-
.../runtime/record/RecordSerializer.java | 24 ++-
.../runtime/record/RecordSerializerFactory.java | 24 ++-
.../flink/api/java/MultipleInvokationsTest.java | 26 +--
.../java/functions/SemanticPropUtilTest.java | 24 ++-
.../SemanticPropertiesProjectionTest.java | 26 +--
.../SemanticPropertiesTranslationTest.java | 26 +--
.../apache/flink/api/java/io/CSVReaderTest.java | 26 +--
.../api/java/io/CollectionInputFormatTest.java | 24 ++-
.../flink/api/java/io/CsvInputFormatTest.java | 24 ++-
.../flink/api/java/io/TextInputFormatTest.java | 24 ++-
.../java/operator/AggregateOperatorTest.java | 26 +--
.../api/java/operator/CoGroupOperatorTest.java | 26 +--
.../api/java/operator/CrossOperatorTest.java | 26 +--
.../api/java/operator/DistinctOperatorTest.java | 26 +--
.../flink/api/java/operator/GroupingTest.java | 26 +--
.../api/java/operator/JoinOperatorTest.java | 26 +--
.../java/operator/ProjectionOperatorTest.java | 26 +--
.../translation/AggregateTranslationTest.java | 26 +--
.../DeltaIterationTranslationTest.java | 26 +--
.../translation/ReduceTranslationTests.java | 26 +--
.../api/java/record/io/CsvInputFormatTest.java | 24 ++-
.../api/java/record/io/CsvOutputFormatTest.java | 24 ++-
...ternalProcessFixedLengthInputFormatTest.java | 24 ++-
.../io/ExternalProcessInputFormatTest.java | 24 ++-
.../record/io/FixedLenghtInputFormatTest.java | 24 ++-
.../api/java/record/io/TextInputFormatTest.java | 24 ++-
.../apache/flink/api/java/tuple/Tuple2Test.java | 26 +--
.../type/extractor/PojoTypeInformationTest.java | 24 ++-
.../TypeExtractorInputFormatsTest.java | 26 +--
.../java/type/extractor/TypeExtractorTest.java | 26 +--
.../api/java/typeutils/TypeInfoParserTest.java | 26 +--
.../runtime/CopyableValueComparatorTest.java | 26 +--
.../runtime/GenericArraySerializerTest.java | 26 +--
.../runtime/GenericTypeComparatorTest.java | 26 +--
.../runtime/GenericTypeSerializerTest.java | 26 +--
.../typeutils/runtime/PojoSerializerTest.java | 26 +--
.../typeutils/runtime/StringArrayWritable.java | 32 ++--
.../runtime/TupleComparatorILD2Test.java | 26 +--
.../runtime/TupleComparatorILD3Test.java | 26 +--
.../runtime/TupleComparatorILDC3Test.java | 26 +--
.../runtime/TupleComparatorILDX1Test.java | 26 +--
.../runtime/TupleComparatorILDXC2Test.java | 26 +--
.../runtime/TupleComparatorISD1Test.java | 26 +--
.../runtime/TupleComparatorISD2Test.java | 26 +--
.../runtime/TupleComparatorISD3Test.java | 26 +--
.../TupleLeadingFieldComparatorTest.java | 26 +--
.../TupleLeadingFieldPairComparatorTest.java | 26 +--
.../runtime/TuplePairComparatorTest.java | 26 +--
.../typeutils/runtime/TupleSerializerTest.java | 26 +--
.../runtime/TupleSerializerTestInstance.java | 26 +--
.../typeutils/runtime/ValueComparatorTest.java | 26 +--
.../runtime/WritableComparatorTest.java | 26 +--
.../runtime/WritableSerializerTest.java | 26 +--
.../tuple/base/TupleComparatorTestBase.java | 26 +--
.../tuple/base/TuplePairComparatorTestBase.java | 26 +--
flink-quickstart/quickstart-SNAPSHOT.sh | 30 +--
.../java/org/apache/flink/quickstart/Dummy.java | 24 ++-
.../archetype-resources/src/main/java/Job.java | 4 +-
flink-quickstart/quickstart-scala-SNAPSHOT.sh | 30 +--
flink-quickstart/quickstart-scala.sh | 30 +--
.../java/org/apache/flink/quickstart/Dummy.java | 24 ++-
.../META-INF/maven/archetype-metadata.xml | 13 ++
flink-quickstart/quickstart.sh | 30 +--
flink-runtime/pom.xml | 13 ++
.../org/apache/flink/runtime/AbstractID.java | 24 ++-
.../org/apache/flink/runtime/ExecutionMode.java | 24 ++-
.../flink/runtime/JobSubmissionException.java | 24 ++-
.../runtime/accumulators/AccumulatorEvent.java | 24 ++-
.../flink/runtime/client/AbstractJobResult.java | 24 ++-
.../flink/runtime/client/JobCancelResult.java | 24 ++-
.../apache/flink/runtime/client/JobClient.java | 24 ++-
.../runtime/client/JobExecutionException.java | 24 ++-
.../flink/runtime/client/JobProgressResult.java | 24 ++-
.../runtime/client/JobSubmissionResult.java | 24 ++-
.../deployment/ChannelDeploymentDescriptor.java | 24 ++-
.../deployment/GateDeploymentDescriptor.java | 24 ++-
.../deployment/TaskDeploymentDescriptor.java | 24 ++-
.../flink/runtime/event/job/AbstractEvent.java | 24 ++-
.../event/job/ExecutionStateChangeEvent.java | 24 ++-
.../flink/runtime/event/job/JobEvent.java | 24 ++-
.../runtime/event/job/ManagementEvent.java | 24 ++-
.../flink/runtime/event/job/RecentJobEvent.java | 24 ++-
.../event/job/VertexAssignmentEvent.java | 24 ++-
.../flink/runtime/event/job/VertexEvent.java | 24 ++-
.../flink/runtime/event/task/AbstractEvent.java | 24 ++-
.../runtime/event/task/AbstractTaskEvent.java | 24 ++-
.../flink/runtime/event/task/EventList.java | 24 ++-
.../flink/runtime/event/task/EventListener.java | 24 ++-
.../event/task/EventNotificationManager.java | 24 ++-
.../runtime/event/task/IntegerTaskEvent.java | 24 ++-
.../runtime/event/task/StringTaskEvent.java | 24 ++-
.../runtime/execution/CancelTaskException.java | 26 +--
.../flink/runtime/execution/Environment.java | 24 ++-
.../runtime/execution/ExecutionListener.java | 24 ++-
.../runtime/execution/ExecutionObserver.java | 24 ++-
.../flink/runtime/execution/ExecutionState.java | 24 ++-
.../execution/ExecutionStateTransition.java | 24 ++-
.../runtime/execution/RuntimeEnvironment.java | 24 ++-
.../librarycache/LibraryCacheManager.java | 24 ++-
.../LibraryCacheProfileRequest.java | 24 ++-
.../LibraryCacheProfileResponse.java | 24 ++-
.../librarycache/LibraryCacheUpdate.java | 24 ++-
.../DistributionPatternProvider.java | 24 ++-
.../runtime/executiongraph/ExecutionEdge.java | 24 ++-
.../runtime/executiongraph/ExecutionGate.java | 24 ++-
.../runtime/executiongraph/ExecutionGraph.java | 24 ++-
.../executiongraph/ExecutionGraphIterator.java | 24 ++-
.../executiongraph/ExecutionGroupEdge.java | 24 ++-
.../executiongraph/ExecutionGroupVertex.java | 24 ++-
.../ExecutionGroupVertexIterator.java | 24 ++-
.../executiongraph/ExecutionPipeline.java | 24 ++-
.../executiongraph/ExecutionSignature.java | 24 ++-
.../runtime/executiongraph/ExecutionStage.java | 24 ++-
.../executiongraph/ExecutionStageListener.java | 24 ++-
.../runtime/executiongraph/ExecutionVertex.java | 24 ++-
.../executiongraph/ExecutionVertexID.java | 24 ++-
.../GraphConversionException.java | 24 ++-
.../executiongraph/InternalJobStatus.java | 24 ++-
.../executiongraph/JobStatusListener.java | 24 ++-
.../executiongraph/ManagementGraphFactory.java | 24 ++-
.../VertexAssignmentListener.java | 24 ++-
.../flink/runtime/filecache/FileCache.java | 24 ++-
.../fs/hdfs/DistributedBlockLocation.java | 24 ++-
.../fs/hdfs/DistributedDataInputStream.java | 24 ++-
.../fs/hdfs/DistributedDataOutputStream.java | 24 ++-
.../runtime/fs/hdfs/DistributedFileStatus.java | 24 ++-
.../runtime/fs/hdfs/DistributedFileSystem.java | 24 ++-
.../flink/runtime/fs/s3/S3BlockLocation.java | 24 ++-
.../flink/runtime/fs/s3/S3BucketObjectPair.java | 24 ++-
.../flink/runtime/fs/s3/S3DataInputStream.java | 24 ++-
.../flink/runtime/fs/s3/S3DataOutputStream.java | 24 ++-
.../runtime/fs/s3/S3DirectoryStructure.java | 24 ++-
.../flink/runtime/fs/s3/S3FileStatus.java | 24 ++-
.../flink/runtime/fs/s3/S3FileSystem.java | 24 ++-
.../runtime/instance/AllocatedResource.java | 24 ++-
.../flink/runtime/instance/AllocatedSlot.java | 24 ++-
.../flink/runtime/instance/AllocationID.java | 24 ++-
.../instance/DefaultInstanceManager.java | 24 ++-
.../flink/runtime/instance/DummyInstance.java | 24 ++-
.../apache/flink/runtime/instance/Hardware.java | 24 ++-
.../runtime/instance/HardwareDescription.java | 24 ++-
.../instance/HardwareDescriptionFactory.java | 24 ++-
.../apache/flink/runtime/instance/Instance.java | 24 ++-
.../instance/InstanceConnectionInfo.java | 24 ++-
.../runtime/instance/InstanceException.java | 24 ++-
.../flink/runtime/instance/InstanceID.java | 24 ++-
.../runtime/instance/InstanceListener.java | 24 ++-
.../flink/runtime/instance/InstanceManager.java | 24 ++-
.../runtime/instance/InstanceNotifier.java | 24 ++-
.../runtime/instance/LocalInstanceManager.java | 24 ++-
.../io/disk/ChannelReaderInputViewIterator.java | 24 ++-
.../runtime/io/disk/InputViewIterator.java | 24 ++-
.../runtime/io/disk/RandomAccessInputView.java | 24 ++-
.../runtime/io/disk/RandomAccessOutputView.java | 24 ++-
.../io/disk/SimpleCollectingOutputView.java | 24 ++-
.../flink/runtime/io/disk/SpillingBuffer.java | 24 ++-
.../io/disk/iomanager/BlockChannelAccess.java | 24 ++-
.../io/disk/iomanager/BlockChannelReader.java | 24 ++-
.../io/disk/iomanager/BlockChannelWriter.java | 24 ++-
.../disk/iomanager/BulkBlockChannelReader.java | 24 ++-
.../runtime/io/disk/iomanager/Channel.java | 24 ++-
.../io/disk/iomanager/ChannelAccess.java | 24 ++-
.../disk/iomanager/ChannelReaderInputView.java | 24 ++-
.../disk/iomanager/ChannelWriterOutputView.java | 24 ++-
.../runtime/io/disk/iomanager/Deserializer.java | 24 ++-
.../HeaderlessChannelReaderInputView.java | 24 ++-
.../runtime/io/disk/iomanager/IOManager.java | 24 ++-
.../runtime/io/disk/iomanager/IORequest.java | 24 ++-
.../runtime/io/disk/iomanager/RequestQueue.java | 24 ++-
.../apache/flink/runtime/io/network/Buffer.java | 24 ++-
.../runtime/io/network/BufferRecycler.java | 24 ++-
.../runtime/io/network/ChannelManager.java | 24 ++-
.../network/ConnectionInfoLookupResponse.java | 25 +--
.../flink/runtime/io/network/Envelope.java | 24 ++-
.../runtime/io/network/EnvelopeDispatcher.java | 24 ++-
.../io/network/EnvelopeReceiverList.java | 24 ++-
.../network/InsufficientResourcesException.java | 24 ++-
.../io/network/LocalConnectionManager.java | 24 ++-
.../LocalReceiverCancelledException.java | 26 +--
.../io/network/NetworkConnectionManager.java | 24 ++-
.../runtime/io/network/RemoteReceiver.java | 24 ++-
.../runtime/io/network/SenderHintEvent.java | 24 ++-
.../io/network/api/AbstractRecordReader.java | 24 ++-
.../api/AbstractSingleGateRecordReader.java | 24 ++-
.../network/api/AbstractUnionRecordReader.java | 24 ++-
.../runtime/io/network/api/BufferWriter.java | 24 ++-
.../runtime/io/network/api/ChannelSelector.java | 24 ++-
.../runtime/io/network/api/MutableReader.java | 24 ++-
.../io/network/api/MutableRecordReader.java | 24 ++-
.../network/api/MutableUnionRecordReader.java | 24 ++-
.../flink/runtime/io/network/api/Reader.java | 24 ++-
.../runtime/io/network/api/ReaderBase.java | 24 ++-
.../runtime/io/network/api/RecordReader.java | 24 ++-
.../runtime/io/network/api/RecordWriter.java | 24 ++-
.../network/api/RoundRobinChannelSelector.java | 24 ++-
.../io/network/api/UnionRecordReader.java | 24 ++-
.../BufferAvailabilityListener.java | 24 ++-
.../network/bufferprovider/BufferProvider.java | 24 ++-
.../bufferprovider/BufferProviderBroker.java | 24 ++-
.../bufferprovider/DiscardBufferPool.java | 24 ++-
.../bufferprovider/GlobalBufferPool.java | 24 ++-
.../network/bufferprovider/LocalBufferPool.java | 24 ++-
.../bufferprovider/LocalBufferPoolOwner.java | 24 ++-
.../io/network/channels/BufferOrEvent.java | 24 ++-
.../runtime/io/network/channels/Channel.java | 24 ++-
.../io/network/channels/ChannelCloseEvent.java | 24 ++-
.../runtime/io/network/channels/ChannelID.java | 24 ++-
.../io/network/channels/ChannelType.java | 24 ++-
.../network/channels/EndOfSuperstepEvent.java | 24 ++-
.../io/network/channels/InputChannel.java | 24 ++-
.../io/network/channels/OutputChannel.java | 24 ++-
.../ReceiverAlreadyClosedException.java | 26 +--
.../flink/runtime/io/network/gates/Gate.java | 24 ++-
.../flink/runtime/io/network/gates/GateID.java | 24 ++-
.../io/network/gates/InputChannelResult.java | 24 ++-
.../runtime/io/network/gates/InputGate.java | 24 ++-
.../runtime/io/network/gates/OutputGate.java | 24 ++-
.../gates/RecordAvailabilityListener.java | 24 ++-
.../network/netty/InboundEnvelopeDecoder.java | 24 ++-
.../netty/InboundEnvelopeDispatcher.java | 24 ++-
.../network/netty/NettyConnectionManager.java | 24 ++-
.../network/netty/OutboundConnectionQueue.java | 24 ++-
.../network/netty/OutboundEnvelopeEncoder.java | 24 ++-
.../AdaptiveSpanningRecordDeserializer.java | 24 ++-
.../serialization/DataInputDeserializer.java | 26 +--
.../serialization/DataOutputSerializer.java | 26 +--
.../serialization/RecordDeserializer.java | 24 ++-
.../network/serialization/RecordSerializer.java | 26 +--
.../serialization/SpanningRecordSerializer.java | 24 ++-
.../org/apache/flink/runtime/ipc/Client.java | 24 ++-
.../flink/runtime/ipc/ConnectionHeader.java | 24 ++-
.../java/org/apache/flink/runtime/ipc/RPC.java | 24 ++-
.../flink/runtime/ipc/RemoteException.java | 24 ++-
.../org/apache/flink/runtime/ipc/Server.java | 24 ++-
.../org/apache/flink/runtime/ipc/Status.java | 24 ++-
.../concurrent/BlockingBackChannel.java | 24 ++-
.../concurrent/BlockingBackChannelBroker.java | 24 ++-
.../runtime/iterative/concurrent/Broker.java | 24 ++-
.../concurrent/IterationAggregatorBroker.java | 24 ++-
.../iterative/concurrent/SolutionSetBroker.java | 24 ++-
.../concurrent/SolutionSetUpdateBarrier.java | 24 ++-
.../SolutionSetUpdateBarrierBroker.java | 24 ++-
.../iterative/concurrent/SuperstepBarrier.java | 24 ++-
.../WorksetEmptyConvergenceCriterion.java | 24 ++-
.../iterative/event/AllWorkersDoneEvent.java | 24 ++-
.../event/IterationEventWithAggregators.java | 24 ++-
.../iterative/event/TerminationEvent.java | 24 ++-
.../iterative/event/WorkerDoneEvent.java | 24 ++-
.../runtime/iterative/io/FakeOutputTask.java | 24 ++-
.../iterative/io/HashPartitionIterator.java | 24 ++-
.../iterative/io/SerializedUpdateBuffer.java | 24 ++-
.../SolutionSetFastUpdateOutputCollector.java | 26 +--
.../io/SolutionSetUpdateOutputCollector.java | 26 +--
.../io/WorksetUpdateOutputCollector.java | 24 ++-
.../task/AbstractIterativePactTask.java | 24 ++-
.../iterative/task/IterationHeadPactTask.java | 24 ++-
.../task/IterationIntermediatePactTask.java | 24 ++-
.../task/IterationSynchronizationSinkTask.java | 24 ++-
.../iterative/task/IterationTailPactTask.java | 24 ++-
.../task/RuntimeAggregatorRegistry.java | 24 ++-
.../iterative/task/SyncEventHandler.java | 24 ++-
.../runtime/iterative/task/Terminable.java | 24 ++-
.../jobgraph/AbstractJobInputVertex.java | 24 ++-
.../jobgraph/AbstractJobOutputVertex.java | 24 ++-
.../runtime/jobgraph/AbstractJobVertex.java | 24 ++-
.../runtime/jobgraph/DistributionPattern.java | 24 ++-
.../apache/flink/runtime/jobgraph/JobEdge.java | 24 ++-
.../apache/flink/runtime/jobgraph/JobGraph.java | 24 ++-
.../jobgraph/JobGraphDefinitionException.java | 24 ++-
.../apache/flink/runtime/jobgraph/JobID.java | 24 ++-
.../flink/runtime/jobgraph/JobInputVertex.java | 24 ++-
.../flink/runtime/jobgraph/JobOutputVertex.java | 24 ++-
.../flink/runtime/jobgraph/JobStatus.java | 24 ++-
.../flink/runtime/jobgraph/JobTaskVertex.java | 24 ++-
.../flink/runtime/jobgraph/JobVertexID.java | 24 ++-
.../jobgraph/tasks/AbstractInvokable.java | 24 ++-
.../jobgraph/tasks/InputSplitIterator.java | 24 ++-
.../jobgraph/tasks/InputSplitProvider.java | 24 ++-
.../runtime/jobmanager/DeploymentManager.java | 24 ++-
.../runtime/jobmanager/EventCollector.java | 24 ++-
.../flink/runtime/jobmanager/JobManager.java | 24 ++-
.../runtime/jobmanager/JobManagerUtils.java | 24 ++-
.../accumulators/AccumulatorManager.java | 24 ++-
.../accumulators/JobAccumulators.java | 24 ++-
.../jobmanager/archive/ArchiveListener.java | 24 ++-
.../jobmanager/archive/MemoryArchivist.java | 24 ++-
.../scheduler/DefaultExecutionListener.java | 24 ++-
.../jobmanager/scheduler/DefaultScheduler.java | 24 ++-
.../scheduler/SchedulingException.java | 24 ++-
.../DefaultInputSplitAssigner.java | 24 ++-
.../splitassigner/InputSplitAssigner.java | 24 ++-
.../splitassigner/InputSplitManager.java | 24 ++-
.../splitassigner/InputSplitTracker.java | 24 ++-
.../splitassigner/InputSplitWrapper.java | 24 ++-
.../LocatableInputSplitAssigner.java | 24 ++-
.../splitassigner/LocatableInputSplitList.java | 24 ++-
.../file/FileInputSplitAssigner.java | 24 ++-
.../splitassigner/file/FileInputSplitList.java | 24 ++-
.../jobmanager/web/JobmanagerInfoServlet.java | 24 ++-
.../jobmanager/web/LogfileInfoServlet.java | 24 ++-
.../runtime/jobmanager/web/MenuServlet.java | 24 ++-
.../jobmanager/web/SetupInfoServlet.java | 24 ++-
.../runtime/jobmanager/web/WebInfoServer.java | 24 ++-
.../managementgraph/ManagementAttachment.java | 24 ++-
.../runtime/managementgraph/ManagementEdge.java | 24 ++-
.../managementgraph/ManagementEdgeID.java | 24 ++-
.../runtime/managementgraph/ManagementGate.java | 24 ++-
.../managementgraph/ManagementGateID.java | 24 ++-
.../managementgraph/ManagementGraph.java | 24 ++-
.../ManagementGraphIterator.java | 24 ++-
.../managementgraph/ManagementGroupEdge.java | 24 ++-
.../managementgraph/ManagementGroupVertex.java | 24 ++-
.../ManagementGroupVertexID.java | 24 ++-
.../ManagementGroupVertexIterator.java | 24 ++-
.../managementgraph/ManagementStage.java | 24 ++-
.../managementgraph/ManagementVertex.java | 24 ++-
.../managementgraph/ManagementVertexID.java | 24 ++-
.../memorymanager/AbstractPagedInputView.java | 24 ++-
.../memorymanager/AbstractPagedOutputView.java | 24 ++-
.../memorymanager/CheckedMemorySegment.java | 24 ++-
.../memorymanager/DefaultMemoryManager.java | 24 ++-
.../memorymanager/ListMemorySegmentSource.java | 24 ++-
.../MemoryAllocationException.java | 24 ++-
.../runtime/memorymanager/MemoryManager.java | 24 ++-
.../memorymanager/SimpleMemorySegment.java | 24 ++-
.../memorymanager/UnsafeMemorySegment.java | 24 ++-
.../org/apache/flink/runtime/net/NetUtils.java | 24 ++-
.../flink/runtime/net/SocketIOWithTimeout.java | 24 ++-
.../flink/runtime/net/SocketInputStream.java | 24 ++-
.../flink/runtime/net/SocketOutputStream.java | 24 ++-
.../AbstractCachedBuildSideMatchDriver.java | 24 ++-
.../runtime/operators/AllGroupReduceDriver.java | 24 ++-
.../runtime/operators/AllReduceDriver.java | 24 ++-
.../operators/BuildFirstCachedMatchDriver.java | 24 ++-
.../operators/BuildSecondCachedMatchDriver.java | 24 ++-
.../flink/runtime/operators/CoGroupDriver.java | 24 ++-
.../CoGroupWithSolutionSetFirstDriver.java | 24 ++-
.../CoGroupWithSolutionSetSecondDriver.java | 24 ++-
.../runtime/operators/CollectorMapDriver.java | 24 ++-
.../flink/runtime/operators/CrossDriver.java | 24 ++-
.../flink/runtime/operators/DamBehavior.java | 24 ++-
.../flink/runtime/operators/DataSinkTask.java | 24 ++-
.../flink/runtime/operators/DataSourceTask.java | 24 ++-
.../flink/runtime/operators/DriverStrategy.java | 24 ++-
.../flink/runtime/operators/FlatMapDriver.java | 24 ++-
.../operators/GroupReduceCombineDriver.java | 24 ++-
.../runtime/operators/GroupReduceDriver.java | 24 ++-
.../JoinWithSolutionSetFirstDriver.java | 24 ++-
.../JoinWithSolutionSetSecondDriver.java | 24 ++-
.../flink/runtime/operators/MapDriver.java | 24 ++-
.../flink/runtime/operators/MatchDriver.java | 24 ++-
.../flink/runtime/operators/NoOpDriver.java | 24 ++-
.../flink/runtime/operators/PactDriver.java | 24 ++-
.../runtime/operators/PactTaskContext.java | 24 ++-
.../runtime/operators/ReduceCombineDriver.java | 24 ++-
.../flink/runtime/operators/ReduceDriver.java | 24 ++-
.../runtime/operators/RegularPactTask.java | 24 ++-
.../runtime/operators/ResettablePactDriver.java | 24 ++-
.../operators/RuntimeExecutionContext.java | 24 ++-
.../flink/runtime/operators/TempBarrier.java | 24 ++-
.../operators/UnionWithTempOperator.java | 24 ++-
.../chaining/ChainedCollectorMapDriver.java | 24 ++-
.../operators/chaining/ChainedDriver.java | 24 ++-
.../chaining/ChainedFlatMapDriver.java | 24 ++-
.../operators/chaining/ChainedMapDriver.java | 24 ++-
.../ChainedTerminationCriterionDriver.java | 24 ++-
.../ExceptionInChainedStubException.java | 24 ++-
.../SynchronousChainedCombineDriver.java | 24 ++-
.../operators/hash/AbstractHashTableProber.java | 26 +--
.../hash/AbstractMutableHashTable.java | 26 +--
.../hash/BuildFirstHashMatchIterator.java | 24 ++-
.../BuildFirstReOpenableHashMatchIterator.java | 24 ++-
.../hash/BuildSecondHashMatchIterator.java | 24 ++-
.../BuildSecondReOpenableHashMatchIterator.java | 24 ++-
.../operators/hash/CompactingHashTable.java | 24 ++-
.../runtime/operators/hash/HashPartition.java | 24 ++-
.../operators/hash/InMemoryPartition.java | 24 ++-
.../operators/hash/MutableHashTable.java | 24 ++-
.../operators/hash/ReOpenableHashPartition.java | 24 ++-
.../hash/ReOpenableMutableHashTable.java | 24 ++-
.../AbstractBlockResettableIterator.java | 24 ++-
.../resettable/BlockResettableIterator.java | 24 ++-
.../BlockResettableMutableObjectIterator.java | 24 ++-
.../resettable/SpillingResettableIterator.java | 24 ++-
...SpillingResettableMutableObjectIterator.java | 24 ++-
.../shipping/HistogramPartitionFunction.java | 24 ++-
.../operators/shipping/OutputCollector.java | 24 ++-
.../operators/shipping/OutputEmitter.java | 24 ++-
.../operators/shipping/PartitionFunction.java | 24 ++-
.../shipping/RecordOutputCollector.java | 24 ++-
.../operators/shipping/RecordOutputEmitter.java | 24 ++-
.../operators/shipping/ShipStrategyType.java | 24 ++-
.../sort/AsynchronousPartialSorter.java | 24 ++-
.../AsynchronousPartialSorterCollector.java | 24 ++-
.../sort/CombiningUnilateralSortMerger.java | 24 ++-
.../operators/sort/ExceptionHandler.java | 32 ++--
.../operators/sort/FixedLengthRecordSorter.java | 24 ++-
.../flink/runtime/operators/sort/HeapSort.java | 24 ++-
.../runtime/operators/sort/InMemorySorter.java | 24 ++-
.../runtime/operators/sort/IndexedSortable.java | 24 ++-
.../runtime/operators/sort/IndexedSorter.java | 24 ++-
.../runtime/operators/sort/MergeIterator.java | 24 ++-
.../operators/sort/MergeMatchIterator.java | 24 ++-
.../operators/sort/NormalizedKeySorter.java | 24 ++-
.../sort/PartialOrderPriorityQueue.java | 24 ++-
.../flink/runtime/operators/sort/QuickSort.java | 24 ++-
.../sort/SortMergeCoGroupIterator.java | 24 ++-
.../flink/runtime/operators/sort/Sorter.java | 24 ++-
.../operators/sort/UnilateralSortMerger.java | 24 ++-
.../operators/udf/RuntimeUDFContext.java | 24 ++-
.../operators/util/CloseableInputProvider.java | 24 ++-
.../operators/util/CoGroupTaskIterator.java | 24 ++-
.../util/CorruptConfigurationException.java | 24 ++-
.../operators/util/JoinTaskIterator.java | 24 ++-
.../runtime/operators/util/LocalStrategy.java | 24 ++-
.../runtime/operators/util/ReaderIterator.java | 24 ++-
.../operators/util/RecordReaderIterator.java | 24 ++-
.../util/SimpleCloseableInputProvider.java | 24 ++-
.../runtime/operators/util/TaskConfig.java | 24 ++-
.../plugable/DeserializationDelegate.java | 24 ++-
.../runtime/plugable/SerializationDelegate.java | 24 ++-
.../runtime/profiling/JobManagerProfiler.java | 24 ++-
.../runtime/profiling/ProfilingException.java | 24 ++-
.../runtime/profiling/ProfilingListener.java | 24 ++-
.../flink/runtime/profiling/ProfilingUtils.java | 24 ++-
.../runtime/profiling/TaskManagerProfiler.java | 24 ++-
.../profiling/impl/EnvironmentListenerImpl.java | 24 ++-
.../profiling/impl/EnvironmentThreadSet.java | 24 ++-
.../profiling/impl/InstanceProfiler.java | 24 ++-
.../profiling/impl/JobManagerProfilerImpl.java | 24 ++-
.../profiling/impl/JobProfilingData.java | 24 ++-
.../profiling/impl/ProfilerImplProtocol.java | 24 ++-
.../profiling/impl/TaskManagerProfilerImpl.java | 24 ++-
.../InternalExecutionVertexProfilingData.java | 24 ++-
...ernalExecutionVertexThreadProfilingData.java | 24 ++-
.../types/InternalInputGateProfilingData.java | 24 ++-
.../types/InternalInstanceProfilingData.java | 24 ++-
.../types/InternalOutputGateProfilingData.java | 24 ++-
.../impl/types/InternalProfilingData.java | 24 ++-
.../impl/types/ProfilingDataContainer.java | 24 ++-
.../types/InputGateProfilingEvent.java | 24 ++-
.../profiling/types/InstanceProfilingEvent.java | 24 ++-
.../types/InstanceSummaryProfilingEvent.java | 24 ++-
.../types/OutputGateProfilingEvent.java | 24 ++-
.../runtime/profiling/types/ProfilingEvent.java | 24 ++-
.../types/SingleInstanceProfilingEvent.java | 24 ++-
.../profiling/types/ThreadProfilingEvent.java | 24 ++-
.../profiling/types/VertexProfilingEvent.java | 24 ++-
.../runtime/protocols/AccumulatorProtocol.java | 24 ++-
.../protocols/ChannelLookupProtocol.java | 24 ++-
.../protocols/ExtendedManagementProtocol.java | 24 ++-
.../protocols/InputSplitProviderProtocol.java | 24 ++-
.../protocols/JobManagementProtocol.java | 24 ++-
.../runtime/protocols/JobManagerProtocol.java | 24 ++-
.../protocols/TaskOperationProtocol.java | 24 ++-
.../runtime/taskmanager/AbstractTaskResult.java | 24 ++-
.../taskmanager/ExecutorThreadFactory.java | 24 ++-
.../apache/flink/runtime/taskmanager/Task.java | 24 ++-
.../runtime/taskmanager/TaskCancelResult.java | 24 ++-
.../runtime/taskmanager/TaskExecutionState.java | 24 ++-
.../taskmanager/TaskInputSplitProvider.java | 24 ++-
.../runtime/taskmanager/TaskKillResult.java | 24 ++-
.../flink/runtime/taskmanager/TaskManager.java | 24 ++-
.../taskmanager/TaskSubmissionResult.java | 24 ++-
.../runtime/ExecutorThreadFactory.java | 24 ++-
.../RegisterTaskManagerResult.java | 24 ++-
.../flink/runtime/topology/NetworkNode.java | 24 ++-
.../flink/runtime/topology/NetworkTopology.java | 24 ++-
.../topology/NetworkTopologyIterator.java | 24 ++-
.../apache/flink/runtime/types/FileRecord.java | 24 ++-
.../flink/runtime/types/IntegerRecord.java | 24 ++-
.../apache/flink/runtime/util/AtomicEnum.java | 24 ++-
.../flink/runtime/util/AtomicEnumerator.java | 24 ++-
.../flink/runtime/util/BufferPoolConnector.java | 24 ++-
.../flink/runtime/util/EmptyIterator.java | 24 ++-
.../util/EmptyMutableObjectIterator.java | 24 ++-
.../apache/flink/runtime/util/EnumUtils.java | 24 ++-
.../runtime/util/EnvironmentInformation.java | 26 +--
.../apache/flink/runtime/util/FileUtils.java | 24 ++-
.../org/apache/flink/runtime/util/IOUtils.java | 24 ++-
.../flink/runtime/util/JarFileCreator.java | 24 ++-
.../flink/runtime/util/KeyGroupedIterator.java | 24 ++-
.../util/KeyGroupedMutableObjectIterator.java | 24 ++-
.../apache/flink/runtime/util/MathUtils.java | 24 ++-
.../flink/runtime/util/MemoryBlockIterator.java | 44 +++--
.../util/MutableToRegularIteratorWrapper.java | 24 ++-
.../flink/runtime/util/NativeCodeLoader.java | 24 ++-
.../util/RegularToMutableObjectIterator.java | 26 +--
.../flink/runtime/util/ResettableIterator.java | 24 ++-
.../util/ResettableMutableObjectIterator.java | 24 ++-
.../runtime/util/SerializableArrayList.java | 24 ++-
.../flink/runtime/util/SerializableHashMap.java | 24 ++-
.../flink/runtime/util/SerializableHashSet.java | 24 ++-
.../runtime/util/SingleElementIterator.java | 26 +--
.../runtime/util/UnmodifiableIterator.java | 24 ++-
.../apache/flink/runtime/AbstractIDTest.java | 24 ++-
.../flink/runtime/client/JobResultTest.java | 24 ++-
.../ChannelDeploymentDescriptorTest.java | 24 ++-
.../GateDeploymentDescriptorTest.java | 24 ++-
.../TaskDeploymentDescriptorTest.java | 24 ++-
.../flink/runtime/event/job/JobEventTest.java | 24 ++-
.../runtime/event/job/ManagementEventTest.java | 24 ++-
.../task/EventNotificationManagerTest.java | 24 ++-
.../flink/runtime/event/task/TaskEventTest.java | 24 ++-
.../executiongraph/ExecutionGraphTest.java | 24 ++-
.../ForwardTask1Input1Output.java | 24 ++-
.../ForwardTask1Input2Outputs.java | 24 ++-
.../ForwardTask2Inputs1Output.java | 24 ++-
.../executiongraph/SelfCrossForwardTask.java | 24 ++-
.../FileCacheDeleteValidationTest.java | 24 ++-
.../org/apache/flink/runtime/fs/LineReader.java | 24 ++-
.../apache/flink/runtime/fs/LineReaderTest.java | 24 ++-
.../flink/runtime/fs/s3/S3FileSystemTest.java | 24 ++-
.../instance/DefaultInstanceManagerTest.java | 24 ++-
.../DefaultInstanceManagerTestUtils.java | 24 ++-
.../runtime/instance/HostInClusterTest.java | 24 ++-
.../runtime/instance/TestInstanceListener.java | 24 ++-
.../local/LocalInstanceManagerTest.java | 24 ++-
.../instance/local/TestInstanceListener.java | 24 ++-
.../flink/runtime/io/disk/ChannelViewsTest.java | 24 ++-
.../runtime/io/disk/SpillingBufferTest.java | 24 ++-
.../io/disk/iomanager/IOManagerITCase.java | 24 ++-
.../IOManagerPerformanceBenchmark.java | 24 ++-
.../io/disk/iomanager/IOManagerTest.java | 24 ++-
.../io/network/DefaultChannelSelectorTest.java | 24 ++-
.../bufferprovider/LocalBufferPoolTest.java | 24 ++-
.../netty/InboundEnvelopeDecoderTest.java | 24 ++-
.../netty/NettyConnectionManagerTest.java | 24 ++-
.../netty/OutboundEnvelopeEncoderTest.java | 24 ++-
.../DataInputOutputSerializerTest.java | 24 ++-
.../network/serialization/PagedViewsTest.java | 24 ++-
.../SpanningRecordSerializationTest.java | 24 ++-
.../SpanningRecordSerializerTest.java | 24 ++-
.../serialization/types/AsciiStringType.java | 24 ++-
.../serialization/types/BooleanType.java | 24 ++-
.../serialization/types/ByteArrayType.java | 24 ++-
.../serialization/types/ByteSubArrayType.java | 24 ++-
.../network/serialization/types/ByteType.java | 24 ++-
.../network/serialization/types/CharType.java | 24 ++-
.../network/serialization/types/DoubleType.java | 24 ++-
.../network/serialization/types/FloatType.java | 24 ++-
.../io/network/serialization/types/IntType.java | 24 ++-
.../network/serialization/types/LongType.java | 24 ++-
.../types/SerializationTestType.java | 24 ++-
.../types/SerializationTestTypeFactory.java | 24 ++-
.../network/serialization/types/ShortType.java | 24 ++-
.../serialization/types/UnsignedByteType.java | 24 ++-
.../serialization/types/UnsignedShortType.java | 24 ++-
.../io/network/serialization/types/Util.java | 24 ++-
.../concurrent/BlockingBackChannelTest.java | 24 ++-
.../iterative/concurrent/BrokerTest.java | 24 ++-
.../iterative/concurrent/StringPair.java | 24 ++-
.../concurrent/SuperstepBarrierTest.java | 24 ++-
.../event/EventWithAggregatorsTest.java | 24 ++-
.../flink/runtime/jobgraph/JobGraphTest.java | 24 ++-
.../runtime/jobmanager/DoubleSourceTask.java | 24 ++-
.../runtime/jobmanager/DoubleTargetTask.java | 24 ++-
.../jobmanager/ExceptionOutputFormat.java | 24 ++-
.../flink/runtime/jobmanager/ExceptionTask.java | 24 ++-
.../flink/runtime/jobmanager/ForwardTask.java | 24 ++-
.../runtime/jobmanager/JobManagerITCase.java | 24 ++-
.../jobmanager/RuntimeExceptionTask.java | 24 ++-
.../flink/runtime/jobmanager/UnionTask.java | 24 ++-
.../scheduler/DefaultSchedulerTest.java | 24 ++-
.../scheduler/TestDeploymentManager.java | 24 ++-
.../scheduler/TestInstanceManager.java | 24 ++-
.../managementgraph/ManagementGraphTest.java | 24 ++-
.../memory/DefaultMemoryManagerTest.java | 24 ++-
.../memory/MemorySegmentSpeedBenchmark.java | 24 ++-
.../flink/runtime/memory/MemorySegmentTest.java | 24 ++-
.../runtime/operators/CachedMatchTaskTest.java | 24 ++-
.../operators/CoGroupTaskExternalITCase.java | 24 ++-
.../runtime/operators/CoGroupTaskTest.java | 24 ++-
.../operators/CombineTaskExternalITCase.java | 24 ++-
.../runtime/operators/CombineTaskTest.java | 24 ++-
.../operators/CrossTaskExternalITCase.java | 24 ++-
.../flink/runtime/operators/CrossTaskTest.java | 24 ++-
.../runtime/operators/DataSinkTaskTest.java | 24 ++-
.../runtime/operators/DataSourceTaskTest.java | 24 ++-
.../flink/runtime/operators/MapTaskTest.java | 24 ++-
.../operators/MatchTaskExternalITCase.java | 24 ++-
.../flink/runtime/operators/MatchTaskTest.java | 24 ++-
.../operators/ReduceTaskExternalITCase.java | 24 ++-
.../flink/runtime/operators/ReduceTaskTest.java | 24 ++-
.../operators/chaining/ChainTaskTest.java | 24 ++-
.../drivers/AllGroupReduceDriverTest.java | 26 +--
.../operators/drivers/AllReduceDriverTest.java | 26 +--
.../operators/drivers/DriverTestData.java | 26 +--
.../operators/drivers/GatheringCollector.java | 26 +--
.../drivers/GroupReduceDriverTest.java | 26 +--
.../drivers/ReduceCombineDriverTest.java | 26 +--
.../operators/drivers/ReduceDriverTest.java | 26 +--
.../operators/drivers/TestTaskContext.java | 26 +--
.../hash/HashFunctionCollisionBenchmark.java | 24 ++-
.../operators/hash/HashMatchIteratorITCase.java | 24 ++-
.../runtime/operators/hash/HashTableITCase.java | 24 ++-
.../hash/HashTablePerformanceComparison.java | 26 +--
.../operators/hash/MemoryHashTableTest.java | 26 +--
.../hash/ReOpenableHashTableITCase.java | 24 ++-
.../operators/hash/util/LastBitsToRange.java | 24 ++-
.../operators/hash/util/RandomIterator.java | 24 ++-
.../operators/hash/util/RangeCalculator.java | 24 ++-
.../operators/hash/util/RangeIterator.java | 24 ++-
.../operators/hash/util/StepRangeIterator.java | 24 ++-
.../resettable/BlockResettableIteratorTest.java | 24 ++-
...lockResettableMutableObjectIteratorTest.java | 24 ++-
.../SpillingResettableIteratorTest.java | 24 ++-
...lingResettableMutableObjectIteratorTest.java | 24 ++-
.../sort/AsynchonousPartialSorterITCase.java | 24 ++-
.../CombiningUnilateralSortMergerITCase.java | 24 ++-
.../operators/sort/ExternalSortITCase.java | 24 ++-
.../sort/FixedLengthRecordSorterTest.java | 24 ++-
.../sort/MassiveStringSortingITCase.java | 26 +--
.../operators/sort/MergeIteratorTest.java | 24 ++-
.../operators/sort/MockRecordReader.java | 24 ++-
.../operators/sort/NormalizedKeySorterTest.java | 24 ++-
.../sort/SortMergeCoGroupIteratorITCase.java | 24 ++-
.../sort/SortMergeMatchIteratorITCase.java | 24 ++-
.../DelayingInfinitiveInputIterator.java | 24 ++-
.../testutils/DiscardingOutputCollector.java | 24 ++-
.../operators/testutils/DriverTestBase.java | 24 ++-
.../operators/testutils/DummyInvokable.java | 24 ++-
.../testutils/ExpectedTestException.java | 24 ++-
.../testutils/InfiniteInputIterator.java | 24 ++-
.../operators/testutils/MockEnvironment.java | 24 ++-
.../testutils/MockInputSplitProvider.java | 24 ++-
.../testutils/MutableObjectIteratorWrapper.java | 24 ++-
.../operators/testutils/NirvanaOutputList.java | 24 ++-
.../testutils/RandomIntPairGenerator.java | 24 ++-
.../operators/testutils/TaskCancelThread.java | 24 ++-
.../operators/testutils/TaskTestBase.java | 24 ++-
.../runtime/operators/testutils/TestData.java | 24 ++-
.../testutils/UniformIntPairGenerator.java | 24 ++-
.../testutils/UniformRecordGenerator.java | 24 ++-
.../testutils/UniformStringPairGenerator.java | 26 +--
.../operators/testutils/UnionIterator.java | 24 ++-
.../operators/testutils/types/IntList.java | 26 +--
.../testutils/types/IntListComparator.java | 26 +--
.../testutils/types/IntListPairComparator.java | 26 +--
.../testutils/types/IntListSerializer.java | 26 +--
.../operators/testutils/types/IntPair.java | 24 ++-
.../testutils/types/IntPairComparator.java | 24 ++-
.../types/IntPairListPairComparator.java | 26 +--
.../testutils/types/IntPairPairComparator.java | 24 ++-
.../testutils/types/IntPairSerializer.java | 24 ++-
.../testutils/types/IntValueSerializer.java | 24 ++-
.../operators/testutils/types/StringPair.java | 26 +--
.../testutils/types/StringPairComparator.java | 26 +--
.../types/StringPairPairComparator.java | 26 +--
.../testutils/types/StringPairSerializer.java | 26 +--
.../operators/util/HashVsSortMiniBenchmark.java | 24 ++-
.../operators/util/OutputEmitterTest.java | 24 ++-
.../operators/util/RecordOutputEmitterTest.java | 24 ++-
.../profiling/impl/InstanceProfilerTest.java | 24 ++-
.../profiling/types/ProfilingTypesTest.java | 24 ++-
.../runtime/testutils/CommonTestUtils.java | 24 ++-
.../runtime/testutils/DiscardingRecycler.java | 26 +--
.../testutils/InterruptibleByteChannel.java | 24 ++-
.../runtime/testutils/ManagementTestUtils.java | 24 ++-
.../runtime/testutils/ServerTestUtils.java | 24 ++-
.../runtime/testutils/TestBufferProvider.java | 26 +--
.../testutils/tasks/DoubleSourceTask.java | 26 +--
.../runtime/testutils/tasks/FileLineReader.java | 26 +--
.../runtime/testutils/tasks/FileLineWriter.java | 26 +--
.../testutils/tasks/JobFileInputVertex.java | 26 +--
.../testutils/tasks/JobFileOutputVertex.java | 26 +--
.../runtime/topology/NetworkTopologyTest.java | 24 ++-
.../flink/runtime/types/StringRecordTest.java | 24 ++-
.../apache/flink/runtime/types/TypeTest.java | 24 ++-
.../runtime/util/KeyGroupedIteratorTest.java | 24 ++-
.../apache/flink/runtime/util/MathUtilTest.java | 24 ++-
.../util/TestDelegatingConfiguration.java | 24 ++-
flink-scala/pom.xml | 13 ++
.../flink/api/scala/operators/Annotations.java | 24 ++-
.../apache/flink/api/scala/AnnotationUtil.scala | 24 ++-
.../apache/flink/api/scala/CompilerHints.scala | 24 ++-
.../org/apache/flink/api/scala/DataSet.scala | 24 ++-
.../org/apache/flink/api/scala/DataSink.scala | 24 ++-
.../org/apache/flink/api/scala/DataSource.scala | 24 ++-
.../apache/flink/api/scala/ScalaOperator.scala | 24 ++-
.../org/apache/flink/api/scala/ScalaPlan.scala | 24 ++-
.../flink/api/scala/analysis/Extractors.scala | 24 ++-
.../api/scala/analysis/FieldSelector.scala | 24 ++-
.../api/scala/analysis/GlobalSchemaFields.scala | 24 ++-
.../scala/analysis/GlobalSchemaGenerator.scala | 24 ++-
.../scala/analysis/GlobalSchemaPrinter.scala | 24 ++-
.../scala/analysis/UserDefinedFunction.scala | 24 ++-
.../api/scala/analysis/UserDefinedType.scala | 24 ++-
.../scala/analysis/postPass/Extractors.scala | 24 ++-
.../postPass/GlobalSchemaCompactor.scala | 29 +--
.../postPass/GlobalSchemaOptimizer.scala | 24 ++-
.../analysis/postPass/GlobalSchemaPrinter.scala | 24 ++-
.../scala/analysis/postPass/OutputSets.scala | 24 ++-
.../flink/api/scala/codegen/Counter.scala | 24 ++-
.../scala/codegen/DeserializeMethodGen.scala | 24 ++-
.../apache/flink/api/scala/codegen/Logger.scala | 24 ++-
.../api/scala/codegen/MacroContextHolder.scala | 24 ++-
.../api/scala/codegen/SelectionExtractor.scala | 24 ++-
.../api/scala/codegen/SerializeMethodGen.scala | 24 ++-
.../flink/api/scala/codegen/SerializerGen.scala | 24 ++-
.../flink/api/scala/codegen/TreeGen.scala | 24 ++-
.../flink/api/scala/codegen/UDTAnalyzer.scala | 24 ++-
.../api/scala/codegen/UDTDescriptors.scala | 24 ++-
.../apache/flink/api/scala/codegen/UDTGen.scala | 24 ++-
.../apache/flink/api/scala/codegen/Util.scala | 24 ++-
.../api/scala/functions/CoGroupFunction.scala | 21 ++-
.../api/scala/functions/CrossFunction.scala | 24 ++-
.../scala/functions/DeserializingIterator.scala | 24 ++-
.../api/scala/functions/JoinFunction.scala | 24 ++-
.../flink/api/scala/functions/MapFunction.scala | 24 ++-
.../api/scala/functions/ReduceFunction.scala | 24 ++-
.../api/scala/operators/ClosureCleaner.scala | 24 ++-
.../api/scala/operators/CoGroupOperator.scala | 24 ++-
.../api/scala/operators/CopyOperator.scala | 24 ++-
.../api/scala/operators/CrossOperator.scala | 24 ++-
.../api/scala/operators/DataSinkMacros.scala | 24 ++-
.../api/scala/operators/DataSourceMacros.scala | 24 ++-
.../api/scala/operators/IterateOperators.scala | 24 ++-
.../api/scala/operators/JoinOperator.scala | 24 ++-
.../flink/api/scala/operators/MapOperator.scala | 24 ++-
.../api/scala/operators/ReduceOperator.scala | 24 ++-
.../api/scala/operators/UnionOperator.scala | 24 ++-
.../flink/api/scala/operators/package.scala | 24 ++-
.../api/scala/CollectionDataSourceTest.scala | 24 ++-
flink-test-utils/pom.xml | 13 ++
.../test/compiler/util/CompilerTestBase.java | 24 ++-
.../test/compiler/util/OperatorResolver.java | 26 +--
.../test/testdata/ConnectedComponentsData.java | 26 +--
.../flink/test/testdata/EnumTriangleData.java | 26 +--
.../apache/flink/test/testdata/KMeansData.java | 26 +--
.../flink/test/testdata/PageRankData.java | 26 +--
.../test/testdata/TransitiveClosureData.java | 26 +--
.../flink/test/testdata/WordCountData.java | 26 +--
.../flink/test/util/AbstractTestBase.java | 24 ++-
.../flink/test/util/JavaProgramTestBase.java | 24 ++-
.../flink/test/util/RecordAPITestBase.java | 24 ++-
flink-tests/pom.xml | 13 ++
.../test/accumulators/AccumulatorITCase.java | 24 ++-
.../AccumulatorIterativeITCase.java | 24 ++-
.../broadcastvars/BroadcastBranchingITCase.java | 26 +--
.../BroadcastVarsNepheleITCase.java | 26 +--
.../KMeansIterativeNepheleITCase.java | 26 +--
.../test/cancelling/CancellingTestBase.java | 24 ++-
.../test/cancelling/MapCancelingITCase.java | 24 ++-
.../cancelling/MatchJoinCancelingITCase.java | 24 ++-
.../clients/examples/LocalExecutorITCase.java | 24 ++-
.../compiler/examples/KMeansSingleStepTest.java | 24 ++-
.../examples/RelationalQueryCompilerTest.java | 24 ++-
.../examples/WordCountCompilerTest.java | 24 ++-
.../ConnectedComponentsCoGroupTest.java | 24 ++-
.../iterations/ConnectedComponentsTest.java | 24 ++-
.../iterations/IterativeKMeansTest.java | 24 ++-
...ultipleJoinsWithSolutionSetCompilerTest.java | 24 ++-
.../iterations/PageRankCompilerTest.java | 26 +--
.../compiler/plandump/DumpCompiledPlanTest.java | 24 ++-
.../compiler/plandump/PreviewPlanDumpTest.java | 24 ++-
.../distributedCache/DistributedCacheTest.java | 24 ++-
.../ConnectedComponentsITCase.java | 24 ++-
.../EnumTriangleBasicITCase.java | 26 +--
.../EnumTriangleOptITCase.java | 26 +--
.../exampleJavaPrograms/PageRankITCase.java | 26 +--
.../TransitiveClosureITCase.java | 24 ++-
.../WebLogAnalysisITCase.java | 26 +--
.../exampleJavaPrograms/WordCountITCase.java | 26 +--
.../WordCountPOJOITCase.java | 26 +--
.../WordCountWithCollectionITCase.java | 26 +--
.../ComputeEdgeDegreesITCase.java | 24 ++-
.../ConnectedComponentsITCase.java | 24 ++-
.../EnumTrianglesOnEdgesWithDegreesITCase.java | 24 ++-
.../IterativeKMeansITCase.java | 24 ++-
.../RelationalQueryITCase.java | 24 ++-
.../TransitiveClosureNaiveITCase.java | 24 ++-
.../WebLogAnalysisITCase.java | 24 ++-
.../exampleScalaPrograms/WordCountITCase.java | 24 ++-
.../WordCountPactValueITCase.java | 24 ++-
.../WordCountWithCountFunctionITCase.java | 24 ++-
.../test/failingPrograms/TaskFailureITCase.java | 24 ++-
.../BulkIterationWithAllReducerITCase.java | 24 ++-
.../CoGroupConnectedComponentsITCase.java | 24 ++-
.../CoGroupConnectedComponentsSecondITCase.java | 24 ++-
.../iterative/ConnectedComponentsITCase.java | 24 ++-
...ectedComponentsWithDeferredUpdateITCase.java | 24 ++-
...tedComponentsWithSolutionSetFirstITCase.java | 24 ++-
.../test/iterative/DanglingPageRankITCase.java | 24 ++-
.../test/iterative/DeltaPageRankITCase.java | 24 ++-
.../DependencyConnectedComponentsITCase.java | 24 ++-
...IterationTerminationWithTerminationTail.java | 24 ++-
.../IterationTerminationWithTwoTails.java | 24 ++-
.../IterationWithAllReducerITCase.java | 24 ++-
.../iterative/IterationWithChainingITCase.java | 24 ++-
.../iterative/IterationWithUnionITCase.java | 24 ++-
.../test/iterative/IterativeKMeansITCase.java | 24 ++-
.../flink/test/iterative/KMeansITCase.java | 24 ++-
.../flink/test/iterative/LineRankITCase.java | 24 ++-
.../MultipleSolutionSetJoinsITCase.java | 26 +--
.../flink/test/iterative/PageRankITCase.java | 24 ++-
.../aggregators/AggregatorsITCase.java | 26 +--
...nentsWithParametrizableAggregatorITCase.java | 24 ++-
...entsWithParametrizableConvergenceITCase.java | 24 ++-
.../test/iterative/nephele/ConfigUtils.java | 24 ++-
.../ConnectedComponentsNepheleITCase.java | 24 ++-
.../nephele/DanglingPageRankNepheleITCase.java | 24 ++-
...nglingPageRankWithCombinerNepheleITCase.java | 24 ++-
.../IterationWithChainingNepheleITCase.java | 24 ++-
.../test/iterative/nephele/JobGraphUtils.java | 24 ++-
.../CustomCompensatableDanglingPageRank.java | 24 ++-
...mpensatableDanglingPageRankWithCombiner.java | 24 ++-
.../CustomCompensatableDotProductCoGroup.java | 24 ++-
.../CustomCompensatableDotProductMatch.java | 24 ++-
.../CustomCompensatingMap.java | 24 ++-
.../CustomImprovedAdjacencyListInputFormat.java | 24 ++-
...stomImprovedDanglingPageRankInputFormat.java | 24 ++-
.../CustomPageWithRankOutFormat.java | 24 ++-
.../CustomRankCombiner.java | 24 ++-
.../types/VertexWithAdjacencyList.java | 24 ++-
.../VertexWithAdjacencyListComparator.java | 24 ++-
...ertexWithAdjacencyListComparatorFactory.java | 24 ++-
.../VertexWithAdjacencyListSerializer.java | 24 ++-
...ertexWithAdjacencyListSerializerFactory.java | 24 ++-
.../types/VertexWithRank.java | 24 ++-
.../types/VertexWithRankAndDangling.java | 24 ++-
.../VertexWithRankAndDanglingComparator.java | 24 ++-
...texWithRankAndDanglingComparatorFactory.java | 24 ++-
.../VertexWithRankAndDanglingSerializer.java | 24 ++-
...texWithRankAndDanglingSerializerFactory.java | 24 ++-
.../types/VertexWithRankComparator.java | 24 ++-
.../types/VertexWithRankComparatorFactory.java | 24 ++-
...xWithAdjacencyListPairComparatorFactory.java | 24 ++-
...ngToVertexWithRankPairComparatorFactory.java | 24 ++-
.../types/VertexWithRankSerializer.java | 24 ++-
.../types/VertexWithRankSerializerFactory.java | 24 ++-
.../danglingpagerank/AsciiLongArrayView.java | 24 ++-
.../nephele/danglingpagerank/BooleanValue.java | 24 ++-
.../CompensatableDanglingPageRank.java | 24 ++-
.../CompensatableDotProductCoGroup.java | 24 ++-
.../CompensatableDotProductMatch.java | 24 ++-
.../danglingpagerank/CompensatingMap.java | 24 ++-
.../DanglingPageGenerateRankInputFormat.java | 24 ++-
.../DiffL1NormConvergenceCriterion.java | 24 ++-
.../ImprovedAdjacencyListInputFormat.java | 24 ++-
.../ImprovedDanglingPageRankInputFormat.java | 24 ++-
.../nephele/danglingpagerank/LongArrayView.java | 24 ++-
.../nephele/danglingpagerank/PageRankStats.java | 24 ++-
.../PageRankStatsAggregator.java | 24 ++-
.../danglingpagerank/PageWithRankOutFormat.java | 24 ++-
.../test/javaApiOperators/AggregateITCase.java | 26 +--
.../test/javaApiOperators/CoGroupITCase.java | 26 +--
.../test/javaApiOperators/CrossITCase.java | 26 +--
.../test/javaApiOperators/DistinctITCase.java | 26 +--
.../test/javaApiOperators/FilterITCase.java | 26 +--
.../test/javaApiOperators/FlatMapITCase.java | 26 +--
.../javaApiOperators/GroupReduceITCase.java | 26 +--
.../flink/test/javaApiOperators/JoinITCase.java | 26 +--
.../flink/test/javaApiOperators/MapITCase.java | 26 +--
.../test/javaApiOperators/ProjectITCase.java | 26 +--
.../test/javaApiOperators/ReduceITCase.java | 26 +--
.../test/javaApiOperators/SumMinMaxITCase.java | 26 +--
.../test/javaApiOperators/UnionITCase.java | 26 +--
.../util/CollectionDataSets.java | 26 +--
.../PackagedProgramEndToEndITCase.java | 24 ++-
.../flink/test/operators/CoGroupITCase.java | 24 ++-
.../flink/test/operators/CrossITCase.java | 24 ++-
.../apache/flink/test/operators/JoinITCase.java | 24 ++-
.../apache/flink/test/operators/MapITCase.java | 24 ++-
.../flink/test/operators/ReduceITCase.java | 24 ++-
.../flink/test/operators/UnionITCase.java | 24 ++-
.../flink/test/operators/UnionSinkITCase.java | 24 ++-
.../operators/io/ContractITCaseIOFormats.java | 24 ++-
.../recordJobTests/CollectionSourceTest.java | 24 ++-
.../CollectionValidationTest.java | 24 ++-
.../ComputeEdgeDegreesITCase.java | 24 ++-
.../EnumTrianglesOnEdgesWithDegreesITCase.java | 24 ++-
.../recordJobTests/EnumTrianglesRDFITCase.java | 24 ++-
.../recordJobTests/GlobalSortingITCase.java | 24 ++-
.../GlobalSortingMixedOrderITCase.java | 24 ++-
.../recordJobTests/GroupOrderReduceITCase.java | 24 ++-
.../recordJobTests/MergeOnlyJoinITCase.java | 24 ++-
.../test/recordJobTests/PairwiseSPITCase.java | 24 ++-
.../test/recordJobTests/TPCHQuery10ITCase.java | 24 ++-
.../test/recordJobTests/TPCHQuery3ITCase.java | 24 ++-
.../TPCHQuery3WithUnionITCase.java | 24 ++-
.../test/recordJobTests/TPCHQuery4ITCase.java | 24 ++-
.../test/recordJobTests/TPCHQuery9ITCase.java | 24 ++-
.../recordJobTests/TPCHQueryAsterixITCase.java | 24 ++-
.../test/recordJobTests/TeraSortITCase.java | 24 ++-
.../recordJobTests/WebLogAnalysisITCase.java | 24 ++-
.../test/recordJobTests/WordCountITCase.java | 24 ++-
.../WordCountUnionReduceITCase.java | 24 ++-
.../recordJobs/graph/ComputeEdgeDegrees.java | 24 ++-
.../graph/ConnectedComponentsWithCoGroup.java | 24 ++-
.../test/recordJobs/graph/DanglingPageRank.java | 24 ++-
.../graph/DeltaPageRankWithInitialDeltas.java | 24 ++-
.../graph/EnumTrianglesOnEdgesWithDegrees.java | 24 ++-
.../recordJobs/graph/EnumTrianglesRdfFoaf.java | 24 ++-
.../graph/EnumTrianglesWithDegrees.java | 24 ++-
.../flink/test/recordJobs/graph/PairwiseSP.java | 24 ++-
.../test/recordJobs/graph/SimplePageRank.java | 24 ++-
.../graph/WorksetConnectedComponents.java | 24 ++-
.../graph/pageRankUtil/AsciiLongArrayView.java | 24 ++-
.../DanglingPageRankInputFormat.java | 24 ++-
.../DiffL1NormConvergenceCriterion.java | 24 ++-
.../graph/pageRankUtil/DotProductCoGroup.java | 24 ++-
.../graph/pageRankUtil/DotProductMatch.java | 24 ++-
.../ImprovedAdjacencyListInputFormat.java | 24 ++-
.../graph/pageRankUtil/LongArrayView.java | 24 ++-
.../graph/pageRankUtil/PageRankStats.java | 24 ++-
.../pageRankUtil/PageRankStatsAggregator.java | 24 ++-
.../pageRankUtil/PageWithRankOutFormat.java | 24 ++-
.../graph/triangleEnumUtil/EdgeInputFormat.java | 24 ++-
.../EdgeWithDegreesInputFormat.java | 24 ++-
.../EdgeWithDegreesOutputFormat.java | 24 ++-
.../triangleEnumUtil/TriangleOutputFormat.java | 24 ++-
.../test/recordJobs/kmeans/KMeansBroadcast.java | 24 ++-
.../test/recordJobs/kmeans/KMeansCross.java | 24 ++-
.../recordJobs/kmeans/KMeansSingleStep.java | 24 ++-
.../recordJobs/kmeans/udfs/ComputeDistance.java | 24 ++-
.../udfs/ComputeDistanceParameterized.java | 24 ++-
.../recordJobs/kmeans/udfs/CoordVector.java | 24 ++-
.../kmeans/udfs/FindNearestCenter.java | 24 ++-
.../recordJobs/kmeans/udfs/PointInFormat.java | 24 ++-
.../recordJobs/kmeans/udfs/PointOutFormat.java | 24 ++-
.../kmeans/udfs/RecomputeClusterCenter.java | 24 ++-
.../recordJobs/relational/MergeOnlyJoin.java | 24 ++-
.../test/recordJobs/relational/TPCHQuery1.java | 24 ++-
.../test/recordJobs/relational/TPCHQuery10.java | 24 ++-
.../test/recordJobs/relational/TPCHQuery3.java | 24 ++-
.../relational/TPCHQuery3Unioned.java | 24 ++-
.../test/recordJobs/relational/TPCHQuery4.java | 24 ++-
.../test/recordJobs/relational/TPCHQuery9.java | 24 ++-
.../recordJobs/relational/TPCHQueryAsterix.java | 24 ++-
.../recordJobs/relational/WebLogAnalysis.java | 24 ++-
.../query1Util/GroupByReturnFlag.java | 24 ++-
.../relational/query1Util/LineItemFilter.java | 24 ++-
.../query1Util/LineItemFilterTest.java | 24 ++-
.../relational/query9Util/AmountAggregate.java | 24 ++-
.../query9Util/FilteredPartsJoin.java | 24 ++-
.../relational/query9Util/IntPair.java | 24 ++-
.../relational/query9Util/LineItemMap.java | 24 ++-
.../relational/query9Util/OrderMap.java | 24 ++-
.../relational/query9Util/OrderedPartsJoin.java | 24 ++-
.../relational/query9Util/PartFilter.java | 24 ++-
.../relational/query9Util/PartJoin.java | 24 ++-
.../relational/query9Util/PartListJoin.java | 24 ++-
.../relational/query9Util/PartsuppMap.java | 24 ++-
.../relational/query9Util/StringIntPair.java | 24 ++-
.../StringIntPairStringDataOutFormat.java | 24 ++-
.../relational/query9Util/SupplierMap.java | 24 ++-
.../relational/query9Util/SuppliersJoin.java | 24 ++-
.../test/recordJobs/sort/ReduceGroupSort.java | 24 ++-
.../flink/test/recordJobs/sort/TeraSort.java | 24 ++-
.../sort/tsUtil/TeraDistribution.java | 24 ++-
.../recordJobs/sort/tsUtil/TeraInputFormat.java | 24 ++-
.../test/recordJobs/sort/tsUtil/TeraKey.java | 24 ++-
.../sort/tsUtil/TeraOutputFormat.java | 24 ++-
.../test/recordJobs/sort/tsUtil/TeraValue.java | 24 ++-
.../flink/test/recordJobs/util/ConfigUtils.java | 25 ++-
.../recordJobs/util/DiscardingOutputFormat.java | 24 ++-
.../util/InfiniteIntegerInputFormat.java | 24 ++-
.../InfiniteIntegerInputFormatWithDelay.java | 24 ++-
.../recordJobs/util/IntTupleDataInFormat.java | 24 ++-
.../util/StringTupleDataOutFormat.java | 24 ++-
.../flink/test/recordJobs/util/Tuple.java | 24 ++-
.../test/recordJobs/util/UniformIntInput.java | 24 ++-
.../test/recordJobs/wordcount/WordCount.java | 24 ++-
.../wordcount/WordCountAccumulators.java | 24 ++-
.../test/runtime/NetworkStackThroughput.java | 24 ++-
.../util/tests/IntTupleDataInFormatTest.java | 24 ++-
.../test/testPrograms/util/tests/TupleTest.java | 24 ++-
.../flink/test/testdata/WebLogAnalysisData.java | 26 +--
.../apache/flink/test/util/FailingTestBase.java | 24 ++-
.../flink/test/util/testjar/KMeansForTest.java | 26 +--
pom.xml | 13 ++
tools/change-version | 25 ++-
tools/deploy_to_maven.sh | 26 ++-
tools/generate_specific_pom.sh | 26 ++-
tools/maven/checkstyle.xml | 13 ++
tools/maven/suppressions.xml | 13 ++
tools/merge_flink_pr.py | 2 +-
1842 files changed, 27929 insertions(+), 17704 deletions(-)
----------------------------------------------------------------------