te().collect().next();
```
But I failed to reproduce the exception you attached :(
Best,
Biao Geng
Eduard Skhisov via user mailto:user@flink.apache.org>>
于2024年5月1日周三 05:09写道:
Hello,
I am trying to use CloseableIterator, but next() operation reliably generates
the following error:
j
Update:
I figured out that error happens only of the SQL contains JOIN of any kind. If
there are no JOINs, everything works fine.
Any help?
Hello,
I am trying to use CloseableIterator, but next() operation reliably generates
the following error:
java.util.concurrent.ExecutionException: org.a
Hello,
I am trying to use CloseableIterator, but next() operation reliably generates
the following error:
java.util.concurrent.ExecutionException: org.apache.flink.util.FlinkException:
Coordinator of operator 4596fb32cad14208ec80c1cae8623e11 does not exist or the
job vertex this operator belong