This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6604c5c [FLINK-22098][table-planner-blink] Fix bug for window join:
plan is wrong if join condition contains 'IS NOT DISTINCT FROM'
add 7765fa8 [hotfix][runtime] Wrong annotation was used
add 3cf5f5e [hotfix][test] Cleans up unused local variable
add 317687b [FLINK-22276][runtime] Fixes the concurrency issue
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/executiongraph/ErrorInfo.java | 20 +-
.../failover/flip1/FailureHandlingResult.java | 3 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 8 +-
.../flink/runtime/scheduler/SchedulerBase.java | 43 ++--
.../exceptionhistory/ExceptionHistoryEntry.java | 38 ++-
.../ExceptionHistoryEntryExtractor.java | 157 ------------
.../FailureHandlingResultSnapshot.java | 152 ++++++++++++
.../RootExceptionHistoryEntry.java | 97 +++++---
.../rest/handler/job/JobExceptionsHandlerTest.java | 28 ++-
.../runtime/scheduler/DefaultSchedulerTest.java | 16 +-
.../ExceptionHistoryEntryTest.java | 149 +++++++++++
.../FailureHandlingResultSnapshotTest.java | 276 +++++++++++++++++++++
...est.java => RootExceptionHistoryEntryTest.java} | 105 ++------
13 files changed, 775 insertions(+), 317 deletions(-)
delete 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/FailureHandlingResultSnapshot.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEntryTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/FailureHandlingResultSnapshotTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/{ExceptionHistoryEntryExtractorTest.java
=> RootExceptionHistoryEntryTest.java} (65%)
