From c44353ad87a53a67c16d1bacd94e06c2b1d91d25 Mon Sep 17 00:00:00 2001 From: godfreyhe Date: Thu, 11 Jun 2020 16:11:03 +0800 Subject: [PATCH] Revert "minor update" This reverts commit e32a32bc --- .../scala/org/apache/flink/table/api/TableITCase.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) 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