You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ga...@apache.org on 2021/11/24 06:04:25 UTC

[flink-ml] branch master updated (212be99 -> 3581dba)

This is an automated email from the ASF dual-hosted git repository.

gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git.


    from 212be99  [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm
     add 4c47957  [hotfix] Fix nullpointer exception when broadcast variables are cleaned
     add 3581dba  [hotfix] Cache records when processing elements rather than only in snapshot func

No new revisions were added by this update.

Summary of changes:
 .../ml/common/broadcast/BroadcastContext.java      |  2 +-
 .../BroadcastVariableReceiverOperator.java         | 51 +++++++++++----------
 .../BroadcastVariableReceiverOperatorTest.java     | 53 +++++++++++++++++++++-
 3 files changed, 79 insertions(+), 27 deletions(-)