Skip to content

Commit 640ffca

Browse files
committed
fix bug
1 parent 98e7ab9 commit 640ffca

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ markUtf8 <- function(s) {
3333
}
3434

3535
setHiveContext <- function() {
36+
ssc <- callJMethod(sc, "sc")
3637
hiveCtx <- tryCatch({
3738
newJObject("org.apache.spark.sql.hive.test.TestHiveContext", ssc)
3839
},
@@ -177,7 +178,6 @@ test_that("create DataFrame from RDD", {
177178
expect_equal(as.list(collect(where(df, df$name == "John"))),
178179
list(name = "John", age = 19L, height = 176.5))
179180

180-
ssc <- callJMethod(sc, "sc")
181181
setHiveContext()
182182
sql("CREATE TABLE people (name string, age double, height float)")
183183
df <- read.df(jsonPathNa, "json", schema)

0 commit comments

Comments
 (0)