-
Notifications
You must be signed in to change notification settings - Fork 28.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-19660][SQL][FOLLOWUP] Replace mapred.input.dir.recursive to mapreduce.input.fileinputformat.input.dir.recursive #18361
[SPARK-19660][SQL][FOLLOWUP] Replace mapred.input.dir.recursive to mapreduce.input.fileinputformat.input.dir.recursive #18361
Conversation
….input.dir.recursive
Test build #78288 has finished for PR 18361 at commit
|
Retest this please. |
Test build #78322 has started for PR 18361 at commit |
test this please |
Test build #78339 has started for PR 18361 at commit |
Retest this please. |
Test build #78376 has finished for PR 18361 at commit
|
@@ -197,7 +197,7 @@ class HadoopMapRedWriteConfigUtil[K, V: ClassTag](conf: SerializableJobConf) | |||
FileCommitProtocol.instantiate( | |||
className = classOf[HadoopMapRedCommitProtocol].getName, | |||
jobId = jobId.toString, | |||
outputPath = getConf.get("mapred.output.dir"), | |||
outputPath = getConf.get("mapreduce.output.fileoutputformat.outputdir"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is intended to support the old mapred API, see the comments above this class.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
OK. close this.
@@ -265,7 +265,7 @@ private case class OutputCommitFunctions(tempDirPath: String) { | |||
val committer = FileCommitProtocol.instantiate( | |||
className = classOf[HadoopMapRedCommitProtocol].getName, | |||
jobId = jobId.value.getId.toString, | |||
outputPath = jobConf.get("mapred.output.dir"), | |||
outputPath = jobConf.get("mapreduce.output.fileoutputformat.outputdir"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ditto
Test build #79563 has finished for PR 18361 at commit
|
What changes were proposed in this pull request?
Replace
mapred.input.dir.recursive
tomapreduce.input.fileinputformat.input.dir.recursive
, this property did't record in DeprecatedProperties.html, but source code has.Some times also saw the deprecation info:
How was this patch tested?
Exists tests