[BEAM-14313] [IT Tests] Message not acknowledged using Direct Runner

• Type: Bug
• Status: Open
• Priority: P2
• Resolution: Unresolved
• Affects Version/s: 2.36.0
• Component/s: io-java-gcp, runner-direct
• Labels: GCP test test-stability
• Flags: Important

Language

Java

• Assignee: Unassigned
• Reporter: Amrane AIT ZEOUAY
• Created: 15/Apr/22 07:48
• Updated: 05/Jun/22 00:17

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()