diff options
| author | Teng Qiu <teng.qiu@gmail.com> | 2015-12-01 07:27:32 +0900 |
|---|---|---|
| committer | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2015-12-01 07:27:32 +0900 |
| commit | a8ceec5e8c1572dd3d74783c06c78b7ca0b8a7ce (patch) | |
| tree | 4dc79a3f127a178e63469552ca0a80bacff8d6f2 /core | |
| parent | 2c5dee0fb8e4d1734ea3a0f22e0b5bfd2f6dba46 (diff) | |
| download | spark-a8ceec5e8c1572dd3d74783c06c78b7ca0b8a7ce.tar.gz spark-a8ceec5e8c1572dd3d74783c06c78b7ca0b8a7ce.tar.bz2 spark-a8ceec5e8c1572dd3d74783c06c78b7ca0b8a7ce.zip | |
[SPARK-12053][CORE] EventLoggingListener.getLogPath needs 4 parameters
```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 #10044 from chutium/SPARK-12053.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 index 9952c97dbd..1355e1ad1b 100644 --- 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)) |