dd.map(identity)
rdd2.cache()
rdd2.setName(rdd.first().toString)
val rdd3 = rdd2.map(identity) ++ rdd2.map(identity)
rdd3
}
}
output.print()
ssc.start()
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Help-needed-to-reproduce-bug-tp2496
rdd3
}
}
output.print()
ssc.start()
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Help-needed-to-reproduce-bug-tp24965.html
Sent from the Apache Spark User List mailing list archive at Nabb
