[FLINK-28648][Flink-Kubernetes-Operator] Fix Cleanup Process for Session Cluster

nishita-pattanayak · nishita-pattanayak · commit 8a1235271e10 · 2025-07-11T16:07:57.000+05:30
diff --git a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconcilerTest.java b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconcilerTest.java
@@ -151,7 +151,7 @@ public void testSetOwnerReference() throws Exception {
     }
 
     @Test
-    public void testUnmanagedJobsIdentification() throws Exception {
+    public void testGetUnmanagedJobs() throws Exception {
         // Create a session cluster deployment with blocking enabled
         FlinkDeployment deployment = TestUtils.buildSessionCluster();
         deployment

Original file line number	Diff line number	Diff line change
`@@ -151,7 +151,7 @@ public void testSetOwnerReference() throws Exception {`
`151`	`151`	`}`
`152`	`152`
`153`	`153`	`@Test`
`154`		`- public void testUnmanagedJobsIdentification() throws Exception {`
	`154`	`+ public void testGetUnmanagedJobs() throws Exception {`
`155`	`155`	`// Create a session cluster deployment with blocking enabled`
`156`	`156`	`FlinkDeployment deployment = TestUtils.buildSessionCluster();`
`157`	`157`	`deployment`