aboutsummaryrefslogtreecommitdiff
path: root/R/pkg/inst/tests/testthat/test_take.R
diff options
context:
space:
mode:
authorFelix Cheung <felixcheung_m@hotmail.com>2016-07-17 19:02:21 -0700
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2016-07-17 19:02:21 -0700
commitd27fe9ba6763aae6a5e48f16d7cbd85658df7cf7 (patch)
tree26d85a87f9f04f8ccf3ff48c5e612bd0c202d44e /R/pkg/inst/tests/testthat/test_take.R
parent7b84758034b9bceca1168438ef5d0beefd5b5273 (diff)
downloadspark-d27fe9ba6763aae6a5e48f16d7cbd85658df7cf7.tar.gz
spark-d27fe9ba6763aae6a5e48f16d7cbd85658df7cf7.tar.bz2
spark-d27fe9ba6763aae6a5e48f16d7cbd85658df7cf7.zip
[SPARK-16027][SPARKR] Fix R tests SparkSession init/stop
## What changes were proposed in this pull request? Fix R SparkSession init/stop, and warnings of reusing existing Spark Context ## How was this patch tested? unit tests shivaram Author: Felix Cheung <felixcheung_m@hotmail.com> Closes #14177 from felixcheung/rsessiontest.
Diffstat (limited to 'R/pkg/inst/tests/testthat/test_take.R')
-rw-r--r--R/pkg/inst/tests/testthat/test_take.R4
1 files changed, 3 insertions, 1 deletions
diff --git a/R/pkg/inst/tests/testthat/test_take.R b/R/pkg/inst/tests/testthat/test_take.R
index daf5e41abe..07f00c9915 100644
--- a/R/pkg/inst/tests/testthat/test_take.R
+++ b/R/pkg/inst/tests/testthat/test_take.R
@@ -30,7 +30,7 @@ strList <- list("Dexter Morgan: Blood. Sometimes it sets my teeth on edge, ",
"raising me. But they're both dead now. I didn't kill them. Honest.")
# JavaSparkContext handle
-sparkSession <- sparkR.session()
+sparkSession <- sparkR.session(enableHiveSupport = FALSE)
sc <- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "getJavaSparkContext", sparkSession)
test_that("take() gives back the original elements in correct count and order", {
@@ -65,3 +65,5 @@ test_that("take() gives back the original elements in correct count and order",
expect_equal(length(take(numListRDD, 0)), 0)
expect_equal(length(take(numVectorRDD, 0)), 0)
})
+
+sparkR.session.stop()