Skip to content

Commit f53b148

Browse files
committed
fix hive context test failure more
1 parent 153d5e7 commit f53b148

File tree

3 files changed

+4
-69
lines changed

3 files changed

+4
-69
lines changed

R/pkg/R/SQLContext.R

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -752,6 +752,7 @@ createExternalTable <- function(x, ...) {
752752
#' df2 <- read.jdbc(jdbcUrl, "table2", partitionColumn = "index", lowerBound = 0,
753753
#' upperBound = 10000, user = "username", password = "password")
754754
#' }
755+
#' @note since 2.0.0
755756

756757
read.jdbc <- function(url, tableName,
757758
partitionColumn = NULL, lowerBound = NULL, upperBound = NULL,

R/pkg/inst/tests/test_mllib.R

Lines changed: 0 additions & 69 deletions
This file was deleted.

R/pkg/inst/tests/testthat/test_sparkSQL.R

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -177,6 +177,7 @@ test_that("create DataFrame from RDD", {
177177
c(16))
178178
expect_equal(collect(sql("SELECT height from people WHERE name ='Bob'"))$height,
179179
c(176.5))
180+
remove(".sparkRHivesc", envir = .sparkREnv)
180181
})
181182

182183
test_that("convert NAs to null type in DataFrames", {
@@ -988,6 +989,7 @@ test_that("test HiveContext", {
988989
expect_is(df5, "SparkDataFrame")
989990
expect_equal(count(df5), 3)
990991
unlink(parquetDataPath)
992+
remove(".sparkRHivesc", envir = .sparkREnv)
991993
})
992994

993995
test_that("column operators", {
@@ -2168,6 +2170,7 @@ test_that("Window functions on a DataFrame", {
21682170
result <- collect(select(df, over(lead("key", 1), ws), over(lead("value", 1), ws)))
21692171
names(result) <- c("key", "value")
21702172
expect_equal(result, expected)
2173+
remove(".sparkRHivesc", envir = .sparkREnv)
21712174
})
21722175

21732176
test_that("createDataFrame sqlContext parameter backward compatibility", {

0 commit comments

Comments
 (0)