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(-)