Skip to content

Commit

Permalink
Ignore JavaHiveSuite.
Browse files Browse the repository at this point in the history
  • Loading branch information
marmbrus committed Apr 1, 2014
1 parent 822f626 commit 33a1b1a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ import org.apache.spark.sql.execution.{ExistingRdd, SparkLogicalPlan}
*/
class JavaSQLContext(sparkContext: JavaSparkContext) {

val sqlContext = new SQLContext(sparkContext)
val sqlContext = new SQLContext(sparkContext.sc)

/**
* Executes a query expressed in SQL, returning the result as a JavaSchemaRDD
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,13 +27,13 @@ import org.apache.spark.sql.hive.TestHive
import scala.collection.JavaConversions._

class JavaHiveSQLSuite extends FunSuite {
val javaCtx = new JavaSparkContext(TestSQLContext.sparkContext)
// There is a little trickery here to avoid instantiating two HiveContexts in the same JVM
val javaSqlCtx = new JavaHiveContext(javaCtx) {
override val sqlContext = TestHive
}
ignore("SELECT * FROM src") {
val javaCtx = new JavaSparkContext(TestSQLContext.sparkContext)
// There is a little trickery here to avoid instantiating two HiveContexts in the same JVM
val javaSqlCtx = new JavaHiveContext(javaCtx) {
override val sqlContext = TestHive
}

test("SELECT * FROM src") {
assert(
javaSqlCtx.hql("SELECT * FROM src").collect().map(_.getInt(0)) ===
TestHive.sql("SELECT * FROM src").collect().map(_.getInt(0)).toSeq)
Expand Down

0 comments on commit 33a1b1a

Please sign in to comment.