Re: Autoscaling with flink-k8s-operator 1.8.0

Hi Gyula, Thanks for getting back and explaining the difference in the responsibilities of the autoscaler and the operator. I figured out what the issue was. Here is what I was trying to do: the autoscaler had initially down-scaled (2->1) the flinkDeployment so there was pipeline.jobvertex-parall

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

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