Github user flinkqa commented on the pull request:
https://github.com/apache/flink/pull/792#issuecomment-109311974
Tested pull request.Result:
From http://git-wip-us.apache.org/repos/asf/flink
92d3251..9b88184 master -> origin/master
Updating 11643c0..9b88184
Fast-forward
docs/README.md | 4 +-
docs/apis/iterations.md | 2 +-
docs/apis/streaming_guide.md | 19 +-
docs/apis/web_client.md | 2 +-
docs/scala_shell.md | 2 +-
.../common/operators/base/JoinOperatorBase.java | 2 +-
.../flink/api/common/typeinfo/TypeInformation.java | 3 -
flink-dist/pom.xml | 10 +
flink-dist/src/main/flink-bin/bin/flink | 4 +-
.../PlanUnwrappingSortedReduceGroupOperator.java | 8 +-
.../runtime/io/network/netty/NettyMessage.java | 20 +
.../io/network/netty/PartitionRequestClient.java | 15 +-
.../io/network/netty/PartitionRequestQueue.java | 6 +
.../netty/PartitionRequestServerHandler.java | 4 +
.../jobgraph/tasks/CheckpointedOperator.java | 16 +-
.../runtime/operators/hash/MutableHashTable.java | 6 +-
.../netty/NettyMessageSerializationTest.java | 7 +
.../runtime/operators/hash/HashTableITCase.java | 76 ++++
flink-staging/flink-hbase/pom.xml | 6 +
.../hbase/example/HBaseWriteStreamExample.java | 119 ++++++
.../org/apache/flink/ml/classification/SVM.scala | 8 +-
.../org/apache/flink/ml/pipeline/Estimator.scala | 2 +-
.../org/apache/flink/ml/pipeline/Predictor.scala | 2 +-
.../ml/regression/MultipleLinearRegression.scala | 362 ++---------------
.../apache/flink/ml/pipeline/PipelineITSuite.scala | 6 +-
.../MultipleLinearRegressionITSuite.scala | 18 +-
.../flink/ml/regression/RegressionData.scala | 4 +-
.../apache/flink/api/scala/ScalaShellITSuite.scala | 8 +-
.../connectors/kafka/KafkaProducerExample.java | 65 ++-
.../connectors/kafka/api/KafkaSource.java | 91 +++--
.../api/persistent/PersistentKafkaSource.java | 105 ++---
.../streaming/connectors/kafka/KafkaITCase.java | 252 +++++++-----
.../streaming/connectors/rabbitmq/RMQSource.java | 49 +--
.../connectors/twitter/TwitterSource.java | 47 +--
.../connectors/twitter/TwitterStreaming.java | 32 +-
.../connectors/twitter/TwitterTopology.java | 42 +-
.../flink/streaming/api/datastream/DataStream.java | 56 +--
.../api/functions/source/ConnectorSource.java | 4 +-
.../functions/source/FileMonitoringFunction.java | 90 ++---
.../api/functions/source/FileSourceFunction.java | 43 +-
.../api/functions/source/FromElementsFunction.java | 26 +-
.../api/functions/source/FromIteratorFunction.java | 14 +-
.../source/FromSplittableIteratorFunction.java | 18 +-
.../functions/source/ParallelSourceFunction.java | 2 +-
.../source/RichParallelSourceFunction.java | 11 +-
.../functions/source/SocketTextStreamFunction.java | 149 ++++---
.../api/functions/source/SourceFunction.java | 126 +++---
.../api/operators/AbstractStreamOperator.java | 2 +-
.../api/operators/AbstractUdfStreamOperator.java | 9 +-
.../streaming/api/operators/StreamSource.java | 30 +-
.../streaming/runtime/tasks/SourceStreamTask.java | 20 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 12 +-
.../streaming/api/ChainedRuntimeContextTest.java | 6 +-
.../apache/flink/streaming/api/TypeFillTest.java | 11 +-
.../api/complex/ComplexIntegrationTest.java | 79 ++--
.../operators/windowing/WindowIntegrationTest.java | 28 +-
.../streaming/api/streamtask/StreamVertexTest.java | 15 +-
.../runtime/tasks/SourceStreamTaskTest.java | 248 ++++++++++++
.../runtime/tasks/StreamMockEnvironment.java | 277 +++++++++++++
.../runtime/tasks/StreamTaskTestBase.java | 109 +++++
.../apache/flink/streaming/util/MockSource.java | 18 +-
.../streaming/util/SocketProgramITCaseBase.java} | 15 +-
.../flink-streaming-examples/pom.xml | 23 --
.../examples/iteration/IterateExample.java | 22 +-
.../flink/streaming/examples/join/WindowJoin.java | 45 ++-
.../examples/ml/IncrementalLearningSkeleton.java | 77 ++--
.../examples/windowing/SessionWindowing.java | 55 +--
.../streaming/examples/windowing/StockPrices.java | 438
---------------------
.../windowing/TopSpeedWindowingExample.java | 104 ++---
.../util/TopSpeedWindowingExampleData.java | 43 +-
.../streaming/scala/examples/join/WindowJoin.scala | 124 ++++--
.../socket/SocketTextStreamWordCount.scala | 2 +-
.../scala/examples/windowing/StockPrices.scala | 228 -----------
.../examples/windowing/TopSpeedWindowing.scala | 67 +++-
.../iteration/IterateExampleITCase.java | 2 +-
.../join/WindowJoinITCase.java | 2 +-
.../ml/IncrementalLearningSkeletonITCase.java | 2 +-
.../socket/SocketTextStreamWordCountITCase.java | 30 ++
.../twitter/TwitterStreamITCase.java | 2 +-
.../windowing/SessionWindowingITCase.java | 2 +-
.../windowing/TopSpeedWindowingExampleITCase.java | 2 +-
.../windowing/WindowWordCountITCase.java | 2 +-
.../wordcount/PojoExampleITCase.java | 2 +-
.../wordcount/WordCountITCase.java | 2 +-
.../join/WindowJoinITCase.java | 50 +++
.../socket/SocketTextStreamWordCountITCase.java | 30 ++
.../windowing/TopSpeedWindowingExampleITCase.java | 45 +++
.../flink/streaming/api/scala/DataStream.scala | 23 +-
.../api/scala/StreamExecutionEnvironment.scala | 17 +-
.../flink/examples/java/JavaTableExample.java | 4 +-
.../flink/api/java/table/TableEnvironment.scala | 22 +-
.../api/java/table/test/AggregationsITCase.java | 25 +-
.../apache/flink/api/java/table/test/AsITCase.java | 25 +-
.../flink/api/java/table/test/CastingITCase.java | 13 +-
.../api/java/table/test/ExpressionsITCase.java | 25 +-
.../flink/api/java/table/test/FilterITCase.java | 21 +-
.../java/table/test/GroupedAggregationsITCase.java | 13 +-
.../flink/api/java/table/test/JoinITCase.java | 43 +-
.../flink/api/java/table/test/SelectITCase.java | 25 +-
.../java/table/test/StringExpressionsITCase.java | 17 +-
.../checkpointing/StreamCheckpointingITCase.java | 147 +++++--
.../flink/test/javaApiOperators/FirstNITCase.java | 29 ++
.../AbstractProcessFailureRecoveryTest.java | 13 +-
.../ProcessFailureStreamingRecoveryITCase.java | 180 ++++-----
pom.xml | 6 +-
105 files changed, 2641 insertions(+), 2250 deletions(-)
create mode 100644
flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
create mode 100644
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java
create mode 100644
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamMockEnvironment.java
create mode 100644
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestBase.java
rename
flink-staging/flink-streaming/{flink-streaming-examples/src/test/java/org/apache/flink/streaming/examples/test/socket/SocketTextStreamWordCountITCase.java
=>
flink-streaming-core/src/test/java/org/apache/flink/streaming/util/SocketProgramITCaseBase.java}
(82%)
delete mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
delete mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/StockPrices.scala
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/iteration/IterateExampleITCase.java (95%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/join/WindowJoinITCase.java (96%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/ml/IncrementalLearningSkeletonITCase.java (95%)
create mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleJavaPrograms/socket/SocketTextStreamWordCountITCase.java
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/twitter/TwitterStreamITCase.java (95%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/windowing/SessionWindowingITCase.java (95%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/windowing/TopSpeedWindowingExampleITCase.java
(96%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/windowing/WindowWordCountITCase.java (96%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/wordcount/PojoExampleITCase.java (95%)
rename
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/{examples/test
=> test/exampleJavaPrograms}/wordcount/WordCountITCase.java (95%)
create mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleScalaPrograms/join/WindowJoinITCase.java
create mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleScalaPrograms/socket/SocketTextStreamWordCountITCase.java
create mode 100644
flink-staging/flink-streaming/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleScalaPrograms/windowing/TopSpeedWindowingExampleITCase.java
Running ./tools/qa-check.sh
Computing Flink QA-Check results (please be patient).
:-1: The change increases the number of javadoc errors from 402 to
548
:-1: The change increases the number of compiler warnings from 702 to
850
```diff
First 100 warnings:
1,144c1,285
< [WARNING] bootstrap class path not set in conjunction with -source 1.6
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/util/OperatorUtil.java:[31,45]
org.apache.flink.api.common.functions.GenericCollectorMap in
org.apache.flink.api.common.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CollectorMapOperatorBase.java:[24,45]
org.apache.flink.api.common.functions.GenericCollectorMap in
org.apache.flink.api.common.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:[579,25]
found raw type: org.apache.flink.api.common.ExecutionConfig.Entry
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:[613,23]
serializable class
org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordPairComparator.java:[50,40]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordPairComparator.java:[51,40]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/types/Record.java:[1782,46]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/Operator.java:[231,81]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/AbstractUdfOperator.java:[142,40]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/AbstractUdfOperator.java:[154,40]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/DualInputOperator.java:[229,91]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/DualInputOperator.java:[241,91]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/Ordering.java:[116,47]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java:[968,38]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/SingleInputOperator.java:[130,83]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/SingleInputOperator.java:[153,89]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupReduceOperatorBase.java:[157,50]
unchecked cast
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java:[56,8]
serializable class org.apache.flink.api.common.typeinfo.BasicTypeInfo has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NumericTypeInfo.java:[27,8]
serializable class org.apache.flink.api.common.typeinfo.NumericTypeInfo has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/FractionalTypeInfo.java:[27,8]
serializable class org.apache.flink.api.common.typeinfo.FractionalTypeInfo has
no definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[38,34]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[56,34]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[62,45]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[78,55]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[154,34]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[157,55]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/distributions/SimpleDistribution.java:[170,47]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/GenericDataSourceBase.java:[49,17]
found raw type:
org.apache.flink.api.common.operators.GenericDataSourceBase.SplitDataProperties
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/GenericDataSourceBase.java:[184,28]
unchecked conversion
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/GenericDataSinkBase.java:[154,97]
found raw type: org.apache.flink.api.common.operators.Operator
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/IntegerTypeInfo.java:[27,8]
serializable class org.apache.flink.api.common.typeinfo.IntegerTypeInfo has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java:[124,25]
found raw type: org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java:[42,8]
Class org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo overrides
equals, but neither it nor any superclass overrides hashCode method
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java:[50,59]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java:[243,76]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java:[277,76]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java:[309,76]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java:[323,48]
found raw type: org.apache.flink.types.parser.FieldParser
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparatorFactory.java:[116,61]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[99,39]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[100,48]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[163,39]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[164,48]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[370,64]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/record/RecordComparator.java:[379,51]
found raw type: org.apache.flink.types.Key
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/base/GroupCombineOperatorBase.java:[85,50]
unchecked cast
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java:[33,37]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java:[42,32]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java:[44,53]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java:[46,41]
sun.misc.Unsafe is internal proprietary API and may be removed in a future
release
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/operators/base/SortPartitionOperatorBase.java:[74,83]
unchecked conversion
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/EnumSerializer.java:[30,14]
Class org.apache.flink.api.common.typeutils.base.EnumSerializer overrides
equals, but neither it nor any superclass overrides hashCode method
< [WARNING] bootstrap class path not set in conjunction with -source 1.6
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/ReduceOperator.java:[44,50]
org.apache.flink.api.java.record.functions.FunctionAnnotation in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/CrossOperator.java:[34,50]
org.apache.flink.api.java.record.functions.FunctionAnnotation in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/CrossWithLargeOperator.java:[26,50]
org.apache.flink.api.java.record.functions.CrossFunction in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/io/CsvInputFormat.java:[28,50]
org.apache.flink.api.java.record.operators.FileDataSource in
org.apache.flink.api.java.record.operators has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/CoGroupOperator.java:[35,50]
org.apache.flink.api.java.record.functions.CoGroupFunction in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/CoGroupOperator.java:[36,50]
org.apache.flink.api.java.record.functions.FunctionAnnotation in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/JoinOperator.java:[33,50]
org.apache.flink.api.java.record.functions.FunctionAnnotation in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/JoinOperator.java:[34,50]
org.apache.flink.api.java.record.functions.JoinFunction in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/functions/MapFunction.java:[22,45]
org.apache.flink.api.common.functions.GenericCollectorMap in
org.apache.flink.api.common.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/CrossWithSmallOperator.java:[26,50]
org.apache.flink.api.java.record.functions.CrossFunction in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/MapOperator.java:[29,50]
org.apache.flink.api.common.operators.base.CollectorMapOperatorBase in
org.apache.flink.api.common.operators.base has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/MapOperator.java:[33,50]
org.apache.flink.api.java.record.functions.FunctionAnnotation in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/MapOperator.java:[34,50]
org.apache.flink.api.java.record.functions.MapFunction in
org.apache.flink.api.java.record.functions has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/io/DelimitedOutputFormat.java:[25,50]
org.apache.flink.api.java.record.operators.FileDataSink in
org.apache.flink.api.java.record.operators has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/io/CsvOutputFormat.java:[28,50]
org.apache.flink.api.java.record.operators.FileDataSink in
org.apache.flink.api.java.record.operators has been deprecated
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple9Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple9
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java:[122,50]
unchecked cast
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple4Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple4
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple3Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple3
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple2Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple2
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[49,17]
found raw type: org.apache.flink.api.common.typeinfo.TypeInformation
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[54,17]
found raw type: org.apache.flink.api.java.typeutils.PojoTypeInfo
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[59,25]
found raw type: org.apache.flink.api.common.typeinfo.TypeInformation
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[64,55]
found raw type: org.apache.flink.api.java.typeutils.GenericTypeInfo
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[64,51]
unchecked call to GenericTypeInfo(java.lang.Class<T>) as a member of the raw
type org.apache.flink.api.java.typeutils.GenericTypeInfo
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java:[42,8]
serializable class org.apache.flink.api.java.typeutils.AvroTypeInfo has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java:[29,8]
serializable class org.apache.flink.api.java.typeutils.PojoField has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple1Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple1
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java:[1769,63]
found raw type: org.apache.flink.api.common.typeinfo.TypeInformation
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/operators/ProjectOperator.java:[605,63]
found raw type: org.apache.flink.api.common.typeinfo.TypeInformation
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java:[166,66]
found raw type: org.apache.flink.api.java.aggregation.AggregationFunction
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java:[1053,63]
found raw type: org.apache.flink.api.common.typeinfo.TypeInformation
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingSortedReduceGroupOperator.java:[75,77]
unchecked call to
combine(java.lang.Iterable<IN>,org.apache.flink.util.Collector<OUT>) as a
member of the raw type
org.apache.flink.api.common.functions.GroupCombineFunction
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/io/SplitDataProperties.java:[440,23]
serializable class
org.apache.flink.api.java.io.SplitDataProperties.SourcePartitionerMarker has no
definition of serialVersionUID
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/io/SplitDataProperties.java:[440,23]
Class org.apache.flink.api.java.io.SplitDataProperties.SourcePartitionerMarker
overrides equals, but neither it nor any superclass overrides hashCode method
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/record/operators/ReduceOperator.java:[268,55]
found raw type: java.lang.Class
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple12Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple12
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple13Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple13
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple14Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple14
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple15Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple15
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple17Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple17
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple16Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple16
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple19Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple19
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple18Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple18
< [WARNING]
/Users/max/Dev/flink-qa-bot/flink/tools/_qa_workdir/flink/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple21Builder.java:[44,43]
found raw type: org.apache.flink.api.java.tuple.Tuple21
```
:+1: The number of files in the lib/ folder was 2 before the change
and is now 2
:-1: The change contains @author tags
QA-Check finished.
Overall result: :-1:. Some tests failed. Please check messages above
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
