Flume spooldir 报错 MalformedInputException: Input length = 1

 使用Flume监控文件夹下,文件变更下入到HDFS

 上传了一本小说2M左右,出现报错 : 

java.nio.charset.MalformedInputException: Input length = 1

 

可能存在问题:

  原本以为是2M,在拷贝过程中,造成系统写,flume读的原因,

       那么文件拷贝完,在启动flume就应该不报错,实际启动Fuleme还报错,那么就排除可能

解决办法:

 在source端增加编码GBK, 默认为UTF8

 a1.sources.r1.inputCharset = GBK

原文地址:https://www.cnblogs.com/codelives/p/14044321.html