Skip to content

Commit a33dbea

Browse files
committed
Merge branch 'master' of https://github.com/hqzizania/SparkR-pkg into hqzizania-master
Conflicts: pkg/R/RDD.R
2 parents 384e6e2 + 9c391c7 commit a33dbea

File tree

3 files changed

+5
-9
lines changed

3 files changed

+5
-9
lines changed

pkg/R/RDD.R

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -110,12 +110,10 @@ setMethod("getJRDD", signature(rdd = "PipelinedRDD"),
110110
computeFunc <- function(split, part) {
111111
rdd@func(split, part)
112112
}
113-
serializedFuncArr <- serialize("computeFunc", connection = NULL,
114-
ascii = TRUE)
113+
serializedFuncArr <- serialize("computeFunc", connection = NULL)
115114

116115
packageNamesArr <- serialize(.sparkREnv[[".packages"]],
117-
connection = NULL,
118-
ascii = TRUE)
116+
connection = NULL)
119117

120118
broadcastArr <- lapply(ls(.broadcastNames),
121119
function(name) { get(name, .broadcastNames) })

pkg/R/context.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ includePackage <- function(sc, pkg) {
179179
#'}
180180
broadcast <- function(sc, object) {
181181
objName <- as.character(substitute(object))
182-
serializedObj <- serialize(object, connection = NULL, ascii = TRUE)
182+
serializedObj <- serialize(object, connection = NULL)
183183

184184
jBroadcast <- callJMethod(sc, "broadcast", serializedObj)
185185
id <- as.character(callJMethod(jBroadcast, "id"))

pkg/R/pairRDD.R

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -212,12 +212,10 @@ setMethod("partitionBy",
212212
depsBinArr <- getDependencies(partitionFunc)
213213

214214
serializedHashFuncBytes <- serialize(as.character(substitute(partitionFunc)),
215-
connection = NULL,
216-
ascii = TRUE)
215+
connection = NULL)
217216

218217
packageNamesArr <- serialize(.sparkREnv$.packages,
219-
connection = NULL,
220-
ascii = TRUE)
218+
connection = NULL)
221219
broadcastArr <- lapply(ls(.broadcastNames), function(name) {
222220
get(name, .broadcastNames) })
223221
jrdd <- getJRDD(rdd)

0 commit comments

Comments
 (0)