You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/10/18 08:01:54 UTC
[flink] branch master updated (fa7b573 -> 1bfeaba)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fa7b573 [FLINK-17914][tests] Increase chances of concurrent deletions
add 1bf172d [FLINK-24017][kryo] Pin registration IDs of Java types
add 5dba785 [FLINK-24017][kryo] Move FlinkChillPackageRegistrar to flink-java
add 1bfeaba [FLINK-24017][kryo] Add scala-free code paths
No new revisions were added by this update.
Summary of changes:
.../api/java/typeutils/runtime/KryoUtils.java | 22 +++--
.../java/typeutils/runtime/ValueSerializer.java | 3 +-
.../runtime/kryo/ChillSerializerRegistrar.java | 27 +++---
.../typeutils/runtime/kryo/KryoSerializer.java | 59 +++++++++++++-
flink-java/pom.xml | 6 ++
.../runtime/kryo/FlinkChillPackageRegistrar.java | 95 ++++++++++++++++++++++
.../runtime/kryo}/PriorityQueueSerializer.java | 2 +-
.../runtime/types/FlinkChillPackageRegistrar.java | 61 --------------
.../runtime/types/FlinkScalaKryoInstantiator.scala | 3 +-
9 files changed, 191 insertions(+), 87 deletions(-)
copy flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/groups/SplitEnumeratorMetricGroup.java => flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/ChillSerializerRegistrar.java (54%)
create mode 100644 flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/FlinkChillPackageRegistrar.java
rename {flink-scala/src/main/scala/org/apache/flink/runtime/types => flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo}/PriorityQueueSerializer.java (98%)
delete mode 100644 flink-scala/src/main/scala/org/apache/flink/runtime/types/FlinkChillPackageRegistrar.java