@Frank : Thanks.
I verified changing that and it works fine.  (I still need to copy the user
jar to the lib dir which ideally shouldn't be required but I think that is
because of userCodeClassLoader() related problem. Will look into that)
About implementation I feel instead of initializing priority queue with 1
when numberPriorityQueueEntries=0. We should have a  condition check that if
numberPriorityQueueEntries > 1 then only perform the next processing
(creating priority queue object and deserialization calls in a loop) as
numberPriorityQueueEntries=0 means nothing needs to be done in restoreState.

I can add a patch for it but as Frank found the resolution it is his call to

View this message in context: 
Sent from the Apache Flink User Mailing List archive. mailing list archive at 

Reply via email to