flink-ml icon indicating copy to clipboard operation
flink-ml copied to clipboard

[FLINK-33003] Support isolation forest algorithm in Flink ML ([fix] related ListStateWithCache)

Open zhaozijun109 opened this issue 2 years ago • 2 comments

…elated ListStateWithCache in https://github.com/apache/flink-ml/commit/ebdf362664283bacad476126ee18c4059593950a)

What is the purpose of the change

This pull request adds the implementation of Isolation Forest algorithm

Brief change log

-Adds Transformer and Estimator implementation of Isolation Forest in Java -Adds examples and test of Isolation Forest

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): (no)
  • The public API, i.e., is any changed class annotated with @Public(Evolving): (no)

Documentation

  • Does this pull request introduce a new feature? (no)
  • If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)

zhaozijun109 avatar Sep 07 '23 08:09 zhaozijun109

@lindong28 Hi, because of the last PR modified the listStateWithCache class which is useful in IsolationForest.java, so I re-updated and fixed this problem here, please help review when you are free teacher, thank you.

zhaozijun109 avatar Sep 07 '23 08:09 zhaozijun109

@lindong28 Hi, could you please Re-run triggered it? Because the failures( Error: BoundedPerRoundStreamIterationITCase.testPerRoundIterationWithState:170 expected:<3> but was:<4> ) is ok on local test, so I'm not sure how to fix it, thank you teacher.

zhaozijun109 avatar Sep 14 '23 03:09 zhaozijun109