Skip to content

[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.

Sign up for GitHub

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

Closed
liancheng wants to merge 4 commits into from
Closed

[SPARK-11595] [SQL] Fixes ADD JAR when the input path contains URL scheme #9569

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
bb4ac2e
Adds test case
liancheng Nov 9, 2015
1b5a9c8
Updates existing CREATE TEMPORARY FUNCTION test
liancheng Nov 9, 2015
0ee3379
Fixes ADD JAR
liancheng Nov 9, 2015
c146845
Removes unnecessary Thrift server test case
liancheng Nov 9, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Adds test case
  • Loading branch information
@liancheng
liancheng committed Nov 9, 2015
commit bb4ac2e75c0325db3002c0a3e4a3da18790c9e10
9 changes: 9 additions & 0 deletions ...erver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ import org.apache.thrift.transport.TSocket
import org.scalatest.BeforeAndAfterAll

import org.apache.spark.sql.hive.HiveContext
import org.apache.spark.sql.hive.test.TestHive
import org.apache.spark.sql.test.ProcessTestUtils.ProcessOutputCapturer
import org.apache.spark.util.Utils
import org.apache.spark.{Logging, SparkFunSuite}
Expand Down Expand Up @@ -462,6 +463,14 @@ class HiveThriftBinaryServerSuite extends HiveThriftJdbcTest {
assert(conf.get("spark.sql.hive.version") === Some("1.2.1"))
}
}

test("SPARK-11191 add jar using path with URL scheme") {
withJdbcStatement { statement =>
val funcJar = TestHive.getHiveFile("TestUDTF.jar").getCanonicalPath
val jarURL = s"file:///$funcJar"
statement.executeQuery(s"ADD JAR $jarURL")
}
}
}

class HiveThriftHttpServerSuite extends HiveThriftJdbcTest {
Expand Down