diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala
index 971600cb8474c..d4b5eb4040b95 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala
@@ -119,13 +119,16 @@ class TableITCase(tableEnvName: String, isStreaming: Boolean) extends TestLogger
     assertEquals(ResultKind.SUCCESS_WITH_CONTENT, tableResult.getResultKind)
     val it = tableResult.collect()
     it.close()
-    try {
-      assertNotEquals(JobStatus.RUNNING, tableResult.getJobClient.get().getJobStatus.get())
+    val jobStatus = try {
+      Some(tableResult.getJobClient.get().getJobStatus.get())
     } catch {
       // ignore the exception,
       // because the MiniCluster maybe already been shut down when getting job status
       case _: Throwable => None
     }
+    if (jobStatus.isDefined) {
+      assertNotEquals(JobStatus.RUNNING, jobStatus.get)
+    }
   }
 
   @Test