java.io.IOException: write beyond end of stream

flume-user | Shady Xu | 1 year ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    write beyond end of stream

    flume-user | 1 year ago | Shady Xu
    java.io.IOException: write beyond end of stream

    Root Cause Analysis

    1. java.io.IOException

      write beyond end of stream

      at com.hadoop.compression.lzo.LzopOutputStream.write()
    2. com.hadoop.compression
      LzopOutputStream.write
      1. com.hadoop.compression.lzo.LzopOutputStream.write(LzopOutputStream.java:134)
      1 frame
    3. Java RT
      OutputStream.write
      1. java.io.OutputStream.write(OutputStream.java:75)
      1 frame
    4. Flume
      BodyTextEventSerializer.write
      1. org.apache.flume.serialization.BodyTextEventSerializer.write(BodyTextEventSerializer.java:71)
      1 frame
    5. org.apache.flume
      BucketWriter$9.call
      1. org.apache.flume.sink.hdfs.HDFSCompressedDataStream.append(HDFSCompressedDataStream.java:126)
      2. org.apache.flume.sink.hdfs.BucketWriter$7.call(BucketWriter.java:550)
      3. org.apache.flume.sink.hdfs.BucketWriter$7.call(BucketWriter.java:547)
      4. org.apache.flume.sink.hdfs.BucketWriter$9$1.run(BucketWriter.java:679)
      5. org.apache.flume.auth.SimpleAuthenticator.execute(SimpleAuthenticator.java:50)
      6. org.apache.flume.sink.hdfs.BucketWriter$9.call(BucketWriter.java:676)
      6 frames
    6. Java RT
      Thread.run
      1. java.util.concurrent.FutureTask.run(FutureTask.java:262)
      2. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      3. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      4. java.lang.Thread.run(Thread.java:724)
      4 frames