Reply
Highlighted
Explorer
Posts: 116
Registered: ‎09-14-2016

flume kudu sink encoding

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)

Announcements