0
これは私のSparkアプリケーションの関連部分で、appName
を使ってアプリケーションの名前を設定します。コードで定義されたアプリケーション名がYARN UIのアプリケーションを実行中に表示されないのはなぜですか?
import org.apache.spark.sql.SparkSession
object sample extends App {
val spark = SparkSession.
builder().
appName("Cortex-Batch"). // <-- application name
enableHiveSupport().
getOrCreate()
私は、実行中のアプリケーションの下でのHadoop YARNクラスタ内のスパークアプリケーションの名前をチェックして、私はコードで定義された名前が表示されません。どうして?
は、私は次のように--properties-file
を使用して、プロパティファイルでを使用します。
/usr/hdp/current/spark2-client/bin/spark-submit \
--master yarn \
--deploy-mode cluster \
--class com.jpmc.cortex.LoadCortexDataLake \
--verbose \
--properties-file /home/e707698/cortex-batch.properties \
--jars /usr/hdp/current/spark-client/lib/datanucleus-api-jdo-3.2.6.jar,/usr/hdp/current/spark-client/lib/datanucleus-core-3.2.10.jar,/usr/hdp/current/spark-client/lib/datanucleus-rdbms-3.2.9.jar \
/home/e707698/cortex-data-lake-batch.jar "/tmp/clickfiles1" "cortex_dev.xpo_click1"
代わりに、プロパティファイルで指定したアプリケーション名が取られています。プロパティファイルからプロパティを削除しようとしましたが、その名前はSparkアプリケーションのフルクラス名(/com/jpmc/cortex/LoadCortexDataLake
)です。
どうすればよいですか?
ここで、「ここに定義されているアプリ名を取得していない」ことを確認してください。プロパティファイルとプロパティは何ですか? "プロパティファイルに指定されたアプリ名が使用されています" _ Sparkアプリをどのように提出しますか? –
'' spark-submit'のコマンドラインで '--name'が差をつけるかどうか確認できますか?あなたは、Web UIの名前を持つページのスクリーンショットを撮り、その質問に含めることができますか? –