java.net.SocketException: Connection reset

Stack Overflow | w.eric | 4 months ago
  1. 0

    Spark cartesian product

    Stack Overflow | 4 months ago | w.eric
    java.net.SocketException: Connection reset
  2. 0

    Spark job failing when calling first() in PySpark

    Stack Overflow | 2 years ago | strimp099
    java.net.SocketException: Connection reset
  3. 0

    Apache-Spark with Python Theano

    Stack Overflow | 1 year ago | Ruofan Kong
    java.net.SocketException: Connection reset
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    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.net.SocketException

      Connection reset

      at java.net.SocketInputStream.read()
    2. Java RT
      DataInputStream.readInt
      1. java.net.SocketInputStream.read(SocketInputStream.java:209)
      2. java.net.SocketInputStream.read(SocketInputStream.java:141)
      3. java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
      4. java.io.BufferedInputStream.read(BufferedInputStream.java:265)
      5. java.io.DataInputStream.readInt(DataInputStream.java:387)
      5 frames
    3. Spark
      Executor$TaskRunner.run
      1. org.apache.spark.api.python.PythonRunner$$anon$1.read(PythonRDD.scala:139)
      2. org.apache.spark.api.python.PythonRunner$$anon$1.<init>(PythonRDD.scala:207)
      3. org.apache.spark.api.python.PythonRunner.compute(PythonRDD.scala:125)
      4. org.apache.spark.api.python.PythonRDD.compute(PythonRDD.scala:70)
      5. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)
      6. org.apache.spark.rdd.RDD.iterator(RDD.scala:270)
      7. org.apache.spark.api.python.PairwiseRDD.compute(PythonRDD.scala:342)
      8. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)
      9. org.apache.spark.rdd.RDD.iterator(RDD.scala:270)
      10. org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)
      11. org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
      12. org.apache.spark.scheduler.Task.run(Task.scala:89)
      13. org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:213)
      13 frames
    4. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames