java.nio.charset.MalformedInputException: Input length = 1 at java.nio.charset.CoderResult.throwException(CoderR esult.java:277) at org.apache.flume.serialization.ResettableFileInput Stream.readChar(ResettableFileInputStream.java:282 ) at org.apache.flume.serialization.LineDeserializer.re adLine(LineDeserializer.java:133) at org.apache.flume.serialization.LineDeserializer.re adEvent(LineDeserializer.java:71) at org.apache.flume.serialization.LineDeserializer.re adEvents(LineDeserializer.java:90) at org.apache.flume.client.avro.ReliableSpoolingFileE ventReader.readEvents(ReliableSpoolingFileEventRea der.java:252) at org.apache.flume.source.SpoolDirectorySource$Spool DirectoryRunnable.run(SpoolDirectorySource.java:22 8) at java.util.concurrent.Executors$RunnableAdapter.cal l(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(Future Task.java:304) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.access$301(ScheduledThreadPoolE xecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.run(ScheduledThreadPoolExecutor .java:293)

cloudera.com | 6 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    Flume spooldir writes smaller files - Cloudera Community

    cloudera.com | 6 months ago
    java.nio.charset.MalformedInputException: Input length = 1 at java.nio.charset.CoderResult.throwException(CoderR esult.java:277) at org.apache.flume.serialization.ResettableFileInput Stream.readChar(ResettableFileInputStream.java:282 ) at org.apache.flume.serialization.LineDeserializer.re adLine(LineDeserializer.java:133) at org.apache.flume.serialization.LineDeserializer.re adEvent(LineDeserializer.java:71) at org.apache.flume.serialization.LineDeserializer.re adEvents(LineDeserializer.java:90) at org.apache.flume.client.avro.ReliableSpoolingFileE ventReader.readEvents(ReliableSpoolingFileEventRea der.java:252) at org.apache.flume.source.SpoolDirectorySource$Spool DirectoryRunnable.run(SpoolDirectorySource.java:22 8) at java.util.concurrent.Executors$RunnableAdapter.cal l(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(Future Task.java:304) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.access$301(ScheduledThreadPoolE xecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.run(ScheduledThreadPoolExecutor .java:293)
  2. 0

    GitHub comment 58#87269892

    GitHub | 2 years ago | austindsouza
    java.nio.charset.MalformedInputException: Input length = 1 at > > java.nio.charset.CoderResult.throwException(CoderResult.java:277) at > > > org.apache.flume.serialization.ResettableInputStreamReader.readInternal(ResettableInputStreamReader.java:405) > > at > > > org.apache.flume.serialization.ResettableInputStreamReader.read(ResettableInputStreamReader.java:280) > > at > > > org.apache.flume.serialization.ResettableLineReader.readLine(ResettableLineReader.java:106) > > at > > > org.apache.flume.serialization.LineDeserializer.readEvent(LineDeserializer.java:93) > > at > > > org.apache.flume.serialization.LineDeserializer.readEvents(LineDeserializer.java:112) > > at > > > org.apache.flume.client.avro.ReliableSpoolingFileEventReader.readEvents(ReliableSpoolingFileEventReader.java:241) > > at > > > org.apache.flume.source.SpoolDirectorySource$SpoolDirectoryRunnable.run(SpoolDirectorySource.java:219) > > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) > > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)

    Root Cause Analysis

    1. java.nio.charset.MalformedInputException

      Input length = 1 at java.nio.charset.CoderResult.throwException(CoderR esult.java:277) at org.apache.flume.serialization.ResettableFileInput Stream.readChar(ResettableFileInputStream.java:282 ) at org.apache.flume.serialization.LineDeserializer.re adLine(LineDeserializer.java:133) at org.apache.flume.serialization.LineDeserializer.re adEvent(LineDeserializer.java:71) at org.apache.flume.serialization.LineDeserializer.re adEvents(LineDeserializer.java:90) at org.apache.flume.client.avro.ReliableSpoolingFileE ventReader.readEvents(ReliableSpoolingFileEventRea der.java:252) at org.apache.flume.source.SpoolDirectorySource$Spool DirectoryRunnable.run(SpoolDirectorySource.java:22 8) at java.util.concurrent.Executors$RunnableAdapter.cal l(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(Future Task.java:304) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.access$301(ScheduledThreadPoolE xecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.run(ScheduledThreadPoolExecutor .java:293)

      at java.util.concurrent.ThreadPoolExecutor.runWorker()
    2. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames