We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fdb3822 commit d1508ddCopy full SHA for d1508dd
core/src/main/scala/org/apache/spark/SparkEnv.scala
@@ -256,7 +256,12 @@ object SparkEnv extends Logging {
256
if (rpcEnv.isInstanceOf[AkkaRpcEnv]) {
257
rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem
258
} else {
259
- val actorSystemPort = if (port == 0) 0 else rpcEnv.address.port + 1
+ val actorSystemPort =
260
+ if (port == 0 || rpcEnv.address == null) {
261
+ port
262
+ } else {
263
+ rpcEnv.address.port + 1
264
+ }
265
// Create a ActorSystem for legacy codes
266
AkkaUtils.createActorSystem(
267
actorSystemName + "ActorSystem",
0 commit comments