rdd.foreachPartition()沒有?

[p42af]

我希望下麵的代碼為每個分區打印“hello”,和“世界”為每一個記錄。但是當我跑它代碼跑但是沒有任何形式的打印輸出。沒有錯誤。這裏正在發生什麼?

% scala val抽樣= spark.sparkContext.parallelize (Seq(1, 2, 3, 4, 5, 6, 7, 8))抽樣。foreachPartition(分區= > {println (“hello”)分區。foreach(有趣= > {println(“世界”)})})

[RKNutalapati]

檢查你的標準輸出日誌

[Hubert_Dudek1]

這是懶惰的評價所以你需要觸發行動我猜

[jose_gonzalez · Accepted solution]

嗨@Leon P,

你需要檢查執行者的日誌。檢查標準輸出

[jose_gonzalez]

嗨@Leon P,

隻是一個友好的後續。你還需要幫助或者你可以檢查執行者的日誌,找到的消息嗎?