could you try to create a dedicated RemoteEnvironment for each parallel
thread. I think that the StreamExecutionEnvironment is not thread safe and
should, thus, not be shared across multiple threads if that's the case.
Getting a glimpse at your code would also help to further understand the
On Fri, Feb 16, 2018 at 5:39 AM, Vinay Patil <vinay18.pa...@gmail.com>
> I am submitting job to the cluster (using remote execution env) from
> multiple threads. I am getting the following exception
> at java.util.ArrayList$Itr.checkForComodification(
> at java.util.ArrayList$Itr.next(ArrayList.java:859)
> I am using Flink 1.3.2, and I am making sure that the job name is different
> for each job.
> Can you please let me know if I am doing something wrong.
> Vinay Patil
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.