Running FlinkML ALS with more than two features

[Banias H <ba...@gmail.com>]

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