diff options
| author | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-08-31 16:56:41 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-08-31 16:56:41 -0700 |
| commit | 2f9c27364ea00473933213700edb93b63b55b313 (patch) | |
| tree | e5785235ccf6a33c7d996ab45d360b16ce8b145c /R/pkg/inst/tests | |
| parent | d375c8a3de1d253c485078f55eb9c5b928ab96d5 (diff) | |
| download | spark-2f9c27364ea00473933213700edb93b63b55b313.tar.gz spark-2f9c27364ea00473933213700edb93b63b55b313.tar.bz2 spark-2f9c27364ea00473933213700edb93b63b55b313.zip | |
[SPARK-16581][SPARKR] Fix JVM API tests in SparkR
## What changes were proposed in this pull request?
Remove cleanup.jobj test. Use JVM wrapper API for other test cases.
## How was this patch tested?
Run R unit tests with testthat 1.0
Author: Shivaram Venkataraman <shivaram@cs.berkeley.edu>
Closes #14904 from shivaram/sparkr-jvm-tests-fix.
Diffstat (limited to 'R/pkg/inst/tests')
| -rw-r--r-- | R/pkg/inst/tests/testthat/test_jvm_api.R | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/R/pkg/inst/tests/testthat/test_jvm_api.R b/R/pkg/inst/tests/testthat/test_jvm_api.R index 151c52906b..7348c893d0 100644 --- a/R/pkg/inst/tests/testthat/test_jvm_api.R +++ b/R/pkg/inst/tests/testthat/test_jvm_api.R @@ -20,24 +20,17 @@ context("JVM API") sparkSession <- sparkR.session(enableHiveSupport = FALSE) test_that("Create and call methods on object", { - jarr <- newJObject("java.util.ArrayList") + jarr <- sparkR.newJObject("java.util.ArrayList") # Add an element to the array - callJMethod(jarr, "add", 1L) + sparkR.callJMethod(jarr, "add", 1L) # Check if get returns the same element - expect_equal(callJMethod(jarr, "get", 0L), 1L) + expect_equal(sparkR.callJMethod(jarr, "get", 0L), 1L) }) test_that("Call static methods", { # Convert a boolean to a string - strTrue <- callJStatic("java.lang.String", "valueOf", TRUE) + strTrue <- sparkR.callJStatic("java.lang.String", "valueOf", TRUE) expect_equal(strTrue, "true") }) -test_that("Manually garbage collect objects", { - jarr <- newJObject("java.util.ArrayList") - cleanup.jobj(jarr) - # Using a jobj after GC should throw an error - expect_error(print(jarr), "Error in invokeJava.*") -}) - sparkR.session.stop() |