Found the problem. There was an rdd.distinct hiding in my code that I had overlooked, and that caused this behavior (because instead of iterating over the raw RDD, I was instead iterating over the RDD which had been derived from it).
Thank you everyone! - Chris -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Incremental-load-of-RDD-from-HDFS-tp25145p25166.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
