This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5532cc0 [FLINK-20355][docs] Add new native K8s documentation page
add b361027 [FLINK-20468][minicluster] Enable leadership control in
MiniCluster to test JM failover
No new revisions were added by this update.
Summary of changes:
.../file/src/FileSourceTextLinesITCase.java | 137 +++------------------
.../EmbeddedCompletedCheckpointStore.java} | 43 +++----
.../PerJobCheckpointRecoveryFactory.java | 68 ++++++++++
.../EmbeddedHaServicesWithLeadershipControl.java} | 28 ++++-
.../nonha/embedded/HaLeadershipControl.java} | 23 ++--
.../flink/runtime/minicluster/MiniCluster.java | 55 ++++++++-
.../minicluster/MiniClusterConfiguration.java | 20 ++-
.../CheckpointCoordinatorRestoringTest.java | 5 +-
.../checkpoint/CheckpointCoordinatorTest.java | 3 +-
.../TestingCheckpointRecoveryFactory.java | 46 -------
.../flink/runtime/jobmaster/JobMasterTest.java | 9 +-
.../LeaderChangeClusterComponentsTest.java | 6 +-
.../TestingMiniClusterConfiguration.java | 2 +-
.../runtime/testutils/MiniClusterResource.java | 1 +
.../MiniClusterResourceConfiguration.java | 34 ++++-
.../util/MiniClusterResourceConfiguration.java | 3 +-
.../NotifyCheckpointAbortedITCase.java | 4 +-
.../test/checkpointing/RegionFailoverITCase.java | 4 +-
18 files changed, 262 insertions(+), 229 deletions(-)
rename
flink-runtime/src/{test/java/org/apache/flink/runtime/testutils/RecoverableCompletedCheckpointStore.java
=>
main/java/org/apache/flink/runtime/checkpoint/EmbeddedCompletedCheckpointStore.java}
(64%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PerJobCheckpointRecoveryFactory.java
rename
flink-runtime/src/{test/java/org/apache/flink/runtime/highavailability/nonha/embedded/TestingEmbeddedHaServices.java
=>
main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedHaServicesWithLeadershipControl.java}
(68%)
copy
flink-runtime/src/{test/java/org/apache/flink/runtime/taskexecutor/NoOpPartitionProducerStateChecker.java
=>
main/java/org/apache/flink/runtime/highavailability/nonha/embedded/HaLeadershipControl.java}
(60%)
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/TestingCheckpointRecoveryFactory.java
