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 eb24d38 [FLINK-19680][checkpointing] Announce timeoutable
CheckpointBarriers
add 91583c7 [FLINK-19836] Add SerializableSupplier in flink-core
add 60b6401 [FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy
No new revisions were added by this update.
Summary of changes:
...mpleVersionedSerializerTypeSerializerProxy.java | 148 +++++++++++++++++++++
.../function/SerializableSupplier.java} | 13 +-
.../apache/flink/api/java/ClosureCleanerTest.java | 7 +-
...VersionedSerializerTypeSerializerProxyTest.java | 99 ++++++++++++++
4 files changed, 256 insertions(+), 11 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializerTypeSerializerProxy.java
copy
flink-core/src/main/java/org/apache/flink/{api/common/eventtime/SerializableTimestampAssigner.java
=> util/function/SerializableSupplier.java} (73%)
create mode 100644
flink-core/src/test/java/org/apache/flink/core/io/SimpleVersionedSerializerTypeSerializerProxyTest.java
