[SPARK-12053][CORE] EventLoggingListener.getLogPath needs 4 parameters

chutium · sarutak · commit a8ceec5e8c15 · 2015-12-01T07:27:32.000+09:00
```EventLoggingListener.getLogPath``` needs 4 input arguments: https://github.com/apache/spark/blob/v1.6.0-preview2/core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala#L276-L280 the 3rd parameter should be appAttemptId, 4th parameter is codec... Author: Teng Qiu <teng.qiu@gmail.com> Closes apache#10044 from chutium/SPARK-12053.
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -934,7 +934,7 @@ private[deploy] class Master(
         }
 
       val eventLogFilePrefix = EventLoggingListener.getLogPath(
-          eventLogDir, app.id, app.desc.eventLogCodec)
+          eventLogDir, app.id, appAttemptId = None, compressionCodecName = app.desc.eventLogCodec)
       val fs = Utils.getHadoopFileSystem(eventLogDir, hadoopConf)
       val inProgressExists = fs.exists(new Path(eventLogFilePrefix +
           EventLoggingListener.IN_PROGRESS))

Original file line number	Diff line number	Diff line change
`@@ -934,7 +934,7 @@ private[deploy] class Master(`
`934`	`934`	`}`
`935`	`935`
`936`	`936`	`val eventLogFilePrefix = EventLoggingListener.getLogPath(`
`937`		`- eventLogDir, app.id, app.desc.eventLogCodec)`
	`937`	`+ eventLogDir, app.id, appAttemptId = None, compressionCodecName = app.desc.eventLogCodec)`
`938`	`938`	`val fs = Utils.getHadoopFileSystem(eventLogDir, hadoopConf)`
`939`	`939`	`val inProgressExists = fs.exists(new Path(eventLogFilePrefix +`
`940`	`940`	`EventLoggingListener.IN_PROGRESS))`