Also forward ADD JAR command to Hive

liancheng · liancheng · commit 095b2c797c9c · 2014-09-03T20:11:39.000-07:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/commands.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/commands.scala
@@ -72,6 +72,7 @@ case class AddJar(path: String) extends LeafNode with Command {
   override def output = Seq.empty
 
   override protected[sql] lazy val sideEffectResult: Seq[Any] = {
+    hiveContext.runSqlHive(s"ADD JAR $path")
     hiveContext.sparkContext.addJar(path)
     Seq.empty[Any]
   }

Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,7 @@ case class AddJar(path: String) extends LeafNode with Command {`
`72`	`72`	`override def output = Seq.empty`
`73`	`73`
`74`	`74`	`override protected[sql] lazy val sideEffectResult: Seq[Any] = {`
	`75`	`+ hiveContext.runSqlHive(s"ADD JAR $path")`
`75`	`76`	`hiveContext.sparkContext.addJar(path)`
`76`	`77`	`Seq.empty[Any]`
`77`	`78`	`}`