BEAM - java .lang.RuntimeException: не удалось прочитать данные - PullRequest
Новая
       86

BEAM - java .lang.RuntimeException: не удалось прочитать данные

1 голос
/ 06 августа 2020
• 1000 * 
[2020-08-05T05:12:36.410Z] java.lang.RuntimeException: Failed to read data.
[2020-08-05T05:12:36.410Z]  at org.apache.beam.runners.spark.io.SourceRDD$Bounded$ReaderToIteratorAdapter.tryProduceNext(SourceRDD.java:197)
[2020-08-05T05:12:36.410Z]  at org.apache.beam.runners.spark.io.SourceRDD$Bounded$ReaderToIteratorAdapter.hasNext(SourceRDD.java:238)
[2020-08-05T05:12:36.410Z]  at scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42)


[2020-08-05T05:12:36.410Z] Caused by: java.net.SocketException: Connection reset
[2020-08-05T05:12:36.410Z]  at java.net.SocketInputStream.read(SocketInputStream.java:210)
[2020-08-05T05:12:36.410Z]  at java.net.SocketInputStream.read(SocketInputStream.java:141)
...