org.apache.spark.SparkException: Error communicating with MapOutputTracker

Stack Overflow | Yu Shi | 5 months ago
  1. 0

    Fail to connect to master. ERROR SparkDeploySchedulerBackend: Application has been killed. Reason: All masters are unresponsive

    Stack Overflow | 5 months ago | Yu Shi
    org.apache.spark.SparkException: Error communicating with MapOutputTracker
  2. 0

    Is it necessary to submit spark application jar?

    Stack Overflow | 11 months ago | Marcin Lagowski
    org.apache.spark.SparkException: Error communicating with MapOutputTracker
  3. 0

    GitHub comment 572#246278541

    GitHub | 3 months ago | car2008
    org.apache.spark.SparkException: Error communicating with MapOutputTracker
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 38#195912077

    GitHub | 9 months ago | VincenzoFerme
    java.lang.InterruptedException
  6. 0

    Intellij connect hortonwork spark remotely failed

    Stack Overflow | 9 months ago | Decula
    java.lang.InterruptedException

  1. jk 1 times, last 9 months ago
2 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.lang.InterruptedException

    No message provided

    at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos()
  2. Java RT
    AbstractQueuedSynchronizer.tryAcquireSharedNanos
    1. java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1325)
    1 frame
  3. Scala
    Await$.result
    1. scala.concurrent.impl.Promise$DefaultPromise.tryAwait(Promise.scala:208)
    2. scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:218)
    3. scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
    4. scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190)
    5. scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
    6. scala.concurrent.Await$.result(package.scala:190)
    6 frames
  4. org.apache.spark
    RpcEndpointRef.askWithRetry
    1. org.apache.spark.rpc.RpcTimeout.awaitResult(RpcTimeout.scala:75)
    2. org.apache.spark.rpc.RpcEndpointRef.askWithRetry(RpcEndpointRef.scala:101)
    3. org.apache.spark.rpc.RpcEndpointRef.askWithRetry(RpcEndpointRef.scala:77)
    3 frames
  5. Spark
    AppClient$ClientEndpoint$$anon$2.run
    1. org.apache.spark.MapOutputTracker.askTracker(MapOutputTracker.scala:110)
    2. org.apache.spark.MapOutputTracker.sendTracker(MapOutputTracker.scala:120)
    3. org.apache.spark.MapOutputTrackerMaster.stop(MapOutputTracker.scala:462)
    4. org.apache.spark.SparkEnv.stop(SparkEnv.scala:93)
    5. org.apache.spark.SparkContext$$anonfun$stop$12.apply$mcV$sp(SparkContext.scala:1756)
    6. org.apache.spark.util.Utils$.tryLogNonFatalError(Utils.scala:1229)
    7. org.apache.spark.SparkContext.stop(SparkContext.scala:1755)
    8. org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend.dead(SparkDeploySchedulerBackend.scala:127)
    9. org.apache.spark.deploy.client.AppClient$ClientEndpoint.markDead(AppClient.scala:264)
    10. org.apache.spark.deploy.client.AppClient$ClientEndpoint$$anon$2$$anonfun$run$1.apply$mcV$sp(AppClient.scala:134)
    11. org.apache.spark.util.Utils$.tryOrExit(Utils.scala:1163)
    12. org.apache.spark.deploy.client.AppClient$ClientEndpoint$$anon$2.run(AppClient.scala:129)
    12 frames
  6. Java RT
    Thread.run
    1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    2. java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
    3. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
    4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    7. java.lang.Thread.run(Thread.java:745)
    7 frames