You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2020/09/02 17:08:27 UTC

[jira] [Commented] (BEAM-3920) JmsIO should ack the message before the finalizeCheckpoint

    [ https://issues.apache.org/jira/browse/BEAM-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189392#comment-17189392 ] 

Beam JIRA Bot commented on BEAM-3920:
-------------------------------------

This issue was marked "stale-P2" and has not received a public comment in 14 days. It is now automatically moved to P3. If you are still affected by it, you can comment and move it back to P2.

> JmsIO should ack the message before the finalizeCheckpoint
> ----------------------------------------------------------
>
>                 Key: BEAM-3920
>                 URL: https://issues.apache.org/jira/browse/BEAM-3920
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-jms
>            Reporter: Jean-Baptiste Onofré
>            Priority: P3
>
> {{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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)