java.net.SocketException: Connection reset

Stack Overflow | Taha Khan | 2 months ago
  1. 0

    toPandas() work from Jupyter iPython Notebook but fails on submit - AWS EMR

    Stack Overflow | 2 months ago | Taha Khan
    java.net.SocketException: Connection reset
  2. 0

    Join two dataframe - Timeout after 5 minutes

    apache.org | 1 year ago
    java.net.SocketException: Broken pipe
  3. 0

    pyspark is crashing in this case. why?

    spark-user | 2 years ago | genesis fatum
    java.net.SocketException: Connection reset by peer: socket write error
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    pyspark is crashing in this case. why?

    spark-user | 2 years ago | genesis fatum
    java.net.SocketException: Connection reset by peer: socket write error
  6. 0

    pyspark is crashing in this case. why?

    spark-user | 2 years ago | genesis fatum
    java.net.SocketException: Connection reset by peer: socket write error

    6 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.SocketOutputStream.socketWrite()
    2. Java RT
      FilterOutputStream.write
      1. java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:118)
      2. java.net.SocketOutputStream.write(SocketOutputStream.java:159)
      3. java.io.BufferedOutputStream.write(BufferedOutputStream.java:122)
      4. java.io.DataOutputStream.write(DataOutputStream.java:107)
      5. java.io.FilterOutputStream.write(FilterOutputStream.java:97)
      5 frames
    3. Spark
      PythonRDD$$anonfun$writeIteratorToStream$1.apply
      1. org.apache.spark.api.python.PythonRDD$.org$apache$spark$api$python$PythonRDD$$write$1(PythonRDD.scala:440)
      2. org.apache.spark.api.python.PythonRDD$$anonfun$writeIteratorToStream$1.apply(PythonRDD.scala:452)
      3. org.apache.spark.api.python.PythonRDD$$anonfun$writeIteratorToStream$1.apply(PythonRDD.scala:452)
      3 frames
    4. Scala
      AbstractIterator.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:727)
      2. scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
      2 frames
    5. Spark
      PythonRDD$$anon$2.run
      1. org.apache.spark.api.python.PythonRDD$.writeIteratorToStream(PythonRDD.scala:452)
      2. org.apache.spark.api.python.PythonRDD$$anon$2$$anonfun$run$1.apply$mcV$sp(PythonRDD.scala:648)
      3. org.apache.spark.api.python.PythonRDD$$anon$2$$anonfun$run$1.apply(PythonRDD.scala:648)
      4. org.apache.spark.api.python.PythonRDD$$anon$2$$anonfun$run$1.apply(PythonRDD.scala:648)
      5. org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1250)
      6. org.apache.spark.api.python.PythonRDD$$anon$2.run(PythonRDD.scala:649)
      6 frames