This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c998ba4 [FLINK-21485][sql-client] Simplify the ExecutionContext
(#15006)
add 9e532f1 [hotfix][tests] Stabilize HistoryServerTest
add 17c1bbf [hotfix][tests] Add 60s timeout to UnalingCheckpointITCase
add 6ee501c [hotfix][yarn][tests] Improve assertion in case job failed
add 748aa6b [hotfix][yarn][tests] Add timeouts to yarn HA IT cases
add 63abbb0 [hotfix][coordination] Remove defaultParallelism argument
add e42f83e [hotfix][tests] Update JIRA reference
add f876eb7 [FLINK-21400][coordination] Maintain attempt counts outside
of ExecutionGraph
add ce6fd3e [FLINK-21400][coordination][tests] Enable tests requiring
attempt counts
No new revisions were added by this update.
Summary of changes:
.../flink/connector/file/sink/FileSinkITBase.java | 3 --
.../webmonitor/history/HistoryServerTest.java | 2 +-
.../executiongraph/DefaultExecutionGraph.java | 11 ++--
.../DefaultExecutionGraphBuilder.java | 6 ++-
....java => DefaultSubtaskAttemptNumberStore.java} | 25 +++++----
.../DefaultVertexAttemptNumberStore.java | 55 +++++++++++++++++++
.../runtime/executiongraph/ExecutionJobVertex.java | 25 +++++----
.../runtime/executiongraph/ExecutionVertex.java | 6 ++-
.../MutableVertexAttemptNumberStore.java} | 24 ++++-----
...istener.java => SubtaskAttemptNumberStore.java} | 14 +++--
...Listener.java => VertexAttemptNumberStore.java} | 16 +++---
.../flink/runtime/scheduler/SchedulerBase.java | 4 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 19 ++++++-
.../DefaultSubtaskAttemptNumberStoreTest.java | 60 +++++++++++++++++++++
.../DefaultVertexAttemptNumberStoreTest.java | 62 ++++++++++++++++++++++
.../TestingDefaultExecutionGraphBuilder.java | 3 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 7 +--
.../EventTimeAllWindowCheckpointingITCase.java | 3 --
.../EventTimeWindowCheckpointingITCase.java | 3 --
.../test/checkpointing/LocalRecoveryITCase.java | 3 --
.../ProcessingTimeWindowCheckpointingITCase.java | 3 --
.../checkpointing/UnalignedCheckpointITCase.java | 4 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 2 +-
.../flink/yarn/YARNFileReplicationITCase.java | 11 +++-
.../flink/yarn/YARNHighAvailabilityITCase.java | 6 +--
25 files changed, 294 insertions(+), 83 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/{NoOpExecutionDeploymentListener.java
=> DefaultSubtaskAttemptNumberStore.java} (58%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultVertexAttemptNumberStore.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{scheduler/adaptive/allocator/VertexParallelism.java
=> executiongraph/MutableVertexAttemptNumberStore.java} (60%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/{ExecutionStateUpdateListener.java
=> SubtaskAttemptNumberStore.java} (71%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/{ExecutionDeploymentListener.java
=> VertexAttemptNumberStore.java} (66%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultSubtaskAttemptNumberStoreTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/DefaultVertexAttemptNumberStoreTest.java
