Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

flume kudu sink encoding

Highlighted

flume kudu sink encoding

Contributor

Hi,

 

I am testing flume kudu sink, and using org.apache.kudu.flume.sink.AvroKuduOperationsProducer, 

 

now i am getting this error, from googing appears an encoding issue, the default is utf-8, some suggests to use ISO-8859-1, i only see RegexpKuduOperationsProducer has an encoding setting/config, is there one for AvroKuduOperationsProducer?

 

Caused by: java.io.IOException: Invalid int encoding at org.apache.avro.io.BinaryDecoder.readInt(BinaryDecoder.java:145) at org.apache.avro.io.BinaryDecoder.readString(BinaryDecoder.java:259) at org.apache.avro.io.BinaryDecoder.readString(BinaryDecoder.java:272) at org.apache.avro.io.ResolvingDecoder.readString(ResolvingDecoder.java:214) at org.apache.avro.generic.GenericDatumReader.readString(GenericDatumReader.java:420) at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:180) at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:152) at org.apache.avro.generic.GenericDatumReader.readField(GenericDatumReader.java:240) at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:230) at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:174) at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:152) at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:144) at org.apache.kudu.flume.sink.AvroKuduOperationsProducer.getOperations(AvroKuduOperationsProducer.java:181)