This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9236eb9 [FLINK-10690][tests] Fix Files.list resource leaks
new 1b9cdf5 [FLINK-7816] Support Scala 2.12 closures and Java 8 lambdas
in ClosureCleaner
new 8513045 [FLINK-7811] Add "override" in Scala code to support Scala
2.12
new e90f788 [FLINK-7811] Make Long literal explicit to support Scala 2.12
new c41b578 [FLINK-7811] Add implicit types to make Scala 2.12 happy
new 578ae73 [FLINK-7811] Add use ForkJoinPool from Java package for Scala
2.12 support
new dec57b9 [FLINK-7811] Fix recursion bug in TypeInformationGen
new 2fc44b0 [FLINK-7811] Update to grizzled 1.3.2 to support Scala 2.12
new b9c3984 [FLINK-7811] Update scalatest to 3.0.0 for Scala 2.12 support
new 5080264 [FLINK-7811] Fix TestingJobManagerLike for Scala 2.12
new d8b8014 [FLINK-7811] Disambiguate ZooKeeperHAJobManagerTest for Scala
2.12
new 21c3908 [FLINK-7811] Disambiguate Graph.scala methods for Scala 2.12
support
new 09d327d [FLINK-7811] Disambiguate method calls for Scala 2.12 support
new 8b35020 [FLINK-7811] Fix japicmp exclusion pattern
new cc62f22 [FLINK-7811] Add DataStream.keyBy() that takes KeySelector
new 3acb98f [FLINK-7811] Remove macro paradise plugin
new ebf825e [FLINK-7811] Update breeze dependency and add explicit types
in FlinkML
new db66cca [FLINK-7811] Disambiguate Scala Example code to work with
Scala 2.12
new 5192ad5 [FLINK-7811] Update Kafka version of Kafka connector base
new 5f688b4 [FLINK-7811] Add ScalaKryoInstantiator from Chill 0.7.4 and
update to 0.7.6
new 1851229 [hotfix] Remove unused testing savepoints
new c53c9c7 [FLINK-7811] Make Scala savepoint migration tests
Scala-version-independent
new fc2e470 [FLINK-7811] Add SerialVersionUID to Scala test classes to
make it work on Scala 2.12
new 66769ba [FLINK-7811] Add scala.Enumeration to ignore list for Scala
SerialVersionUID
new 62ef547 [FLINK-7811] Make IterateExample.Bound final so it can be
used in withinBound()
new f8cbbb5 [FLINK-7811] Add Scala 2.12 profile
The 25 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.travis.yml | 14 +-
flink-connectors/flink-connector-kafka-0.8/pom.xml | 8 +
flink-connectors/flink-connector-kafka-0.9/pom.xml | 28 +-
.../flink-connector-kafka-base/pom.xml | 13 +-
flink-connectors/pom.xml | 14 +-
.../typeutils/runtime/kryo/KryoSerializer.java | 3 +-
.../org/apache/flink/util/InstantiationUtil.java | 1 +
flink-dist/pom.xml | 24 +-
flink-dist/src/main/assemblies/opt.xml | 4 +-
flink-examples/flink-examples-batch/pom.xml | 6 +
.../scala/graph/TransitiveClosureNaive.scala | 13 +-
.../examples/scala/relational/WebLogAnalysis.scala | 7 +-
.../scala/examples/iteration/IterateExample.scala | 2 +-
flink-examples/pom.xml | 6 -
flink-formats/flink-avro/pom.xml | 20 +-
flink-formats/flink-json/pom.xml | 3 +-
flink-formats/flink-parquet/pom.xml | 5 +-
.../flink/cep/scala/pattern/PatternTest.scala | 5 +-
.../scala/org/apache/flink/graph/scala/Graph.scala | 69 +--
flink-libraries/flink-ml/pom.xml | 2 +-
.../org/apache/flink/ml/common/FlinkMLTools.scala | 2 +-
.../main/scala/org/apache/flink/ml/nn/KNN.scala | 8 +-
.../ml/outlier/StochasticOutlierSelection.scala | 2 +-
.../flink/ml/preprocessing/MinMaxScaler.scala | 2 +-
.../ml/preprocessing/PolynomialFeatures.scala | 2 +-
.../apache/flink/ml/preprocessing/Splitter.scala | 10 +-
.../flink/ml/preprocessing/StandardScaler.scala | 4 +-
flink-libraries/flink-sql-client/pom.xml | 23 +-
.../table/runtime/stream/sql/SortITCase.scala | 2 +-
.../flink/table/runtime/utils/StreamITCase.scala | 6 +-
.../mesos/scheduler/LaunchCoordinatorTest.scala | 9 +-
.../scheduler/ReconciliationCoordinatorTest.scala | 8 +-
.../flink/mesos/scheduler/TaskMonitorTest.scala | 9 +-
.../runtime/types/FlinkChillPackageRegistrar.java | 63 +++
.../runtime/types/PriorityQueueSerializer.java | 93 ++++
.../flink/runtime/taskmanager/TaskManager.scala | 4 +-
.../runtime/types/FlinkScalaKryoInstantiator.scala | 194 +++++++
.../types/JavaIterableWrapperSerializer.scala | 75 +++
.../jobmanager/ZooKeeperHAJobManagerTest.java | 7 +-
.../testingUtils/TestingJobManagerLike.scala | 13 +-
flink-scala/pom.xml | 20 +-
.../apache/flink/api/scala/ClosureCleaner.scala | 564 ++++++++++++++++-----
.../api/scala/codegen/TypeInformationGen.scala | 2 +-
.../impl/acceptPartialFunctions/OnDataSet.scala | 5 +-
.../acceptPartialFunctions/OnGroupedDataSet.scala | 5 +-
.../api/scala/unfinishedKeyPairOperation.scala | 32 ++
.../org/apache/flink/api/scala/utils/package.scala | 8 +-
flink-streaming-scala/pom.xml | 2 +-
.../flink/streaming/api/scala/DataStream.scala | 14 +-
.../api/scala/AllWindowTranslationTest.scala | 28 +-
.../streaming/api/scala/CoGroupJoinITCase.scala | 12 +-
.../flink/streaming/api/scala/DataStreamTest.scala | 2 +-
.../streaming/api/scala/WindowFoldITCase.scala | 12 +-
.../streaming/api/scala/WindowFunctionITCase.scala | 8 +-
.../streaming/api/scala/WindowReduceITCase.scala | 12 +-
.../api/scala/WindowTranslationTest.scala | 20 +-
.../minicluster/LocalFlinkMiniClusterITCase.java | 2 +-
...migration-itcase-flink1.2-jobmanager-savepoint} | Bin
...df-migration-itcase-flink1.2-rocksdb-savepoint} | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
.../_metadata | Bin
...-migration-itcase-flink1.2-jobmanager-savepoint | Bin 92818 -> 0 bytes
...udf-migration-itcase-flink1.2-rocksdb-savepoint | Bin 92818 -> 0 bytes
.../_metadata | Bin 213759 -> 0 bytes
.../_metadata | Bin 213759 -> 0 bytes
.../api/scala/functions/ClosureCleanerITCase.scala | 2 +-
.../api/scala/migration/MigrationTestTypes.scala | 3 +
.../StatefulJobSavepointMigrationITCase.scala | 13 +-
...StatefulJobWBroadcastStateMigrationITCase.scala | 10 +-
.../flink/api/scala/operators/CoGroupITCase.scala | 131 +++--
.../api/scala/operators/GroupCombineITCase.scala | 13 +-
.../api/scala/operators/GroupReduceITCase.scala | 84 +--
pom.xml | 128 ++++-
tools/check_dependency_convergence.sh | 14 +-
tools/releasing/create_binary_release.sh | 14 +
tools/releasing/deploy_staging_jars.sh | 7 +-
tools/travis/stage.sh | 12 +-
85 files changed, 1511 insertions(+), 451 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/types/PriorityQueueSerializer.java
create mode 100644
flink-runtime/src/main/scala/org/apache/flink/runtime/types/FlinkScalaKryoInstantiator.scala
create mode 100644
flink-runtime/src/main/scala/org/apache/flink/runtime/types/JavaIterableWrapperSerializer.scala
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.2-jobmanager-savepoint
=> stateful-scala-udf-migration-itcase-flink1.2-jobmanager-savepoint} (100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.2-rocksdb-savepoint
=> stateful-scala-udf-migration-itcase-flink1.2-rocksdb-savepoint} (100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.3-jobmanager-savepoint
=>
stateful-scala-udf-migration-itcase-flink1.3-jobmanager-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.3-rocksdb-savepoint
=> stateful-scala-udf-migration-itcase-flink1.3-rocksdb-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.4-jobmanager-savepoint
=>
stateful-scala-udf-migration-itcase-flink1.4-jobmanager-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.4-rocksdb-savepoint
=> stateful-scala-udf-migration-itcase-flink1.4-rocksdb-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint
=>
stateful-scala-udf-migration-itcase-flink1.6-jobmanager-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint
=> stateful-scala-udf-migration-itcase-flink1.6-rocksdb-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.5-jobmanager-savepoint
=>
stateful-scala-with-broadcast-udf-migration-itcase-flink1.5-jobmanager-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.5-rocksdb-savepoint
=>
stateful-scala-with-broadcast-udf-migration-itcase-flink1.5-rocksdb-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint
=>
stateful-scala-with-broadcast-udf-migration-itcase-flink1.6-jobmanager-savepoint}/_metadata
(100%)
rename
flink-tests/src/test/resources/{stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint
=>
stateful-scala-with-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint}/_metadata
(100%)
delete mode 100644
flink-tests/src/test/resources/stateful-scala2.10-udf-migration-itcase-flink1.2-jobmanager-savepoint
delete mode 100644
flink-tests/src/test/resources/stateful-scala2.10-udf-migration-itcase-flink1.2-rocksdb-savepoint
delete mode 100644
flink-tests/src/test/resources/stateful-scala2.10-udf-migration-itcase-flink1.3-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala2.10-udf-migration-itcase-flink1.3-rocksdb-savepoint/_metadata
