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

Posted to commits@flink.apache.org by sr...@apache.org on 2019/07/22 09:54:08 UTC

[flink] branch master updated (61d2525 -> c75af84)

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

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


    from 61d2525  [FLINK-13323][table-runtime-blink] Add tests for complex data formats
     add 23f726c  [FLINK-13326] Add closeInterruptibly()
     add 3c38352  [FLINK-13326] Use ResourceGuard in NonClosingCheckpointStream
     add c75af84  [FLINK-13326] Support async rawState checkpointing

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/util/ResourceGuard.java  |  39 ++++++--
 .../state/KeyedStateCheckpointOutputStream.java    |   4 +-
 .../state/NonClosingCheckpointOutputStream.java    |  24 ++++-
 .../state/OperatorStateCheckpointOutputStream.java |   2 +-
 .../state/StateSnapshotContextSynchronousImpl.java | 108 ++++++++++++++-------
 .../api/operators/AbstractStreamOperator.java      |  19 ++--
 .../api/operators/AbstractStreamOperatorTest.java  |   4 -
 .../StateSnapshotContextSynchronousImplTest.java   |  43 +++++++-
 8 files changed, 187 insertions(+), 56 deletions(-)