Re: value from groubBy paired rdd

Hello Abhishek, your code appears ok. Can you please post the exception you get? Without, it's hard to track down the issue. Best Eike

Re: value from groubBy paired rdd

Hi Mishra, I haven’t tested anything but : > grouped_val= grouped.map(lambda x : (list(x[1]))).collect() what is x[1] ? data = sc.textFile('file:///home/cloudera/LDA-Model/Pyspark/test1.csv') header = data.first() #extract header data = data.filter(lambda x:x !=header)#filter out header