Hi all, Please share if anyone have faced the same problem. There are many similar issues on web but I did not find any solution and reason why this happens. It will be really helpful. Regards, Prateek
On Mon, Apr 29, 2019 at 3:18 PM Prateek Rajput <prateek.raj...@flipkart.com> wrote: > I checked and removed 0 sized files then also it is coming. And sometimes > when there is no 0 size file then also it is happening. > I checked data also if it is corrupted by directly opening that file and > checking it. I traced whole data but did not find any issue. For hadoop > Map-Reduce no such issue is coming it is happening in case of spark only. > > On Mon, Apr 29, 2019 at 2:50 PM Deepak Sharma <deepakmc...@gmail.com> > wrote: > >> This can happen if the file size is 0 >> >> On Mon, Apr 29, 2019 at 2:28 PM Prateek Rajput >> <prateek.raj...@flipkart.com.invalid> wrote: >> >>> Hi guys, >>> I am getting this strange error again and again while reading from from >>> a sequence file in spark. >>> User class threw exception: org.apache.spark.SparkException: Job aborted. >>> at >>> org.apache.spark.internal.io.SparkHadoopWriter$.write(SparkHadoopWriter.scala:100) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopDataset$1.apply$mcV$sp(PairRDDFunctions.scala:1096) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopDataset$1.apply(PairRDDFunctions.scala:1094) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopDataset$1.apply(PairRDDFunctions.scala:1094) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112) >>> at org.apache.spark.rdd.RDD.withScope(RDD.scala:363) >>> at >>> org.apache.spark.rdd.PairRDDFunctions.saveAsHadoopDataset(PairRDDFunctions.scala:1094) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$4.apply$mcV$sp(PairRDDFunctions.scala:1067) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$4.apply(PairRDDFunctions.scala:1032) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$4.apply(PairRDDFunctions.scala:1032) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112) >>> at org.apache.spark.rdd.RDD.withScope(RDD.scala:363) >>> at >>> org.apache.spark.rdd.PairRDDFunctions.saveAsHadoopFile(PairRDDFunctions.scala:1032) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$1.apply$mcV$sp(PairRDDFunctions.scala:958) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$1.apply(PairRDDFunctions.scala:958) >>> at >>> org.apache.spark.rdd.PairRDDFunctions$$anonfun$saveAsHadoopFile$1.apply(PairRDDFunctions.scala:958) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112) >>> at org.apache.spark.rdd.RDD.withScope(RDD.scala:363) >>> at >>> org.apache.spark.rdd.PairRDDFunctions.saveAsHadoopFile(PairRDDFunctions.scala:957) >>> at >>> org.apache.spark.rdd.RDD$$anonfun$saveAsTextFile$1.apply$mcV$sp(RDD.scala:1499) >>> at >>> org.apache.spark.rdd.RDD$$anonfun$saveAsTextFile$1.apply(RDD.scala:1478) >>> at >>> org.apache.spark.rdd.RDD$$anonfun$saveAsTextFile$1.apply(RDD.scala:1478) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151) >>> at >>> org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112) >>> at org.apache.spark.rdd.RDD.withScope(RDD.scala:363) >>> at org.apache.spark.rdd.RDD.saveAsTextFile(RDD.scala:1478) >>> at >>> org.apache.spark.api.java.JavaRDDLike$class.saveAsTextFile(JavaRDDLike.scala:550) >>> at >>> org.apache.spark.api.java.AbstractJavaRDDLike.saveAsTextFile(JavaRDDLike.scala:45) >>> at >>> com.flipkart.prognos.spark.UniqueDroppedFSN.main(UniqueDroppedFSN.java:42) >>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>> at >>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) >>> at >>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>> at java.lang.reflect.Method.invoke(Method.java:498) >>> at >>> org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:678) >>> Caused by: org.apache.spark.SparkException: Job aborted due to stage >>> failure: Task 186 in stage 0.0 failed 4 times, most recent failure: Lost >>> task 186.3 in stage 0.0 (TID 179, prod-fdphadoop-krios-dn-1039, executor >>> 1): java.io.EOFException >>> at java.io.DataInputStream.readFully(DataInputStream.java:197) >>> at >>> org.apache.hadoop.io.DataOutputBuffer$Buffer.write(DataOutputBuffer.java:70) >>> at org.apache.hadoop.io.DataOutputBuffer.write(DataOutputBuffer.java:120) >>> at org.apache.hadoop.io.SequenceFile$Reader.next(SequenceFile.java:2436) >>> at org.apache.hadoop.io.SequenceFile$Reader.next(SequenceFile.java:2568) >>> at >>> org.apache.hadoop.mapred.SequenceFileRecordReader.next(SequenceFileRecordReader.java:82) >>> at org.apache.spark.rdd.HadoopRDD$$anon$1.getNext(HadoopRDD.scala:293) >>> at org.apache.spark.rdd.HadoopRDD$$anon$1.getNext(HadoopRDD.scala:224) >>> at org.apache.spark.util.NextIterator.hasNext(NextIterator.scala:73) >>> at >>> org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:37) >>> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:409) >>> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:409) >>> at >>> org.apache.spark.util.collection.ExternalSorter.insertAll(ExternalSorter.scala:191) >>> at >>> org.apache.spark.shuffle.sort.SortShuffleWriter.write(SortShuffleWriter.scala:62) >>> at >>> org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99) >>> at >>> org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:55) >>> at org.apache.spark.scheduler.Task.run(Task.scala:121) >>> at >>> org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:402) >>> at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360) >>> at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:408) >>> at >>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >>> at >>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >>> at java.lang.Thread.run(Thread.java:745) >>> Driver stacktrace: >>> at org.apache.spark.scheduler.DAGScheduler.org >>> $apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1887) >>> at >>> org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1875) >>> at >>> org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1874) >>> at >>> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) >>> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) >>> at >>> org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1874) >>> at >>> org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:926) >>> at >>> org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:926) >>> at scala.Option.foreach(Option.scala:257) >>> at >>> org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:926) >>> at >>> org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:2108) >>> at >>> org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2057) >>> at >>> org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2046) >>> at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:49) >>> at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:737) >>> at org.apache.spark.SparkContext.runJob(SparkContext.scala:2061) >>> at org.apache.spark.SparkContext.runJob(SparkContext.scala:2082) >>> at org.apache.spark.SparkContext.runJob(SparkContext.scala:2114) >>> at >>> org.apache.spark.internal.io.SparkHadoopWriter$.write(SparkHadoopWriter.scala:78) >>> ... 36 more >>> Caused by: java.io.EOFException >>> at java.io.DataInputStream.readFully(DataInputStream.java:197) >>> at >>> org.apache.hadoop.io.DataOutputBuffer$Buffer.write(DataOutputBuffer.java:70) >>> at org.apache.hadoop.io.DataOutputBuffer.write(DataOutputBuffer.java:120) >>> at org.apache.hadoop.io.SequenceFile$Reader.next(SequenceFile.java:2436) >>> at org.apache.hadoop.io.SequenceFile$Reader.next(SequenceFile.java:2568) >>> at >>> org.apache.hadoop.mapred.SequenceFileRecordReader.next(SequenceFileRecordReader.java:82) >>> at org.apache.spark.rdd.HadoopRDD$$anon$1.getNext(HadoopRDD.scala:293) >>> at org.apache.spark.rdd.HadoopRDD$$anon$1.getNext(HadoopRDD.scala:224) >>> at org.apache.spark.util.NextIterator.hasNext(NextIterator.scala:73) >>> at >>> org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:37) >>> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:409) >>> at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:409) >>> at >>> org.apache.spark.util.collection.ExternalSorter.insertAll(ExternalSorter.scala:191) >>> at >>> org.apache.spark.shuffle.sort.SortShuffleWriter.write(SortShuffleWriter.scala:62) >>> at >>> org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99) >>> at >>> org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:55) >>> at org.apache.spark.scheduler.Task.run(Task.scala:121) >>> at >>> org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:402) >>> at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360) >>> at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:408) >>> at >>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >>> at >>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >>> at java.lang.Thread.run(Thread.java:745) >>> >>> My code block is - >>> >>> JavaRDD<Tuple2<String, String>> distinctFSN = sc.sequenceFile(inputFile, >>> Text.class, Text.class) >>> .map(x -> new Tuple2<>(x._1.toString(), x._2.toString())).distinct(); >>> >>> JavaRDD<String> orderEventsFSN = distinctFSN >>> .filter(x -> x._1().equals(ORDER_EVENTS)) >>> .map(Tuple2::_2); >>> >>> JavaRDD<String> ravenEventsFSN = distinctFSN >>> .filter(x -> x._1().equals(RAVEN_EVENTS)) >>> .map(Tuple2::_2); >>> orderEventsFSN.coalesce(1).saveAsTextFile(outputDir + DIRECTORY_SEPARATOR + >>> ORDER_EVENTS); >>> ravenEventsFSN.coalesce(1).saveAsTextFile(outputDir + DIRECTORY_SEPARATOR + >>> RAVEN_EVENTS); >>> >>> Please help with this issue, if someone have also faced it. >>> >>> SPARK-JAVA VERSION - 2.4.0 >>> JDK VERSION - 1.8 >>> SPARK ARTIFACTID - spark-core_2.11 >>> >>> Regards, >>> Prateek >>> >>> >> >> -- >> Thanks >> Deepak >> www.bigdatabig.com >> www.keosha.net >> >
