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
