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/03 07:19:31 UTC

[flink] branch master updated (9986e6f -> 9e8c551)

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

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


    from 9986e6f  [FLINK-22612][python] Restructure the coders in PyFlink
     add 9e8c551  [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    | 61 +++++++++++++++++++++
 .../active/ActiveResourceManagerTest.java          |  4 +-
 .../TaskExecutorMemoryConfigurationTest.java       | 33 ++----------
 .../TaskExecutorResourceUtilsTest.java             | 62 ++++++++++++++++++++++
 .../runtime/taskexecutor/TaskExecutorTest.java     | 19 ++++---
 ...tractTaskManagerProcessFailureRecoveryTest.java |  2 +
 .../JobManagerHAProcessFailureRecoveryITCase.java  |  2 +
 8 files changed, 150 insertions(+), 42 deletions(-)