Abacn commented on PR #30218: URL: https://github.com/apache/beam/pull/30218#issuecomment-2037783134
Yeah, it seems authors of this IO connector were aware of prefetch in implementation affects how the message gets delivered. Here I hava a proposal, introduce a "checkPointTimeout" option for JmsIO.read, default to 0 (never timeout), and if works as when the last advance return true and current advance return false passed the checkPointTimeout, then we revoke the lastly made jmscheckpoint, that is close the session without acknowledge messages in it This will cause some duplicates, but it may unblock the mesdages sit in the internal buffer of the previous session -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
