2016-09-13 2 views
1

私はすべての私の仕事が完了したが、私のアプリケーションが完了していないことに気づいたスパークアプリケーション(入力90Mo)を実行します。 )SCが正常に停止したことを私のアプリケーションがスパークを完了しない理由

16/09/13 2時17分31秒INFO DAGSchedulerを得る:ジョブ15が終了:slowlyChangingDimension.java:244でsaveAsTextFileを取っ1,222274の 16/09/13 02:17:38 INFO BlockManagerInfo:メモリ内の10.0.10.45:46789のbroadcast_49_piece0を削除しました(サイズ:26.2 KB、フリー:1424.7 MB) 16/09/13 02:17:38 INFO BlockManagerInfo:10.0.10.51のbroadcast_49_piece0を削除しました。メモリ内の54860(サイズ:26.2 KB、フリー:1424.7 MB) 16/09/13 02:17:38 INFO BlockManagerInfo:メモリ内の10.0.10.45:46789のbroadcast_48_piece0を削除しました(サイズ:4.4 KB、フリー:1424.7 MB) 16/09/13 02:17:38 INFO BlockManagerInfo:削除BlockManagerInfo:メモリ内の10.0.10.47:51300上のbroadcast_48_piece0を削除しました(サイズ:4.4 KB、128 KB、空き:1458.5 MB) BlockManagerInfo:メモリに10.0.10.51:54860のbroadcast_48_piece0を削除しました(サイズ:4.4 KB、フリー:1424.7 MB) 16/09/13 02:17: BlockManagerInfo:メモリ内の10.0.10.54:44644のbroadcast_48_piece0を削除しました(サイズ:4.4 KB、フリー:1458.6 MB) 16/09/13 02:17:38 INFO BlockManagerInfo:10.0.10.52:32794上のbroadcast_48_piece0をメモリに削除しましたサイズ:4.4 KB、フリー:1458.6 MB) 16/09/13 02:17: 38 INFO BlockManagerInfo:10.0.10.45:46789 on 10.0.10.45:46789をメモリから削除しました(サイズ:26.2 KB、フリー:1424.7 MB) 16/09/13 02:17:38 INFO BlockManagerInfo:10.0.10.48:54348のbroadcast_47_piece0をメモリに削除しました。サイズ:26.2キロバイト、無料:1458.6メガバイト) 16/09/13 2時17分38秒INFO ContextCleaner:これは、バッチ・アプリケーションであるように洗浄は28

+0

Spark Ba​​tchアプリケーションまたはSpark Streamingアプリケーションですか? – Hokam

+0

バッチアプリケーション – asma

答えて

1

をシャッフルします。あなたはプログラムの最後の行にcontext.stop()を使用する必要があります、それは正常に動作します。
そうでない場合は、実行しているコードを共有できます。

+0

ok私は最初にそれを使用しているかどうか確認します – asma

+0

それは行方不明のものでしたありがとう@ホーカム – asma

関連する問題