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 64f8f65 [FLINK-18042][tests] Auto-detect distDir
add 6dc624d [FLINK-18136][checkpointing] Don't start channel state writer
for savepoint
No new revisions were added by this update.
Summary of changes:
.../state/TestCheckpointStorageWorkerView.java | 52 +++++++++++++
.../runtime/io/CheckpointBarrierUnaligner.java | 15 ++--
.../streaming/runtime/io/InputProcessorUtil.java | 14 ++--
.../runtime/tasks/MultipleInputStreamTask.java | 2 +-
.../runtime/tasks/OneInputStreamTask.java | 2 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 7 +-
.../tasks/SubtaskCheckpointCoordinator.java | 10 ++-
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 50 ++++++++++--
.../runtime/tasks/TwoInputStreamTask.java | 2 +-
.../AlternatingCheckpointBarrierHandlerTest.java | 12 +--
...CheckpointBarrierUnalignerCancellationTest.java | 4 +-
.../runtime/io/CheckpointBarrierUnalignerTest.java | 6 +-
.../runtime/io/InputProcessorUtilTest.java | 3 +-
.../runtime/io/StreamTaskNetworkInputTest.java | 5 +-
.../tasks/SubtaskCheckpointCoordinatorTest.java | 47 ++++++++++++
.../tasks/TestSubtaskCheckpointCoordinator.java | 89 ++++++++++++++++++++++
16 files changed, 278 insertions(+), 42 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/TestCheckpointStorageWorkerView.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TestSubtaskCheckpointCoordinator.java
