RE: [EXTERNAL] Re: Coordinator of operator ... does not exist or the job vertex this operator belongs to is not initialized.

2024-05-07 Thread Eduard Skhisov via user
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

Coordinator of operator ... does not exist or the job vertex this operator belongs to is not initialized.

2024-05-02 Thread Eduard Skhisov via user
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

Coordinator of operator ... does not exist or the job vertex this operator belongs to is not initialized.

2024-04-30 Thread Eduard Skhisov via user
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