You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by zhangminglei <gi...@git.apache.org> on 2018/04/03 13:37:29 UTC
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5808
[FLINK-8835] [taskmanager] Fix TaskManager config keys
## What is the purpose of the change
Fix TaskManager config keys to make it easier for users.
## Brief change log
Change the original key and variable name to a easier way.
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhangminglei/flink flink-8835-taskmanager-config-key
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5808.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 #5808
----
commit a4df41079edd228ea346227f2f04b41d694c0420
Author: zhangminglei <zm...@...>
Date: 2018-04-03T13:23:19Z
[FLINK-8835] [taskmanager] Fix TaskManager config keys
----
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179054013
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
--- End diff --
But confused me is that there is no reference to this field in project.
---
[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5808
Hi, @zentol I have updated the code based on your suggestions. Could you can take another look when available ?
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045805
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
/**
* The interval (in ms) for the log thread to log the current memory usage.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS} instead
--- End diff --
I would revert the renaming; it' a useful piece of info that we're dealing with milliseconds.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5808
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045016
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
.defaultValue("500 ms")
- .withDescription("The initial registration pause between two consecutive registration attempts. The pause" +
- " is doubled for each new registration attempt until it reaches the maximum registration pause.");
+ .withDescription("The initial registration backoff between two consecutive registration attempts. The backoff" +
+ " is doubled for each new registration attempt until it reaches the maximum registration backoff.");
/**
- * The maximum registration pause between two consecutive registration attempts.
+ * The maximum registration backoff between two consecutive registration attempts.
*/
- public static final ConfigOption<String> MAX_REGISTRATION_PAUSE =
- key("taskmanager.max-registration-pause")
+ public static final ConfigOption<String> REGISTRATION_MAX_BACKOFF =
+ key("taskmanager.registration.max-backoff")
.defaultValue("30 s")
- .withDescription("The maximum registration pause between two consecutive registration attempts. The max" +
- " registration pause requires a time unit specifier (ms/s/min/h/d).");
+ .withDescription("The maximum registration backoff between two consecutive registration attempts. The max" +
+ " registration backoff requires a time unit specifier (ms/s/min/h/d).");
/**
- * The pause after a registration has been refused by the job manager before retrying to connect.
+ * The backoff after a registration has been refused by the job manager before retrying to connect.
*/
- public static final ConfigOption<String> REFUSED_REGISTRATION_PAUSE =
- key("taskmanager.refused-registration-pause")
+ public static final ConfigOption<String> REFUSED_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.refused-backoff")
--- End diff --
missing deprecated key `"taskmanager.refused-registration-pause"`
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179060468
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
--- End diff --
I think there already has deprecated key ```"taskmanager.initial-registration-pause"``` in the ```ConfigConstants.java``` file. Below:
```
/**
* The initial registration pause between two consecutive registration attempts. The pause
* is doubled for each new registration attempt until it reaches the maximum registration pause.
*
* @deprecated use {@link TaskManagerOptions#INITIAL_REGISTRATION_BACKOFF} instead
*/
@Deprecated
public static final String TASK_MANAGER_INITIAL_REGISTRATION_PAUSE = "taskmanager.initial-registration-pause";
```
Or, I am guessing what you mean is that I should change the value ```taskmanager.initial-registration-pause``` to ```taskmanager.registration.initial-backoff``` in ```ConfigConstants.java``` file. But you said ((nor should we change the value)) before. So, Hmm. Am I missing something ?
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179055088
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
--- End diff --
There is no reference because the project works against `TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD`. We keep this field around since it is in a `@Public` class, and thus part of the stable API.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045294
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -321,8 +321,8 @@
* credit-based flow control.
*/
@Deprecated
- public static final ConfigOption<Boolean> NETWORK_CREDIT_BASED_FLOW_CONTROL_ENABLED =
- key("taskmanager.network.credit-based-flow-control.enabled")
+ public static final ConfigOption<Boolean> TASKMANAGER_NETWORK_CREDIT_MODEL =
+ key("taskmanager.network.credit-model")
--- End diff --
even though this key is new I would still add the deprecated key `"taskmanager.network.credit-based-flow-control.enabled"`
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179044730
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
--- End diff --
We can't rename this variable (nor should we change the value) since this class is `@Public`. The referral to the `TaskManagerOptions` is enough.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045089
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -153,13 +153,13 @@
" is typically proportional to the number of physical CPU cores that the TaskManager's machine has" +
" (e.g., equal to the number of cores, or half the number of cores).");
- public static final ConfigOption<Boolean> DEBUG_MEMORY_USAGE_START_LOG_THREAD =
- key("taskmanager.debug.memory.startLogThread")
+ public static final ConfigOption<Boolean> DEBUG_MEMORY_LOG =
+ key("taskmanager.debug.memory.log")
--- End diff --
missing deprecated key `"taskmanager.debug.memory.startLogThread"`
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179056634
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
--- End diff --
Ah. Makes better sense to me.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179061417
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
--- End diff --
```
public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
key("taskmanager.registration.initial-backoff")
.defaultValue("500 ms")
====> .withDeprecatedKeys("taskmanager.initial-registration-pause")
.withDescription("....");
```
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045129
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -153,13 +153,13 @@
" is typically proportional to the number of physical CPU cores that the TaskManager's machine has" +
" (e.g., equal to the number of cores, or half the number of cores).");
- public static final ConfigOption<Boolean> DEBUG_MEMORY_USAGE_START_LOG_THREAD =
- key("taskmanager.debug.memory.startLogThread")
+ public static final ConfigOption<Boolean> DEBUG_MEMORY_LOG =
+ key("taskmanager.debug.memory.log")
.defaultValue(false)
.withDescription("Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.");
- public static final ConfigOption<Long> DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS =
- key("taskmanager.debug.memory.logIntervalMs")
+ public static final ConfigOption<Long> DEBUG_MEMORY_USAGE_LOG_INTERVAL =
+ key("taskmanager.debug.memory.log-interval")
--- End diff --
missing deprecated key `"taskmanager.debug.memory.logIntervalMs"`
---
[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5808
merging.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179044920
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
--- End diff --
missing deprecated key `"taskmanager.initial-registration-pause"`
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179062374
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -321,8 +321,8 @@
* credit-based flow control.
*/
@Deprecated
- public static final ConfigOption<Boolean> NETWORK_CREDIT_BASED_FLOW_CONTROL_ENABLED =
- key("taskmanager.network.credit-based-flow-control.enabled")
+ public static final ConfigOption<Boolean> TASKMANAGER_NETWORK_CREDIT_MODEL =
--- End diff --
Will change.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179062712
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
--- End diff --
Oh. Sorry. I see.
---
[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5808
cc @StephanEwen @aljoscha
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045392
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -321,8 +321,8 @@
* credit-based flow control.
*/
@Deprecated
- public static final ConfigOption<Boolean> NETWORK_CREDIT_BASED_FLOW_CONTROL_ENABLED =
- key("taskmanager.network.credit-based-flow-control.enabled")
+ public static final ConfigOption<Boolean> TASKMANAGER_NETWORK_CREDIT_MODEL =
--- End diff --
remove `TASKMANAGER_` prefix, it is redundant as the option is defined int he `TaskManagerOptions`.
---
[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5808
Thanks @zentol for review. 👍
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179044973
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
.defaultValue("500 ms")
- .withDescription("The initial registration pause between two consecutive registration attempts. The pause" +
- " is doubled for each new registration attempt until it reaches the maximum registration pause.");
+ .withDescription("The initial registration backoff between two consecutive registration attempts. The backoff" +
+ " is doubled for each new registration attempt until it reaches the maximum registration backoff.");
/**
- * The maximum registration pause between two consecutive registration attempts.
+ * The maximum registration backoff between two consecutive registration attempts.
*/
- public static final ConfigOption<String> MAX_REGISTRATION_PAUSE =
- key("taskmanager.max-registration-pause")
+ public static final ConfigOption<String> REGISTRATION_MAX_BACKOFF =
--- End diff --
missing deprecated key `"taskmanager.max-registration-pause"`
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179062944
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
--- End diff --
oh my god.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zhangminglei <gi...@git.apache.org>.
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179053677
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -299,15 +299,15 @@
/**
* Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
*
- * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_USAGE_START_LOG_THREAD} instead
+ * @deprecated use {@link TaskManagerOptions#DEBUG_MEMORY_LOG} instead
*/
@Deprecated
- public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD = "taskmanager.debug.memory.startLogThread";
+ public static final String TASK_MANAGER_DEBUG_MEMORY_LOG = "taskmanager.debug.memory.log";
--- End diff --
will change.
---
[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...
Posted by zentol <gi...@git.apache.org>.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5808#discussion_r179045058
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ---
@@ -104,40 +104,40 @@
" global ssl flag " + SecurityOptions.SSL_ENABLED.key() + " is set to true");
/**
- * The initial registration pause between two consecutive registration attempts. The pause
- * is doubled for each new registration attempt until it reaches the maximum registration pause.
+ * The initial registration backoff between two consecutive registration attempts. The backoff
+ * is doubled for each new registration attempt until it reaches the maximum registration backoff.
*/
- public static final ConfigOption<String> INITIAL_REGISTRATION_PAUSE =
- key("taskmanager.initial-registration-pause")
+ public static final ConfigOption<String> INITIAL_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.initial-backoff")
.defaultValue("500 ms")
- .withDescription("The initial registration pause between two consecutive registration attempts. The pause" +
- " is doubled for each new registration attempt until it reaches the maximum registration pause.");
+ .withDescription("The initial registration backoff between two consecutive registration attempts. The backoff" +
+ " is doubled for each new registration attempt until it reaches the maximum registration backoff.");
/**
- * The maximum registration pause between two consecutive registration attempts.
+ * The maximum registration backoff between two consecutive registration attempts.
*/
- public static final ConfigOption<String> MAX_REGISTRATION_PAUSE =
- key("taskmanager.max-registration-pause")
+ public static final ConfigOption<String> REGISTRATION_MAX_BACKOFF =
+ key("taskmanager.registration.max-backoff")
.defaultValue("30 s")
- .withDescription("The maximum registration pause between two consecutive registration attempts. The max" +
- " registration pause requires a time unit specifier (ms/s/min/h/d).");
+ .withDescription("The maximum registration backoff between two consecutive registration attempts. The max" +
+ " registration backoff requires a time unit specifier (ms/s/min/h/d).");
/**
- * The pause after a registration has been refused by the job manager before retrying to connect.
+ * The backoff after a registration has been refused by the job manager before retrying to connect.
*/
- public static final ConfigOption<String> REFUSED_REGISTRATION_PAUSE =
- key("taskmanager.refused-registration-pause")
+ public static final ConfigOption<String> REFUSED_REGISTRATION_BACKOFF =
+ key("taskmanager.registration.refused-backoff")
.defaultValue("10 s")
- .withDescription("The pause after a registration has been refused by the job manager before retrying to connect.");
+ .withDescription("The backoff after a registration has been refused by the job manager before retrying to connect.");
/**
- * Defines the maximum time it can take for the TaskManager registration. If the duration is
+ * Defines the timeout it can take for the TaskManager registration. If the duration is
* exceeded without a successful registration, then the TaskManager terminates.
*/
- public static final ConfigOption<String> MAX_REGISTRATION_DURATION =
- key("taskmanager.maxRegistrationDuration")
+ public static final ConfigOption<String> REGISTRATION_TIMEOUT =
+ key("taskmanager.registration.timeout")
--- End diff --
missing deprecated key `"taskmanager.maxRegistrationDuration"`
---