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

Posted to commits@flink.apache.org by xt...@apache.org on 2021/06/04 06:21:53 UTC

[flink] branch release-1.12 updated (31f4099 -> 68f1812)

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 31f4099  [FLINK-22820] Allow storing SUSPENDED jobs in FileArchivedExecutionGraphStore
     add 08bf3e6  [hotfix][coordination] Adjust TaskExecutor resource to reasonably large value for local execution
     add 68f1812  [FLINK-22683][runtime] Fix the null or incorrect value of total Flink/process memory in creating TaskExecutorMemoryConfiguration

No new revisions were added by this update.

Summary of changes:
 .../TaskExecutorMemoryConfiguration.java           |  9 ++-
 .../taskexecutor/TaskExecutorResourceUtils.java    | 72 +++++++++++++++++++++-
 .../active/ActiveResourceManagerTest.java          |  4 +-
 .../TaskExecutorMemoryConfigurationTest.java       | 33 ++--------
 .../TaskExecutorResourceUtilsTest.java             | 62 +++++++++++++++++++
 .../runtime/taskexecutor/TaskExecutorTest.java     | 19 +++---
 ...tractTaskManagerProcessFailureRecoveryTest.java |  2 +
 .../JobManagerHAProcessFailureRecoveryITCase.java  |  2 +
 8 files changed, 158 insertions(+), 45 deletions(-)