You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tr...@apache.org on 2020/08/14 17:48:11 UTC

[flink] branch master updated (61caf2e -> 56c0169)

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 61caf2e  [FLINK-18935] Reject CompletedOperationCache.registerOngoingOperation if cache is shutting down
     add 56c0169  [FLINK-18220][runtime] Enrich heap space OOMs with memory configuration information

No new revisions were added by this update.

Summary of changes:
 .../flink/core/memory/MemorySegmentFactory.java    |   6 +-
 .../java/org/apache/flink/util/ExceptionUtils.java | 108 +++++++++++++--------
 .../flink/util/TaskManagerExceptionUtils.java      |  15 ++-
 .../org/apache/flink/util/ExceptionUtilsTest.java  |  55 ++++++++++-
 .../flink/runtime/dispatcher/Dispatcher.java       |   2 +
 .../ClusterEntryPointExceptionUtils.java           |  36 ++++---
 .../runtime/entrypoint/ClusterEntrypoint.java      |   4 +-
 .../runtime/executiongraph/ExecutionGraph.java     |   2 +
 .../runtime/jobgraph/InputOutputFormatVertex.java  |   2 -
 .../runtime/taskexecutor/TaskManagerRunner.java    |   9 +-
 .../org/apache/flink/runtime/taskmanager/Task.java |   2 +-
 .../ClusterEntryPointExceptionUtilsTest.java       |  66 +++++++++++++
 .../runtime/minicluster/MiniClusterITCase.java     |  83 ++++++++++++++++
 13 files changed, 315 insertions(+), 75 deletions(-)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntryPointExceptionUtilsTest.java