diff options
Diffstat (limited to 'R/pkg/inst/worker/worker.R')
| -rw-r--r-- | R/pkg/inst/worker/worker.R | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/R/pkg/inst/worker/worker.R b/R/pkg/inst/worker/worker.R index 014bf7bd7b..7e3b5fc403 100644 --- a/R/pkg/inst/worker/worker.R +++ b/R/pkg/inst/worker/worker.R @@ -72,7 +72,7 @@ if (numBroadcastVars > 0) { for (bcast in seq(1:numBroadcastVars)) { bcastId <- SparkR:::readInt(inputCon) value <- unserialize(SparkR:::readRaw(inputCon)) - setBroadcastValue(bcastId, value) + SparkR:::setBroadcastValue(bcastId, value) } } |