2017-05-29 4 views
0

flumeを使用してHDFSにcsvファイルをインポートしようとしています。 しかし、私は "行の長さが最大2048を超えています"という警告と行が切り捨てられています。 誰でもこの問題の解決方法を教えてください。 Flumeを使用してcsvをインポートする

はfile--

a1.sources = s 
a1.channels = c 
a1.sinks = sk 

a1.sources.s.type = spooldir 
a1.sources.s.spoolDir = /home/itelligence/Desktop/Project 2 

a1.channels.c.type = file 

a1.sinks.sk.type = hdfs 
a1.sinks.sk.hdfs.path = /project 2 
a1.sinks.sk.hdfs.fileType = DataStream 

a1.sources.s.channels = c 
a1.sinks.sk.channel = c 

は、ソースファイルに次の行を追加します。事前

答えて

0

でいただきありがとうございます私の源である

a1.sources.s.deserializer.maxLineLength = <MAXIMUM_LINE_LENGTH> 
関連する問題