[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-28 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r757997408 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/common/datastream/AllReduceUtilsTest.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-25 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r756988674 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceImpl.java ## @@ -0,0 +1,287 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-25 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r756990623 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceImpl.java ## @@ -0,0 +1,287 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-25 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r756998935 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/common/datastream/AllReduceUtilsTest.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-25 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r756986550 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceImpl.java ## @@ -0,0 +1,287 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753631808 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769359 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769187 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769124 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-19 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753631808 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752809063 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752808628 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752807677 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752807105 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752805491 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-18 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752304927 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-16 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r750948104 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,298 @@ +/* + * Licensed to the Apache