Hello all, I have been programming for years but this has me baffled.
I have an RDD[(String,Int)] that I return from a function after extensive manipulation of an initial RDD of a different type. When I return this RDD and initiate the .collectAsMap() on it from the caller, I get an empty Map().
If I copy and paste the code from the function into the caller (same exact code) and produce the same RDD and call collectAsMap() on it, I get the Map with all the expected information in it.
What gives? Does Spark defy programming principles or am I crazy? ;-) Thanks! --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
