Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5362
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5362#discussion_r165646464
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java
---
@@ -52,7 +52,7 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5362#discussion_r165636384
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java
---
@@ -52,7 +52,7 @@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5362#discussion_r165573730
--- Diff:
flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java
---
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5362
[FLINK-8421] [DataStream] Make timer serializers reconfigurable on restore
## What is the purpose of the change
Previously, key and namespace serializers of the `HeapInternalTimerService`
