The GitHub Actions job "Flink CI (beta)" on flink.git has failed. Run started by GitHub user becketqin (triggered by becketqin).
Head commit for run: a15bf58da5442deeb07ac2a1795a961a0ec75561 / Jiangjie (Becket) Qin <becket....@gmail.com> [FLINK-35924][Connectors / Common] delay the SplitReader closure to until all the emitted records are processed. (#25130) This patch delays the SplitReader closure to wait until all the previously emitted records are processed. This is needed for some of the SplitReader implementation which stores the returned records in internal buffer to save a data copy. In that case, closing the SplitReader will result in corruption of the emitted but not yet processed records. Report URL: https://github.com/apache/flink/actions/runs/10269514679 With regards, GitHub Actions via GitBox