You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ar...@apache.org on 2021/01/25 12:45:18 UTC

[flink] branch master updated (0d3c785 -> e3b3c6f)

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

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


    from 0d3c785  [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql
     add 1257d15  [FLINK-21104][network] Improve debug information for unaligned checkpoints
     add e3b3c6f  [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 ++++++++++++++++++++++
 .../SingleCheckpointBarrierHandler.java            | 10 +++++++
 5 files changed, 58 insertions(+), 2 deletions(-)