[FLINK-33003] Flink ML add isolationForest algorithm

• Type: New Feature
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Library / Machine Learning
• Labels: ml pull-request-available

Language

Java

• Assignee: Unassigned
• Reporter: zhaozijun
• Created: 31/Aug/23 02:22
• Updated: 14/Sep/23 03:19

Description

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 🙏

Issue Links

• links to: GitHub Pull Request #253
• links to: GitHub Pull Request #255