Revert "minor update"

This reverts commit e32a32b
apache · Jun 11, 2020 · c44353a · c44353a
1 parent e32a32b
commit c44353a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...ble/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala b/...ble/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