When I run a batch job using Flink 1.19, I used collect() in the job, and many times the following error appears in the JobManager log: Caused by: org.apache.flink.util.FlinkException: Coordinator of operator xxxx does not exist or the job vertex this operator belongs to is not initialized. What is the cause of this exception?
- Exception: Coordinator of operator xxxx does not exist or the j... Corin
