[
https://issues.apache.org/jira/browse/FLINK-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14574557#comment-14574557
]
ASF GitHub Bot commented on FLINK-2072:
---------------------------------------
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
> Add a quickstart guide for FlinkML
> ----------------------------------
>
> Key: FLINK-2072
> URL: https://issues.apache.org/jira/browse/FLINK-2072
> Project: Flink
> Issue Type: New Feature
> Components: Documentation, Machine Learning Library
> Reporter: Theodore Vasiloudis
> Assignee: Theodore Vasiloudis
> Fix For: 0.9
>
>
> We need a quickstart guide that introduces users to the core concepts of
> FlinkML to get them up and running quickly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
