This is an automated email from the ASF dual-hosted git repository.

arvid pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 9238633  [FLINK-20680][table-common] Fix invalid validation of var-arg 
function with no parameters
     add 38b51c0  [FLINK-21104][network] Improve debug information for 
unaligned checkpoints
     add 509425b  [FLINK-21104][network] Ensure that converted input channels 
start in the correct persisting state.

No new revisions were added by this update.

Summary of changes:
 .../partition/consumer/ChannelStatePersister.java  |  3 +-
 .../partition/consumer/RecoveredInputChannel.java  | 11 ++++++-
 .../partition/consumer/SingleInputGate.java        |  1 +
 .../consumer/ChannelStatePersisterTest.java        | 35 ++++++++++++++++++++++
 .../runtime/io/SingleCheckpointBarrierHandler.java |  1 +
 5 files changed, 49 insertions(+), 2 deletions(-)

Reply via email to