Skip to content

Commit

Permalink
Update InsertIntoHiveTableSuite.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
pzzs committed Mar 26, 2015
1 parent e57d23f commit 6e0140d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ class InsertIntoHiveTableSuite extends QueryTest with BeforeAndAfter {
val testDatawithNull = TestHive.sparkContext.parallelize(
(1 to 10).map(i => ThreeCloumntable(i, i.toString,null))).toDF()

val tmpDir = File.createTempDir()
val tmpDir = Utils.createTempDir()
sql(s"CREATE TABLE table_with_partition(key int,value string) PARTITIONED by (ds string) location '${tmpDir.toURI.toString}' ")
sql("INSERT OVERWRITE TABLE table_with_partition partition (ds='1') SELECT key,value FROM testData")

Expand Down

0 comments on commit 6e0140d

Please sign in to comment.