[ https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592437#comment-15592437 ]
ASF GitHub Bot commented on FLINK-4871: --------------------------------------- GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2669 [FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to MiniCluster This PR is based on #2651, #2655 and #2657. If the managed memory size for the task manager has not been set in the Configuration, then it is automatically calculated by dividing the available memory by the number of distributed components. Additionally this PR allows to provide a MetricRegistry to the TaskManagerRunner. That way it is possible to use the MiniCluster's MetricRegistry. Add memory calculation for task managers. You can merge this pull request into a Git repository by running: $ git pull https://github.com/tillrohrmann/flink miniClusterUpdate Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2669.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2669 ---- commit 6487af737b57ca16190c0f4a6b63d4afd2af2b06 Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-10-17T14:22:16Z [FLINK-4847] Let RpcEndpoint.start/shutDown throw exceptions Allowing the RpcEndpoint.start/shutDown to throw exceptions will help to let rpc endpoints to quickly fail without having to use a callback like the FatalErrorHandler. commit cf7661aafb71649360ad6159f27a82433bfd8f75 Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-10-17T14:03:02Z [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM This PR introduces a FatalErrorHandler and the MetricRegistry to the RM. The FatalErrorHandler is used to handle fatal errors. Additionally, the PR adds the MetricRegistry to the RM which can be used to register metrics. Apart from these changes the PR restructures the code of the RM a little bit and fixes some blocking operations. The PR also moves the TestingFatalErrorHandler into the util package of flink-runtime test. That it is usable across multiple tests. Introduce ResourceManagerRunner to handle errors in the ResourceManager commit 61d328adb637c44889aa724c270c39657d1289c2 Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-10-18T16:03:00Z [FLINK-4853] [rm] Clean up job manager registration at the resource manager Introduce the JobLeaderIdService which automatically retrieves the current job leader id. This job leader id is used to validate job manager registartion attempts. Additionally, it is used to disconnect old job leaders from the resource manager. Add comments commit 58e8d6c06b55456793d2dffbee309e491d21d309 Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-10-20T09:07:08Z [FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to MiniCluster If the managed memory size for the task manager has not been set in the Configuration, then it is automatically calculated by dividing the available memory by the number of distributed components. Additionally this PR allows to provide a MetricRegistry to the TaskManagerRunner. That way it is possible to use the MiniCluster's MetricRegistry. Add memory calculation for task managers ---- > Add memory calculation for TaskManagers and forward MetricRegistry > ------------------------------------------------------------------ > > Key: FLINK-4871 > URL: https://issues.apache.org/jira/browse/FLINK-4871 > Project: Flink > Issue Type: Sub-task > Components: Cluster Management > Reporter: Till Rohrmann > Assignee: Till Rohrmann > Priority: Minor > > Add automatic memory calculation for {{TaskManagers}} executed by the > {{MiniCluster}}. > Additionally, change the {{TaskManagerRunner}} to accept a given > {{MetricRegistry}} so that the one instantiated by the {{MiniCluster}} is > used. -- This message was sent by Atlassian JIRA (v6.3.4#6332)