Skip to content

Commit 4d0fb56

Browse files
committed
Merge pull request apache#203 from shivaram/sparkr-hive-fix
Fix HiveContext package name
2 parents d0d4626 + 62b0760 commit 4d0fb56

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

pkg/R/sparkR.R

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -247,15 +247,15 @@ sparkRSQL.init <- function(jsc) {
247247

248248
sparkRHive.init <- function(jsc) {
249249
if (exists(".sparkRHivesc", envir = .sparkREnv)) {
250-
cat("Re-using existing HiveContext. Please restart R to create a new HiveContext\n")
250+
cat("Re-using existing HiveContext. Please restart R to create a new HiveContext\n")
251251
return(get(".sparkRHivesc", envir = .sparkREnv))
252252
}
253253

254254
ssc <- callJMethod(jsc, "sc")
255255
hiveCtx <- tryCatch({
256-
newJObject("org.apache.spark.sql.HiveContext", ssc)
256+
newJObject("org.apache.spark.sql.hive.HiveContext", ssc)
257257
}, error = function(err) {
258-
stop("Hive is not build with SparkSQL")
258+
stop("Spark SQL is not built with Hive support")
259259
})
260260

261261
assign(".sparkRHivesc", hiveCtx, envir = .sparkREnv)

pkg/inst/tests/test_sparkSQL.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -297,7 +297,7 @@ test_that("save() as parquet file", {
297297

298298
test_that("test HiveContext", {
299299
hiveCtx <- tryCatch({
300-
newJObject("org.apache.spark.sql.TestHiveContext", ssc)
300+
newJObject("org.apache.spark.sql.hive.test.TestHiveContext", ssc)
301301
}, error = function(err) {
302302
skip("Hive is not build with SparkSQL, skipped")
303303
})

0 commit comments

Comments
 (0)