糸とクラスタモードでのsparkコマンドの印刷

Question

spark yarnモードでいくつかのコマンドを出力する必要があります。明らかにprintln（メッセージ）が動作しない...私はメッセージを収集する方法を見つけたい。誰かが現在のメソッドを私は例を収集を使用して私を指摘できますか？

collectの使い方は？

以下のコードは機能しますか？

val c=message.collect() 
println (c) 

Answer 1

あなたは、これは以下のコマンドを使用して達成することができます：

message.foreach(println) 

あなたはエグゼキュータ・ログに上記の呼び出しの出力があります。