This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a021db68a85 [FLINK-34543][datastream] Introduce the SortPartition API
on PartitionWindowedStream
add 583722e721a [FLINK-32076][checkpoint] Introduce non-blocking file pool
to reuse files
add 3b9623e5d2e [FLINK-32076][checkpoint] Introduce blocking file pool to
reuse files (#24418)
No new revisions were added by this update.
Summary of changes:
.../filemerging/BlockingPhysicalFilePool.java | 96 ++++++++++++++
.../FileMergingSnapshotManagerBase.java | 29 ++++-
.../FileMergingSnapshotManagerBuilder.java | 23 +++-
.../filemerging/NonBlockingPhysicalFilePool.java | 62 +++++++++
.../checkpoint/filemerging/PhysicalFile.java | 9 ++
.../checkpoint/filemerging/PhysicalFilePool.java | 145 +++++++++++++++++++++
...WithinCheckpointFileMergingSnapshotManager.java | 101 +++++++-------
.../FileMergingSnapshotManagerTest.java | 102 +++++++++++++--
8 files changed, 498 insertions(+), 69 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/BlockingPhysicalFilePool.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/NonBlockingPhysicalFilePool.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFilePool.java
