This is an automated email from the ASF dual-hosted git repository.
srowen pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 92e5216 Revert "[SPARK-28657][CORE] Fix currentContext Instance
failed sometimes"
92e5216 is described below
commit 92e5216ea0763e67d369547291e28b61ff5065fd
Author: Sean Owen <[email protected]>
AuthorDate: Mon Sep 9 18:44:38 2019 -0500
Revert "[SPARK-28657][CORE] Fix currentContext Instance failed sometimes"
This reverts commit df55f3cb120a5fd57aeec9ca3d67434e756e4b1c.
---
core/src/main/scala/org/apache/spark/util/Utils.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala
b/core/src/main/scala/org/apache/spark/util/Utils.scala
index e7d1613..8f86b47 100644
--- a/core/src/main/scala/org/apache/spark/util/Utils.scala
+++ b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -2946,8 +2946,7 @@ private[spark] class CallerContext(
if (CallerContext.callerContextSupported) {
try {
val callerContext =
Utils.classForName("org.apache.hadoop.ipc.CallerContext")
- val builder: Class[AnyRef] =
- Utils.classForName("org.apache.hadoop.ipc.CallerContext$Builder")
+ val builder =
Utils.classForName("org.apache.hadoop.ipc.CallerContext$Builder")
val builderInst =
builder.getConstructor(classOf[String]).newInstance(context)
val hdfsContext = builder.getMethod("build").invoke(builderInst)
callerContext.getMethod("setCurrent", callerContext).invoke(null,
hdfsContext)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
