Hi, can you please add stacktrace ? Lukas On 23.4.2014 11:45, randylu wrote:
my code is like: rdd2 = rdd1.filter(_._2.length > 1) rdd2.collect() it works well, but if i use a variable /num/ instead of 1: var num = 1 rdd2 = rdd1.filter(_._2.length > num) rdd2.collect() it fails at rdd2.collect() so strange?-- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/about-rdd-filter-tp4657.html Sent from the Apache Spark User List mailing list archive at Nabble.com.