This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
from a10fb450 [FLINK-33803]remove metadata/generation fields from
ReconciliationMetadata
add 0ef627ed [FLINK-36110][snapshot] Store periodic snapshot trigger
timestamps in memory
No new revisions were added by this update.
Summary of changes:
.../operator/observer/SnapshotObserver.java | 15 +--
.../reconciler/SnapshotTriggerTimestampStore.java | 140 ++++++++++++++++++++
.../deployment/AbstractJobReconciler.java | 19 ++-
.../operator/utils/FlinkStateSnapshotUtils.java | 25 ++++
.../kubernetes/operator/utils/SnapshotUtils.java | 16 +--
.../flink/kubernetes/operator/TestUtils.java | 22 +---
.../SnapshotTriggerTimestampStoreTest.java | 143 +++++++++++++++++++++
.../deployment/ApplicationReconcilerTest.java | 44 -------
.../operator/utils/SnapshotUtilsTest.java | 44 +++++--
9 files changed, 370 insertions(+), 98 deletions(-)
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/SnapshotTriggerTimestampStore.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/SnapshotTriggerTimestampStoreTest.java
