arr = [1,2,3,4,5]
data = sc.parallelize(arr)
def func(x, i):
    return x*i
for i in xrange (2,6):
    data = data.map(lambda x: func(x,i)) # doesnt work
    # data = data.map(lambda x: func(x,i)).cache() # work !
for item in data.collect():
    print item