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

Posted to dev@flink.apache.org by "zhaozijun (Jira)" <ji...@apache.org> on 2023/08/31 02:23:00 UTC

[jira] [Created] (FLINK-33003) Flink ML add isolationForest algorithm

zhaozijun created FLINK-33003:
---------------------------------

             Summary: Flink ML add isolationForest algorithm
                 Key: FLINK-33003
                 URL: https://issues.apache.org/jira/browse/FLINK-33003
             Project: Flink
          Issue Type: New Feature
          Components: Library / Machine Learning
            Reporter: zhaozijun
         Attachments: IsolationForest.zip

I want to use flink solve some problems related to anomaly detection, but currently flink ml lacks algorithms related to anomaly detection, so I want to add the isolation forest algorithm to library/flink ml. During the implementation process, when IterationBody is used, I try to understand the implementation of the Kmeans algorithm, and use iterative behavior to calculate the center point of the isolation forest algorithm, but in the test, I found that when the parallelism > 1, the number of iterations > 1, and there will be sometimes succeed sometimes fail (fail to find the broadcast variable). Please teachers help me to review and point out my problem. Thank you 🙏



--
This message was sent by Atlassian Jira
(v8.20.10#820010)