This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1662d5d [FLINK-15278][docs-zh] Update Chinese version
StreamingFileSink doc
add 86ebb10 [hotfix][tests] Remove legany codes from
CheckpointBarrierAlignerTestBase
add 9f92ddf [FLINK-15444][runtime] Make the component AbstractInvokable
in CheckpointBarrierHandler NonNull
No new revisions were added by this update.
Summary of changes:
...Iterator.java => DummyCheckpointInvokable.java} | 26 +++++++++-------
.../runtime/io/CheckpointBarrierAligner.java | 4 +--
.../runtime/io/CheckpointBarrierHandler.java | 35 ++++++++++------------
.../runtime/io/CheckpointBarrierTracker.java | 8 +----
.../runtime/io/CheckpointedInputGate.java | 4 +--
.../CheckpointBarrierAlignerMassiveRandomTest.java | 3 +-
.../io/CheckpointBarrierAlignerTestBase.java | 13 +++-----
.../runtime/io/CheckpointBarrierTrackerTest.java | 3 +-
.../CreditBasedCheckpointBarrierAlignerTest.java | 4 +--
.../runtime/io/StreamTaskNetworkInputTest.java | 5 ++--
10 files changed, 45 insertions(+), 60 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/{InfiniteIntTupleIterator.java
=> DummyCheckpointInvokable.java} (59%)
