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)
