This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 686634aa05a [FLINK-25097][table-planner] Fix bug in inner join when
the filter condition is boolean type
add 8540b8d3510 [FLINK-28258][runtime] Introduce ExecutionHistory to host
historical executions for each execution vertex
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 2 +-
.../generated/job_manager_configuration.html | 2 +-
.../flink/configuration/JobManagerOptions.java | 4 +-
.../executiongraph/AccessExecutionVertex.java | 10 +-
.../executiongraph/ArchivedExecutionVertex.java | 30 ++--
.../executiongraph/DefaultExecutionGraph.java | 10 +-
.../DefaultExecutionGraphBuilder.java | 4 +-
.../runtime/executiongraph/ExecutionHistory.java | 94 ++++++++++
.../runtime/executiongraph/ExecutionJobVertex.java | 4 +-
.../runtime/executiongraph/ExecutionVertex.java | 30 +---
.../handler/job/AbstractSubtaskAttemptHandler.java | 13 +-
...SubtaskExecutionAttemptAccumulatorsHandler.java | 4 +-
.../job/SubtaskExecutionAttemptDetailsHandler.java | 4 +-
.../flink/runtime/util/EvictingBoundedList.java | 192 ---------------------
.../executiongraph/ExecutionHistoryTest.java | 85 +++++++++
.../rest/handler/job/JobExceptionsHandlerTest.java | 4 +-
.../SubtaskCurrentAttemptDetailsHandlerTest.java | 4 +-
.../SubtaskExecutionAttemptDetailsHandlerTest.java | 4 +-
.../runtime/util/EvictingBoundedListTest.java | 180 -------------------
.../DefaultSchedulerLocalRecoveryITCase.java | 4 +-
20 files changed, 238 insertions(+), 446 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionHistory.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/util/EvictingBoundedList.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionHistoryTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/EvictingBoundedListTest.java
