Skip to content

Commit 9c768ae

Browse files
committed
improve exception handling that fixes the test too
1 parent 28195b9 commit 9c768ae

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

R/pkg/R/catalog.R

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ createExternalTable <- function(x, ...) {
8383
cacheTable.default <- function(tableName) {
8484
sparkSession <- getSparkSession()
8585
catalog <- callJMethod(sparkSession, "catalog")
86-
invisible(callJMethod(catalog, "cacheTable", tableName))
86+
invisible(handledCallJMethod(catalog, "cacheTable", tableName))
8787
}
8888

8989
cacheTable <- function(x, ...) {
@@ -112,7 +112,7 @@ cacheTable <- function(x, ...) {
112112
uncacheTable.default <- function(tableName) {
113113
sparkSession <- getSparkSession()
114114
catalog <- callJMethod(sparkSession, "catalog")
115-
invisible(callJMethod(catalog, "uncacheTable", tableName))
115+
invisible(handledCallJMethod(catalog, "uncacheTable", tableName))
116116
}
117117

118118
uncacheTable <- function(x, ...) {

0 commit comments

Comments
 (0)