In your morphline file which is reviews.conf.
change the order for { generateUUID { field : id } } move this down after readCSV
morphlines : [
{
id : dpi1
importCommands : ["org.kitesdk.**", "org.apache.solr.**"]
commands : [
{
readCSV {
separator : ","
columns : [msisdn,sgsn,local_ip,local_port,external_ip,external_port,translated_ip,translated_port,site,url,session_time,event_time,bytes]
quoteChar : "\""
charset : UTF-8
}
}
{ generateUUID { field : id } }
{
if {
conditions : [
{
equals { id : [] }
}
]
then : [
{
logDebug { format : "output record: {}", args : ["@{}"] }
}
]
}
}
