pjfanning commented on PR #146: URL: https://github.com/apache/incubator-pekko-connectors/pull/146#issuecomment-1584170343
> > There is a 2nd place where the queue is recreated. I can see if I can clear the original queue instead of resetting the var. > > You should be able to just clear the queue? * clearing a queue affects the iterator that was previously created for the queue (before the clear) - causes an IndexOutOfBoundsException * I'm trying a different solution at the moment -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
