Skip to content

Conversation

@liancheng
Copy link
Contributor

No description provided.

@liancheng liancheng changed the title [SPARK-11595] [SQL] [SPARK-11595] [SQL] Fixes ADD JAR when the input path contains URL scheme Nov 9, 2015
@liancheng
Copy link
Contributor Author

PR #9570 backports this one to branch-1.5.

@SparkQA
Copy link

SparkQA commented Nov 9, 2015

Test build #45365 has finished for PR 9569 at commit 0ee3379.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@SparkQA
Copy link

SparkQA commented Nov 9, 2015

Test build #45370 has finished for PR 9569 at commit c146845.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@davies
Copy link
Contributor

davies commented Nov 9, 2015

LGTM, merging this into master and 1.6 branch.

asfgit pushed a commit that referenced this pull request Nov 9, 2015
…heme

Author: Cheng Lian <[email protected]>

Closes #9569 from liancheng/spark-11595.fix-add-jar.

(cherry picked from commit 150f6a8)
Signed-off-by: Davies Liu <[email protected]>
@asfgit asfgit closed this in 150f6a8 Nov 9, 2015
asfgit pushed a commit that referenced this pull request Nov 12, 2015
…ains URL scheme

This PR backports #9569 to branch-1.5.

Author: Cheng Lian <[email protected]>

Closes #9570 from liancheng/spark-11595.for-branch-1.5.
@liancheng liancheng deleted the spark-11595.fix-add-jar branch February 3, 2016 00:26

def addJar(path: String): Unit = {
clientLoader.addJar(path)
val uri = new Path(path).toUri

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

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants