Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168168418
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -316,6 +316,11 @@
*/
public static final String TASK_MANAGER_REFUSED_REGISTRATION_PAUSE =
"taskmanager.refused-registration-pause";
+ /**
+ * The config parameter defining the root directories for storing
file-based state for local recovery.
+ */
+ public static final String TASK_MANAGER_LOCAL_STATE_ROOT_DIR_KEY =
"taskmanager.local-state-root.dir";
--- End diff --
ð
---
