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 ef78962 [FLINK-15501] Remove the wrong doc of
ExecutionVertexSchedulingRequirements#getExecutionVertexId
add f21f1c7 [FLINK-15406][state-processor-api] RocksDB savepoints with
heap timers cannot be restored by non-process functions
No new revisions were added by this update.
Summary of changes:
.../operators/KeyedStateBootstrapOperator.java | 7 +-
.../api/output/operators/LazyTimerService.java | 42 +++++--
.../output/KeyedStateBootstrapOperatorTest.java | 121 +++++++++++++++++++++
3 files changed, 157 insertions(+), 13 deletions(-)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/SimpleTimerService.java
=>
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/LazyTimerService.java
(60%)
create mode 100644
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/output/KeyedStateBootstrapOperatorTest.java
