Hi, it looks to me as if you need the whole user database on every node, so maybe put the id->name information as a Map[Id, String] in a broadcast variable and then do something like
recommendations.map(line => {
line.map(uid => usernames(uid))
})
or so?
Tobias
