use native checkpoint for tests

Author: gyfora

e2e-tests/data/savepoint.yaml

@@ -28,5 +28,5 @@ spec:
   savepoint:
     alreadyExists: false
     disposeOnDelete: true
-    formatType: CANONICAL
+    formatType: NATIVE
 

e2e-tests/test_snapshot.sh

@@ -53,7 +53,8 @@ wait_for_status $APPLICATION_IDENTIFIER '.status.jobStatus.state' RUNNING ${TIME
 
 
 # Test upgrade by setting legacy field
-kubectl patch flinkdep ${CLUSTER_ID} --type merge --patch '{"spec":{"job":{"state": "suspended"}}}'
+# Use native savepoints to avoid Flink 2.0/2.1 issues
+kubectl patch flinkdep ${CLUSTER_ID} --type merge --patch '{"spec":{"job":{"state": "suspended"}, "flinkConfiguration":{"kubernetes.operator.savepoint.format.type" : "NATIVE"} }}'
 wait_for_status $APPLICATION_IDENTIFIER '.status.lifecycleState' "SUSPENDED" ${TIMEOUT} || exit 1
 
 location=$(kubectl get $APPLICATION_IDENTIFIER -o yaml | yq '.status.jobStatus.upgradeSavepointPath')

examples/basic-checkpoint-ha.yaml

@@ -29,6 +29,7 @@ spec:
     state.checkpoints.dir: file:///flink-data/checkpoints
     high-availability.type: kubernetes
     high-availability.storageDir: file:///flink-data/ha
+    kubernetes.operator.savepoint.format.type: NATIVE
   serviceAccount: flink
   jobManager:
     resource: