-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-25738][SQL] Fix LOAD DATA INPATH for hdfs port #22733
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
Conversation
LOAD DATA INPATH didn't work if the defaultFS included a port for hdfs. Handling this just requires a small change to use the correct URI constructor.
squito
left a comment
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.
I wasn't sure about the best place to put the test, I decided to put it next to the other tests on LOAD DATA INPATH in SQLQuerySuites, though its not running full sql queries. I thought a test just on makeQualified would be much easier to deal with than a full query. Is there a standard place to put tests on helper functions for files like tables.scala?
also if a reviewer would just rewrite themselves to organize tests in the right way, that is fine, this can be abandoned.
| } | ||
| try { | ||
| val newUri = new URI(scheme, authority, pathUri.getPath, pathUri.getFragment) | ||
| val newUri = new URI(scheme, authority, pathUri.getPath, null, pathUri.getFragment) |
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 change is all that's needed to fix the bug, the rest is for testing
|
CC @sujith71955 |
|
LGTM. |
|
LGTM |
|
Test build #97413 has finished for PR 22733 at commit
|
|
Merging to master / 2.4 |
## What changes were proposed in this pull request? LOAD DATA INPATH didn't work if the defaultFS included a port for hdfs. Handling this just requires a small change to use the correct URI constructor. ## How was this patch tested? Added a unit test, ran all tests via jenkins Closes #22733 from squito/SPARK-25738. Authored-by: Imran Rashid <irashid@cloudera.com> Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com> (cherry picked from commit fdaa998) Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>
## What changes were proposed in this pull request? LOAD DATA INPATH didn't work if the defaultFS included a port for hdfs. Handling this just requires a small change to use the correct URI constructor. ## How was this patch tested? Added a unit test, ran all tests via jenkins Closes apache#22733 from squito/SPARK-25738. Authored-by: Imran Rashid <irashid@cloudera.com> Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>
What changes were proposed in this pull request?
LOAD DATA INPATH didn't work if the defaultFS included a port for hdfs.
Handling this just requires a small change to use the correct URI
constructor.
How was this patch tested?
Added a unit test, ran all tests via jenkins