Support Questions
Find answers, ask questions, and share your expertise
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


flume kudu sink encoding




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: Invalid int encoding at at at at at org.apache.avro.generic.GenericDatumReader.readString( at org.apache.avro.generic.GenericDatumReader.readWithoutConversion( at at org.apache.avro.generic.GenericDatumReader.readField( at org.apache.avro.generic.GenericDatumReader.readRecord( at org.apache.avro.generic.GenericDatumReader.readWithoutConversion( at at at org.apache.kudu.flume.sink.AvroKuduOperationsProducer.getOperations(