java.net.SocketException: Connection reset by peer: socket write error

Stack Overflow | suvojyotic | 4 months ago
  1. 0

    Pyspark socket write error

    Stack Overflow | 7 months ago | codemania
    java.net.SocketException: Connection reset by peer: socket write error
  2. 0

    pyspark failing to create dataframe with 1000000+ rows

    Stack Overflow | 4 months ago | suvojyotic
    java.net.SocketException: Connection reset by peer: socket write error
  3. 0

    IndexError: list index out of range Error while writing to parquet or csv file

    Stack Overflow | 4 months ago | ML_Passion
    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

    Spark cartesian product

    Stack Overflow | 4 months ago | w.eric
    java.net.SocketException: Daten?bergabe unterbrochen (broken pipe)
  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 by peer: socket write error

      at java.net.SocketOutputStream.socketWrite0()
    2. Java RT
      FilterOutputStream.write
      1. java.net.SocketOutputStream.socketWrite0(Native Method)
      2. java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109)
      3. java.net.SocketOutputStream.write(SocketOutputStream.java:153)
      4. java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
      5. java.io.BufferedOutputStream.write(BufferedOutputStream.java:126)
      6. java.io.DataOutputStream.write(DataOutputStream.java:107)
      7. java.io.FilterOutputStream.write(FilterOutputStream.java:97)
      7 frames
    3. Spark
      PythonRDD$$anonfun$writeIteratorToStream$1.apply
      1. org.apache.spark.api.python.PythonRDD$.writeUTF(PythonRDD.scala:622)
      2. org.apache.spark.api.python.PythonRDD$.org$apache$spark$api$python$PythonRDD$$write$1(PythonRDD.scala:442)
      3. org.apache.spark.api.python.PythonRDD$$anonfun$writeIteratorToStream$1.apply(PythonRDD.scala:452)
      4. org.apache.spark.api.python.PythonRDD$$anonfun$writeIteratorToStream$1.apply(PythonRDD.scala:452)
      4 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
      PythonRunner$WriterThread.run
      1. org.apache.spark.api.python.PythonRDD$.writeIteratorToStream(PythonRDD.scala:452)
      2. org.apache.spark.api.python.PythonRunner$WriterThread$$anonfun$run$3.apply(PythonRDD.scala:280)
      3. org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1765)
      4. org.apache.spark.api.python.PythonRunner$WriterThread.run(PythonRDD.scala:239)
      4 frames