diff options
Diffstat (limited to 'R')
-rw-r--r-- | R/pkg/inst/tests/testthat/test_rdd.R | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/R/pkg/inst/tests/testthat/test_rdd.R b/R/pkg/inst/tests/testthat/test_rdd.R index b6c8e1dc6c..3b0c16be5a 100644 --- a/R/pkg/inst/tests/testthat/test_rdd.R +++ b/R/pkg/inst/tests/testthat/test_rdd.R @@ -791,11 +791,3 @@ test_that("sampleByKey() on pairwise RDDs", { expect_equal(lookup(sample, 3)[which.min(lookup(sample, 3))] >= 0, TRUE) expect_equal(lookup(sample, 3)[which.max(lookup(sample, 3))] <= 2000, TRUE) }) - -test_that("Test correct concurrency of RRDD.compute()", { - rdd <- parallelize(sc, 1:1000, 100) - jrdd <- getJRDD(lapply(rdd, function(x) { x }), "row") - zrdd <- callJMethod(jrdd, "zip", jrdd) - count <- callJMethod(zrdd, "count") - expect_equal(count, 1000) -}) |