Amrane AIT ZEOUAY created BEAM-14313:
----------------------------------------

             Summary: [IT Tests] Message not acknowledged using Direct Runner
                 Key: BEAM-14313
                 URL: https://issues.apache.org/jira/browse/BEAM-14313
             Project: Beam
          Issue Type: Bug
          Components: io-java-gcp, runner-direct
    Affects Versions: 2.36.0
            Reporter: Amrane AIT ZEOUAY


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.

!image-2022-04-15-09-45-02-201.png!

The acknowledgement is called inside of the function *finalizeCheckpoint()*

!image-2022-04-15-09-45-48-395.png!



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to