Skip to content

Commit 20f9498

Browse files
committed
add test
1 parent c20916a commit 20f9498

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

R/pkg/tests/fulltests/test_context.R

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -240,3 +240,10 @@ test_that("add and get file to be downloaded with Spark job on every node", {
240240
unlink(path, recursive = TRUE)
241241
sparkR.session.stop()
242242
})
243+
244+
test_that("SPARK-25234: parallelize should not have integer overflow", {
245+
sc <- sparkR.sparkContext(master = sparkRTestMaster)
246+
# 47000 * 47000 exceeds integer range
247+
parallelize(sc, 1:47000, 47000)
248+
sparkR.session.stop()
249+
})

0 commit comments

Comments
 (0)