Skip to content

Commit

Permalink
update with scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
lianhuiwang committed Jul 16, 2015
1 parent 9116810 commit 68552cc
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ class UnsafeExternalAggregationSuite extends QueryTest with BeforeAndAfterAll {
sqlContext.setConf(SQLConf.CODEGEN_ENABLED, true)
val unsafeOriginalValue = sqlContext.conf.unsafeEnabled
sqlContext.setConf(SQLConf.UNSAFE_ENABLED, true)
SparkEnv.get.conf.set("spark.test.aggregate.spillFrequency","5")
SparkEnv.get.conf.set("spark.test.aggregate.spillFrequency", "5")
// Prepare a table that we can group some rows.
sqlContext.table("testData")
.unionAll(sqlContext.table("testData"))
Expand Down Expand Up @@ -131,7 +131,7 @@ class UnsafeExternalAggregationSuite extends QueryTest with BeforeAndAfterAll {
sqlContext.dropTempTable("testData3x")
sqlContext.setConf(SQLConf.CODEGEN_ENABLED, originalValue)
sqlContext.setConf(SQLConf.UNSAFE_ENABLED, unsafeOriginalValue)
SparkEnv.get.conf.set("spark.test.aggregate.spillFrequency","0")
SparkEnv.get.conf.set("spark.test.aggregate.spillFrequency", "0")
}
}
}

0 comments on commit 68552cc

Please sign in to comment.