You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/03/31 08:40:21 UTC
[flink] branch master updated (4597d55 -> 39c959c)
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 4597d55 [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode
add e10a723 [FLINK-21190][test] Adds comment about hashCode/equals implementation
add 507ec83 [FLINK-21189][runtime] Introduces ExceptionHistoryEntryExtractor
add 39c959c [FLINK-21189][runtime] Adds timestamp to FailureHandlingResult
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/rest_api_v1.snapshot | 26 ++-
.../executiongraph/DefaultExecutionGraph.java | 10 +-
.../runtime/executiongraph/ExecutionGraph.java | 4 +-
.../failover/flip1/ExecutionFailureHandler.java | 13 +-
.../failover/flip1/FailureHandlingResult.java | 33 ++-
.../rest/handler/job/JobExceptionsHandler.java | 61 ++++--
.../messages/JobExceptionsInfoWithHistory.java | 87 +++++++-
.../flink/runtime/scheduler/DefaultScheduler.java | 13 +-
.../runtime/scheduler/ExecutionGraphInfo.java | 7 +-
.../flink/runtime/scheduler/SchedulerBase.java | 66 +++---
.../flink/runtime/scheduler/adaptive/Failing.java | 2 +-
.../ExceptionHistoryEntry.java | 51 ++---
.../ExceptionHistoryEntryExtractor.java | 149 ++++++++++++++
.../RootExceptionHistoryEntry.java | 95 +++++++++
.../ExecutionGraphCheckpointCoordinatorTest.java | 2 +-
.../flip1/ExecutionFailureHandlerTest.java | 31 ++-
.../failover/flip1/FailureHandlingResultTest.java | 12 +-
.../rest/handler/job/JobExceptionsHandlerTest.java | 128 +++++++++---
.../JobExceptionsInfoWithHistoryNoRootTest.java | 19 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 160 +++++++--------
.../scheduler/ExceptionHistoryEntryTest.java | 222 --------------------
.../runtime/scheduler/adaptive/ExecutingTest.java | 3 +-
.../adaptive/StateTrackingMockExecutionGraph.java | 4 +-
.../adaptive/StateWithExecutionGraphTest.java | 4 +-
.../ArchivedTaskManagerLocationMatcher.java | 95 +++++++++
.../ExceptionHistoryEntryExtractorTest.java | 228 +++++++++++++++++++++
.../ExceptionHistoryEntryMatcher.java | 121 +++++++++++
27 files changed, 1171 insertions(+), 475 deletions(-)
rename flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{ => exceptionhistory}/ExceptionHistoryEntry.java (74%)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEntryExtractor.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/ExceptionHistoryEntryTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/ArchivedTaskManagerLocationMatcher.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEntryExtractorTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEntryMatcher.java