[jira] [Created] (FLINK-29399) TableITCase is unstable

["Chesnay Schepler (Jira)" <ji...@apache.org>]

Chesnay Schepler created FLINK-29399:
----------------------------------------

             Summary: TableITCase is unstable
                 Key: FLINK-29399
                 URL: https://issues.apache.org/jira/browse/FLINK-29399
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner, Tests
    Affects Versions: 1.16.0
            Reporter: Chesnay Schepler


    

{code:java}
    val it = tableResult.collect()
    it.close()
    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.get, JobStatus.RUNNING)
    }
{code}

There's no guarantee that the cancellation already went through. The test should periodically poll the job status until another state is reached.
Or even better, use the new collect API, call execute in a separate thread, close the iterator and wait for the thread to terminate.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)