aboutsummaryrefslogtreecommitdiff
path: root/R/pkg/inst/tests/testthat/test_broadcast.R
diff options
context:
space:
mode:
Diffstat (limited to 'R/pkg/inst/tests/testthat/test_broadcast.R')
-rw-r--r--R/pkg/inst/tests/testthat/test_broadcast.R4
1 files changed, 3 insertions, 1 deletions
diff --git a/R/pkg/inst/tests/testthat/test_broadcast.R b/R/pkg/inst/tests/testthat/test_broadcast.R
index cf1d432771..c7fefb5cf9 100644
--- a/R/pkg/inst/tests/testthat/test_broadcast.R
+++ b/R/pkg/inst/tests/testthat/test_broadcast.R
@@ -18,7 +18,7 @@
context("broadcast variables")
# JavaSparkContext handle
-sparkSession <- sparkR.session()
+sparkSession <- sparkR.session(enableHiveSupport = FALSE)
sc <- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "getJavaSparkContext", sparkSession)
# Partitioned data
@@ -47,3 +47,5 @@ test_that("without using broadcast variable", {
expected <- list(sum(randomMat) * 1, sum(randomMat) * 2)
expect_equal(actual, expected)
})
+
+sparkR.session.stop()