This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0f3889e7eec [FLINK-39313][table-planner] Fix NDU analyzer to detect
non-deterministic functions in ChangelogNormalize filter conditions
new b1b986cfd8f [hotfix][runtime] Extract RecordFilter as the interface
new fbd2e4f93f0 [hotfix] Extract VirtualChannel as the public class
new eabc3cef8a1 [FLINK-38541][checkpoint] Introducing config option:
execution.checkpointing.unaligned.during-recovery.enabled
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/common_checkpointing_section.html | 6 +
.../flink/configuration/CheckpointingOptions.java | 47 ++++++++
.../configuration/CheckpointingOptionsTest.java | 46 ++++++++
.../recovery/DemultiplexingRecordDeserializer.java | 61 +---------
...ordFilter.java => PartitionerRecordFilter.java} | 30 +++--
.../runtime/io/recovery/RecordFilter.java | 62 +++++-----
.../recovery/RescalingStreamTaskNetworkInput.java | 9 +-
.../runtime/io/recovery/VirtualChannel.java | 130 +++++++++++++++++++++
.../DemultiplexingRecordDeserializerTest.java | 8 +-
.../runtime/io/recovery/RecordFilterTest.java | 109 +++++++++++++++++
10 files changed, 390 insertions(+), 118 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/io/recovery/{RecordFilter.java
=> PartitionerRecordFilter.java} (67%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/io/recovery/VirtualChannel.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/streaming/runtime/io/recovery/RecordFilterTest.java
