Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-14313

[IT Tests] Message not acknowledged using Direct Runner

Details

    • Important

    Description

      When running integration tests using direct runner, the messages are not acknowledged. The function finalizeCheckpoint() is not called because the shard's checkpoint is always null.

      The acknowledgement is called inside of the function finalizeCheckpoint()

      Attachments

        1. JmsCheckpointMark.java.png
          58 kB
          Amrane AIT ZEOUAY
        2. UnboundedReadEvaluatorFactory.java.png
          58 kB
          Amrane AIT ZEOUAY

        Activity

          People

            Unassigned Unassigned
            Amrane Amrane AIT ZEOUAY
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: