JmsIO should ack the message before the finalizeCheckpoint
Open
bug
io
java
jms
P3
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
`JmsIO` sends back the ack to the broker in the `finalizeCheckpoint()` method. However, the checkpoint doesn't seem to be fast enough (with the direct runner at least), and the messages are still pending in the queue whereas the data has been processed in the pipeline. This should be improved.
Imported from Jira [BEAM-3920](https://issues.apache.org/jira/browse/BEAM-3920). Original Jira may contain additional context.
Reported by: jbonofre.
Contributor guide
Assessment
This issue has not been assessed yet.