Flink will soon be releasing 1.0.2, which includes a kryo fix that should help us with the following issues:
FlinkOpABt: https://issues.apache.org/jira/browse/MAHOUT-1750 <https://issues.apache.org/jira/browse/MAHOUT-1750> Flink Dals error: <https://issues.apache.org/jira/browse/MAHOUT-1818> https://issues.apache.org/jira/browse/MAHOUT-1818 As well we may be able to work the Flink Shell in along with these: https://issues.apache.org/jira/browse/MAHOUT-1831 Though that might be better to save for Mahout 0.13 as it is both a new feature and I've noticed that Flink has some issues with this that may not be addressed until a later release. Is there anything on the Spark side of things that needs to be addressed? Or anything else in general?