nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shawn Weeks <>
Subject Re: CSV Illegal Initial Character
Date Mon, 20 Aug 2018 14:05:36 GMT
That option is ignored if you're deriving the schema from the header. Since in the CSV standard
supports quoting everything then having the header quoted should be supported.



From: Mark Payne <>
Sent: Saturday, August 18, 2018 6:56 PM
Subject: Re: CSV Illegal Initial Character

Hey Shawn,

It sounds like you need to set the cvs reader’s “Treat First Line as Header” property
to true. By default it treats the first line as the first record (as opposed to the header),
which looks like the case here.

Sent from my iPhone

On Aug 18, 2018, at 1:30 PM, Shawn Weeks <<>>

I was building some example NiFi workflows from the CSV files at
specifically nile.csv and it appears that NiFi is trying to include the quoted header with
quotes in the Avro schema it generates. This is an all defaults CSVReader used with a JsonRecordSetWriter
in ConvertRecord. Wondering if this is a bug or expected behavior. I’m using the latest
1.7 binaries from<>.

org.apache.avro.SchemaParseException: Illegal initial character: "Flood"

              at org.apache.avro.Schema.validateName(

              at org.apache.avro.Schema.access$200(

              at org.apache.avro.Schema$Field.<init>(

              at org.apache.avro.Schema$Field.<init>(

              at org.apache.avro.Schema$Field.<init>(

              at org.apache.nifi.avro.AvroTypeUtil.buildAvroField(

              at org.apache.nifi.avro.AvroTypeUtil.buildAvroSchema(

              at org.apache.nifi.avro.AvroTypeUtil.extractAvroSchema(

              at org.apache.nifi.schema.access.WriteAvroSchemaAttributeStrategy.getAttributes(

              at org.apache.nifi.json.WriteJsonResult.writeRecord(

              at org.apache.nifi.serialization.AbstractRecordSetWriter.write(

              at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(

              at org.apache.nifi.controller.repository.StandardProcessSession.write(

              at org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(

              at org.apache.nifi.processor.AbstractProcessor.onTrigger(

              at org.apache.nifi.controller.StandardProcessorNode.onTrigger(

              at org.apache.nifi.controller.tasks.ConnectableTask.invoke(

              at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$

              at java.util.concurrent.Executors$

              at java.util.concurrent.FutureTask.runAndReset(

              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(

              at java.util.concurrent.ScheduledThreadPoolExecutor$

              at java.util.concurrent.ThreadPoolExecutor.runWorker(

              at java.util.concurrent.ThreadPoolExecutor$


View raw message