私はクラスタモードでスパークをインストールしました。 1マスターと2ワーカー。そして、私がマスターノードでsparkシェルを起動すると、それはスケーラシェルを取得せずに数多く実行されています。 しかし、ワーカーノードでspark-shellを実行すると、scala shellを取得しています。そして、私はそのジョブを実行することができます。Apacheはクラスタモードで起動し、ジョブを実行します。マスターまたはワーカーノードでは?
val file=sc.textFile(“hdfs://192.168.1.20:9000/user/1gbdata”)
file.count()
これは私が出力を得ました。
だから私の疑問は実際にスパークジョブを実行する場所です。 ワーカーノードにありますか?