-
Notifications
You must be signed in to change notification settings - Fork 28.6k
[SPARK-11595] [SQL] Fixes ADD JAR when the input path contains URL scheme #9569
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
PR #9570 backports this one to branch-1.5. |
Test build #45365 has finished for PR 9569 at commit
|
Test build #45370 has finished for PR 9569 at commit
|
LGTM, merging this into master and 1.6 branch. |
…heme Author: Cheng Lian <lian@databricks.com> Closes #9569 from liancheng/spark-11595.fix-add-jar. (cherry picked from commit 150f6a8) Signed-off-by: Davies Liu <davies.liu@gmail.com>
…ains URL scheme This PR backports #9569 to branch-1.5. Author: Cheng Lian <lian@databricks.com> Closes #9570 from liancheng/spark-11595.for-branch-1.5.
@@ -548,7 +547,15 @@ private[hive] class ClientWrapper( | |||
} | |||
|
|||
def addJar(path: String): Unit = { | |||
clientLoader.addJar(path) | |||
val uri = new Path(path).toUri |
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.
我在1.6.1 版本上测试了一下这次的修改,发现add jar 的方式的确是可以通过的。
但是 如果按照 CREATE FUNCTION xxx AS 'org.hue.udf.MyUpper' USING JAR 'hdfs://xxx/myudfs.jar';
的方式, 看log是现实了加载了 , jar。 但是实际运行时会报, class not found 。
请问这个bug 有思路么?
@liancheng
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.
https://issues.apache.org/jira/browse/SPARK-16833, this isseue shows that sometimes it work.
looks like sometimes private val jars = new ConcurrentHashMap[String, File]()
in class NettyStreamManager doesn't successful add jar.
No description provided.