@@ -49,21 +49,21 @@ abstract class StandaloneRecoveryModeFactory(conf: SparkConf, serializer: Serial
49
49
* LeaderAgent in this case is a no-op. Since leader is forever leader as the actual
50
50
* recovery is made by restoring from filesystem.
51
51
*/
52
- private [spark] class FileSystemRecoveryModeFactory (conf : SparkConf , s : Serialization )
53
- extends StandaloneRecoveryModeFactory (conf, s ) with Logging {
52
+ private [spark] class FileSystemRecoveryModeFactory (conf : SparkConf , serializer : Serialization )
53
+ extends StandaloneRecoveryModeFactory (conf, serializer ) with Logging {
54
54
val RECOVERY_DIR = conf.get(" spark.deploy.recoveryDirectory" , " " )
55
55
56
56
def createPersistenceEngine () = {
57
57
logInfo(" Persisting recovery state to directory: " + RECOVERY_DIR )
58
- new FileSystemPersistenceEngine (RECOVERY_DIR , s )
58
+ new FileSystemPersistenceEngine (RECOVERY_DIR , serializer )
59
59
}
60
60
61
61
def createLeaderElectionAgent (master : LeaderElectable ) = new MonarchyLeaderAgent (master)
62
62
}
63
63
64
- private [spark] class ZooKeeperRecoveryModeFactory (conf : SparkConf , s : Serialization )
65
- extends StandaloneRecoveryModeFactory (conf, s ) {
66
- def createPersistenceEngine () = new ZooKeeperPersistenceEngine (conf, s )
64
+ private [spark] class ZooKeeperRecoveryModeFactory (conf : SparkConf , serializer : Serialization )
65
+ extends StandaloneRecoveryModeFactory (conf, serializer ) {
66
+ def createPersistenceEngine () = new ZooKeeperPersistenceEngine (conf, serializer )
67
67
68
68
def createLeaderElectionAgent (master : LeaderElectable ) =
69
69
new ZooKeeperLeaderElectionAgent (master, conf)
0 commit comments