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

2021-10-19 Thread GitBox
gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r731782006 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/coordinator/HeadOperatorCoordinator.java ## @@ -63,10 +63,16 @@

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

2021-10-19 Thread GitBox
gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r731780041 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/HeadOperator.java ## @@ -129,12 +168,89 @@ public void setup(

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

2021-10-19 Thread GitBox
gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r731534576 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/HeadOperator.java ## @@ -129,12 +168,89 @@ public void setup(