java.io.IOException: FileAlreadyExistException(message:/0)

JIRA | Calvin Jia | 1 year ago
  1. 0

    {code:java} java.io.IOException: FileAlreadyExistException(message:Block file is being written! userId(##) blockId(####)) at tachyon.worker.WorkerClient.requestBlockLocation(WorkerClient.java:378) at tachyon.client.TachyonFS.getLocalBlockTemporaryPath(TachyonFS.java:633) at tachyon.client.BlockOutStream.<init>(BlockOutStream.java:96) at tachyon.client.BlockOutStream.<init>(BlockOutStream.java:65) at tachyon.client.RemoteBlockInStream.<init>(RemoteBlockInStream.java:128) at tachyon.client.BlockInStream.get(BlockInStream.java:62) at tachyon.client.FileInStream.seek(FileInStream.java:157) at tachyon.hadoop.HdfsFileInputStream.seek(HdfsFileInputStream.java:244) at org.apache.hadoop.fs.FSDataInputStream.seek(FSDataInputStream.java:48) at org.apache.hadoop.mapred.LineRecordReader.<init>(LineRecordReader.java:103) at org.apache.hadoop.mapred.TextInputFormat.getRecordReader(TextInputFormat.java:54) at org.apache.spark.rdd.HadoopRDD$$anon$1.<init>(HadoopRDD.scala:236) at org.apache.spark.rdd.HadoopRDD.compute(HadoopRDD.scala:212) at org.apache.spark.rdd.HadoopRDD.compute(HadoopRDD.scala:101) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68) at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41) at org.apache.spark.scheduler.Task.run(Task.scala:64) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:203) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) {code}

    JIRA | 2 years ago | Calvin Jia
    java.io.IOException: FileAlreadyExistException(message:Block file is being written! userId(##) blockId(####))
  2. Speed up your debug routine!

    Automated exception search integrated into your IDE

  3. 0

    {code:java} java.io.IOException: FileAlreadyExistException(message:Block file is being written! userId(##) blockId(####)) at tachyon.worker.WorkerClient.requestBlockLocation(WorkerClient.java:378) at tachyon.client.TachyonFS.getLocalBlockTemporaryPath(TachyonFS.java:633) at tachyon.client.BlockOutStream.<init>(BlockOutStream.java:96) at tachyon.client.BlockOutStream.<init>(BlockOutStream.java:65) at tachyon.client.RemoteBlockInStream.<init>(RemoteBlockInStream.java:128) at tachyon.client.BlockInStream.get(BlockInStream.java:62) at tachyon.client.FileInStream.seek(FileInStream.java:157) at tachyon.hadoop.HdfsFileInputStream.seek(HdfsFileInputStream.java:244) at org.apache.hadoop.fs.FSDataInputStream.seek(FSDataInputStream.java:48) at org.apache.hadoop.mapred.LineRecordReader.<init>(LineRecordReader.java:103) at org.apache.hadoop.mapred.TextInputFormat.getRecordReader(TextInputFormat.java:54) at org.apache.spark.rdd.HadoopRDD$$anon$1.<init>(HadoopRDD.scala:236) at org.apache.spark.rdd.HadoopRDD.compute(HadoopRDD.scala:212) at org.apache.spark.rdd.HadoopRDD.compute(HadoopRDD.scala:101) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:277) at org.apache.spark.rdd.RDD.iterator(RDD.scala:244) at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68) at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41) at org.apache.spark.scheduler.Task.run(Task.scala:64) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:203) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) {code}

    JIRA | 2 years ago | Calvin Jia
    java.io.IOException: FileAlreadyExistException(message:Block file is being written! userId(##) blockId(####))
  4. 0

    Socket Error 804 | Teradata Developer Exchange

    teradata.com | 1 year ago
    java.io.IOException: Incomplete LAN message header: read 0 bytes

    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.io.IOException

      FileAlreadyExistException(message:/0)

      at tachyon.thrift.MasterService$user_createFile_result$user_createFile_resultStandardScheme.read()
    2. Tachyon Project Core
      MasterService$user_createFile_result.read
      1. tachyon.thrift.MasterService$user_createFile_result$user_createFile_resultStandardScheme.read(MasterService.java:19109)
      2. tachyon.thrift.MasterService$user_createFile_result$user_createFile_resultStandardScheme.read(MasterService.java:19087)
      3. tachyon.thrift.MasterService$user_createFile_result.read(MasterService.java:18999)
      3 frames
    3. Apache Thrift
      TServiceClient.receiveBase
      1. org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
      1 frame
    4. Tachyon Project Core
      MasterFaultToleranceIntegrationTest.getClientsTest
      1. tachyon.thrift.MasterService$Client.recv_user_createFile(MasterService.java:629)
      2. tachyon.thrift.MasterService$Client.user_createFile(MasterService.java:613)
      3. tachyon.master.MasterClient.user_createFile(MasterClient.java:482)
      4. tachyon.client.TachyonFS.createFile(TachyonFS.java:330)
      5. tachyon.client.AbstractTachyonFS.createFile(AbstractTachyonFS.java:61)
      6. tachyon.client.TachyonFS.createFile(TachyonFS.java:60)
      7. tachyon.master.MasterFaultToleranceIntegrationTest.getClientsTest(MasterFaultToleranceIntegrationTest.java:127)
      7 frames