私はすべての私の仕事が完了したが、私のアプリケーションが完了していないことに気づいたスパークアプリケーション(入力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
Spark BatchアプリケーションまたはSpark Streamingアプリケーションですか? – Hokam
バッチアプリケーション – asma