Update ProgressTrackerBase.scala
This commit is contained in:
Родитель
7a34e39bd9
Коммит
289b617109
|
@ -37,6 +37,7 @@ private[spark] abstract class ProgressTrackerBase[T <: EventHubsConnector](
|
|||
appName)
|
||||
private[spark] lazy val tempDirectoryStr = PathTools.makeTempDirectoryStr(progressDir, appName)
|
||||
private[spark] lazy val metadataDirectoryStr = PathTools.makeMetadataDirectoryStr(progressDir,
|
||||
appName)
|
||||
|
||||
private[spark] lazy val progressDirectoryPath = new Path(progressDirectoryStr)
|
||||
private[spark] lazy val tempDirectoryPath = new Path(tempDirectoryStr)
|
||||
|
|
Загрузка…
Ссылка в новой задаче