Skip to content

Commit 5108700

Browse files
committed
Fix in Spark for the Concurrent thread modification issue (SPARK-1097, HADOOP-10456)
1 parent 681b36f commit 5108700

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ class HadoopRDD[K, V](
126126
private val createTime = new Date()
127127

128128
// Returns a JobConf that will be used on slaves to obtain input splits for Hadoop reads.
129-
protected def getJobConf(): JobConf = {
129+
protected def getJobConf(): JobConf = synchronized {
130130
val conf: Configuration = broadcastedConf.value.value
131131
if (conf.isInstanceOf[JobConf]) {
132132
// A user-broadcasted JobConf was provided to the HadoopRDD, so always use it.

0 commit comments

Comments
 (0)