The GitHub Actions job "CI" on flink-connector-gcp-pubsub.git has failed. Run started by GitHub user RyanSkraba (triggered by RyanSkraba).
Head commit for run: 7e8e4abee14df77bcb944e289e94dd7ed8e0d9d8 / David Christle <[email protected]> Improvements to FLINK-20625 FLIP-27 connector (#1) * Add retry mechanism to acknowledging pubsub messages * Remove synchronized locks and instead decouple reader and fetcher threads with ArrayBlockingQueue. This fixes a concurrency bug between separate threads calling fetch/acknowledgeMessages. * Handle failed checkpoints and ensure subscriber is not null in acknowledgeMessages. * Implement splitAckIds with iteration instead of recursion. Fixes bug where payload can exceed maxPayload. --------- Co-authored-by: Richard Deurwaarder <[email protected]> Report URL: https://github.com/apache/flink-connector-gcp-pubsub/actions/runs/6850189688 With regards, GitHub Actions via GitBox
