minor update

apache · Jun 11, 2020 · e32a32b · e32a32b
1 parent 9e43454
commit e32a32b
Showing 1 changed file with 2 additions and 5 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,16 +119,13 @@ class TableITCase(tableEnvName: String, isStreaming: Boolean) extends TestLogger
     assertEquals(ResultKind.SUCCESS_WITH_CONTENT, tableResult.getResultKind)
     val it = tableResult.collect()
     it.close()
-    val jobStatus = try {
-      Some(tableResult.getJobClient.get().getJobStatus.get())
+    try {
+      assertNotEquals(JobStatus.RUNNING, 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