[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r740039154 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java ## @@ -139,6 +142,22 @@ public void

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r740036597 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java ## @@ -99,19 +99,18 @@

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r740035659 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/InputOperator.java ## @@ -53,13 +53,14 @@ public void

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739975616 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/ReduceAllRoundProcessFunction.java ## @@ -49,16 +59,53 @@

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739975373 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/FailingMap.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739975206 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/FailingMap.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739975028 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/FailingMap.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739974909 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/BoundedAllRoundCheckpointTest.java ## @@ -0,0 +1,191 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739945912 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java ## @@ -61,6 +62,12 @@ public

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739942123 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperatorCheckpointAligner.java ## @@ -0,0 +1,104 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r737186361 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java ## @@ -224,4 +261,28 @@ public