flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From StefanRRichter <...@git.apache.org>
Subject [GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery
Date Wed, 14 Feb 2018 13:41:15 GMT
Github user StefanRRichter commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5239#discussion_r168176031
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManager.java
---
    @@ -60,4 +62,9 @@ void reportTaskStateSnapshots(
     	 * @return previous state for the operator. Null if no previous state exists.
     	 */
     	OperatorSubtaskState operatorStates(OperatorID operatorID);
    +
    +	/**
    +	 * Returns the base directory for all file-based local state of the owning subtask.
    +	 */
    +	File getSubtaskLocalStateBaseDirectory();
    --- End diff --
    
    This is the manager, not the state objects. So for local recovery that is not based on
local files, the backend will just not care about directories and no invoke this method.


---

Mime
View raw message