[ https://issues.apache.org/jira/browse/FLINK-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958535#comment-15958535 ]
ASF GitHub Bot commented on FLINK-6270: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110102292 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala --- @@ -350,23 +350,18 @@ class LocalFlinkMiniCluster( def setMemory(config: Configuration): Unit = { // set this only if no memory was pre-configured - if (config.getInteger(ConfigConstants.TASK_MANAGER_MEMORY_SIZE_KEY, -1) == -1) { + if (config.getLong(TaskManagerOptions.MANAGED_MEMORY_SIZE) == -1L) { --- End diff -- If we keep the default at -1 then we should compare against `TaskManagerOptons.MANAGED_MEMORY_SIZE.defaultValue()`; the same applies to other instances of this pattern. > Port several network config parameters to ConfigOption > ------------------------------------------------------ > > Key: FLINK-6270 > URL: https://issues.apache.org/jira/browse/FLINK-6270 > Project: Flink > Issue Type: Improvement > Components: Network > Affects Versions: 1.3.0 > Reporter: Nico Kruber > Assignee: Nico Kruber > Priority: Minor > > I'd like to port some memory and network buffers related config options to > new {{ConfigOption}} instances before continuing with FLINK-4545. These > include: > * {{taskmanager.memory.size}} > * {{taskmanager.memory.fraction}} > * {{taskmanager.memory.off-heap}} > * {{taskmanager.memory.preallocate}} > * {{taskmanager.network.numberOfBuffers}} > * {{taskmanager.memory.segment-size}} > Some of these already existed as {{ConfigOption}} instances in > {{MiniClusterConfiguration}}. -- This message was sent by Atlassian JIRA (v6.3.15#6346)