[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2018-02-27 Thread sihuazhou
Github user sihuazhou closed the pull request at: https://github.com/apache/flink/pull/5074 ---

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153495140 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java --- @@ -0,0 +1,195 @@ +/* + * Licensed to

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153493925 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java --- @@ -0,0 +1,195 @@ +/* + * Licensed to

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153493396 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -190,6 +199,11 @@ public static

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153492995 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java --- @@ -510,6 +512,13 @@ private static

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153492082 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java --- @@ -510,6 +512,13 @@ private static

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153432998 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java --- @@ -0,0 +1,195 @@ +/* + *

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-28 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153432415 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java --- @@ -0,0 +1,195 @@ +/* + *

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153241166 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java --- @@ -0,0 +1,195 @@ +/* + *

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153234962 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -190,6 +199,11 @@ public static

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5074#discussion_r153235421 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java --- @@ -510,6 +512,13 @@ private

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

2017-11-26 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5074 [FLINK-7873] [runtime] Introduce local recovery ## What is the purpose of the change This PR fixes [FLINK-7873](https://issues.apache.org/jira/browse/FLINK-7873). Current recover