Description
This code in ClientBase.scala sets the replication used for files uploaded to HDFS:
val replication = sparkConf.getInt("spark.yarn.submit.file.replication", 3).toShort
Instead of a hardcoded "3" (which is the default value for HDFS), it should be using the default value from the HDFS conf ("dfs.replication").
Attachments
Issue Links
- links to