[FLINK-35265] Change generated snapshot name to contain epoch

apache · Jul 25, 2024 · d82d5dd · d82d5dd
1 parent 637b305
commit d82d5dd
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...tor/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkStateSnapshotUtils.java b/...tor/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkStateSnapshotUtils.java
@@ -41,7 +41,6 @@
 import javax.annotation.Nullable;
 
 import java.time.Instant;
-import java.util.UUID;
 
 import static org.apache.flink.kubernetes.operator.api.status.FlinkStateSnapshotStatus.State.ABANDONED;
 import static org.apache.flink.kubernetes.operator.api.status.FlinkStateSnapshotStatus.State.COMPLETED;
@@ -221,11 +220,11 @@ public static String getFlinkStateSnapshotName(
             SnapshotTriggerType triggerType,
             AbstractFlinkResource<?, ?> referencedResource) {
         return String.format(
-                "%s-%s-%s-%s",
+                "%s-%s-%s-%d",
                 referencedResource.getMetadata().getName(),
                 snapshotType.name().toLowerCase(),
                 triggerType.name().toLowerCase(),
-                UUID.randomUUID());
+                System.currentTimeMillis());
     }
 
     /**