You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by gy...@apache.org on 2024/08/23 07:36:31 UTC

(flink-kubernetes-operator) branch main updated (a10fb450 -> 0ef627ed)

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