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

Reply via email to