[
https://issues.apache.org/jira/browse/FLINK-29399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-29399:
----------------------------------------
Assignee: Chesnay Schepler
> 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
> Assignee: Chesnay Schepler
> Priority: Major
>
>
> {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)
