[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r744108746 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriter.java ## @@ -43,6 +43,10 @@ private

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r732437805 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r732431833 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java ## @@ -96,31 +97,36 @@

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730201843 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache