Running FlinkML ALS with more than two features

[Banias H]

Hello Flink experts,

I am new to FlinkML and currently playing around with using ALS in a recommender system. In our dataset, we have more than 2 features. When I tried running the example towards the bottom of this page: https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/ml/als.html, I got a method not implemented error in fit(). Here is how I set up inputDS:

val inputDS: DataSet[(Int, Int, Int, Int, Double)] = env.readCsvFile[(Int, Int, Int, Int, Double)](

  pathToTrainingFile)

...

als.fit(inputDS, parameters)

However when I used only 2 features (i.e passing DataSet[(Int, Int, Double)] to fit()), it went successfully.  Is it a limitation in ALS in general or it is an configuration issue?

I would appreciate any info on this. Thanks.

Regards,

BH