This is an automated email from the ASF dual-hosted git repository.
srowen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 02fdefddcfa [CORE][MINOR] Correct spelling for RPC in log
02fdefddcfa is described below
commit 02fdefddcfa29aedc3b41548b61c4f8f0fd6c995
Author: Ted Yu <[email protected]>
AuthorDate: Sat Dec 24 08:38:43 2022 -0600
[CORE][MINOR] Correct spelling for RPC in log
### What changes were proposed in this pull request?
This PR corrects spelling mistake for `RPC` in log for `sendRpc`.
Similar error in context.R is also fixed.
### Why are the changes needed?
The spelling mistake confuses users.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Existing test suite
Closes #39200 from tedyu/trans-rpc.
Authored-by: Ted Yu <[email protected]>
Signed-off-by: Sean Owen <[email protected]>
---
R/pkg/R/context.R | 2 +-
.../src/main/java/org/apache/spark/network/client/TransportClient.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/R/pkg/R/context.R b/R/pkg/R/context.R
index cca6c2c817d..eea83aa5ab5 100644
--- a/R/pkg/R/context.R
+++ b/R/pkg/R/context.R
@@ -170,7 +170,7 @@ parallelize <- function(sc, coll, numSlices = 1) {
serializedSlices <- lapply(slices, serialize, connection = NULL)
# The RPC backend cannot handle arguments larger than 2GB (INT_MAX)
- # If serialized data is safely less than that threshold we send it over the
PRC channel.
+ # If serialized data is safely less than that threshold we send it over the
RPC channel.
# Otherwise, we write it to a file and send the file name
if (objectSize < sizeLimit) {
jrdd <- callJStatic("org.apache.spark.api.r.RRDD", "createRDDFromArray",
sc, serializedSlices)
diff --git
a/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java
b/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java
index dd2fdb08ee5..4a0a1566998 100644
---
a/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java
+++
b/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java
@@ -274,7 +274,7 @@ public class TransportClient implements Closeable {
copy.flip();
result.set(copy);
} catch (Throwable t) {
- logger.warn("Error in responding PRC callback", t);
+ logger.warn("Error in responding RPC callback", t);
result.setException(t);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
