我希望下麵的代碼為每個分區打印“hello”,和“世界”為每一個記錄。但是當我跑它代碼跑但是沒有任何形式的打印輸出。沒有錯誤。這裏正在發生什麼?
% scala val抽樣= spark.sparkContext.parallelize (Seq(1, 2, 3, 4, 5, 6, 7, 8))抽樣。foreachPartition(分區= > {println (“hello”)分區。foreach(有趣= > {println(“世界”)})})
嗨@Leon P,
你需要檢查執行者的日誌。檢查標準輸出
嗨@Leon P,
隻是一個友好的後續。你還需要幫助或者你可以檢查執行者的日誌,找到的消息嗎?