Hi Vinay,
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
Hi,
I am submitting job to the cluster (using remote execution env) from
multiple threads. I am getting the following exception
java.util.ConcurrentModificationException
at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:909)
at java.util.ArrayList$Itr.next(ArrayLis
