Permalink
Browse files

Scalding Platform honors configProvider in buildConfig (#696)

  • Loading branch information...
1 parent 159c8a5 commit 5741c6570eef8292bc7956408b2a11da4e70ef88 @jnievelt jnievelt committed on GitHub Oct 14, 2016
@@ -723,13 +723,13 @@ class Scalding(
}
final def buildConfig(hConf: Configuration): Config = {
- val postConfig = finalTransform(Config.hadoopWithDefaults(hConf))
+ val postConfig = finalTransform(configProvider(hConf))
postConfig.toMap.foreach { case (k, v) => hConf.set(k, v) }
postConfig
}
private def finalTransform(c: Config): Config =
- transformConfig(withKryo(c))
+ transformConfig(c)
// Store the options used:
.+("summingbird.options" -> options.toString)
.+("summingbird.jobname" -> jobName)

0 comments on commit 5741c65

Please sign in to comment.