ExecuteSQL erroring out

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

ExecuteSQL erroring out

Karthik Kothareddy (karthikk) [CONT - Type 2]

Hello All,

 

I am using NiFi 1.2.0 with some customizations. I was trying to query a Teradata table using ExecuteSQL processor and it is giving me the below error, I am querying from a view that casts the VARCHAR columns into double. This Error doesn’t seem to occur when queried directly without casting that column. Any help around this would be much appreciated.

 

 

2017-06-15 14:05:44,585 ERROR [Timer-Driven Process Thread-7] o.a.nifi.processors.standard.ExecuteSQL ExecuteSQL[id=015c1027-b41a-1e3d-6bf3-1f879545559c] ExecuteSQL[id=015c1027-b41a-1e3d-6bf3-1f879545559c] failed to process due to org.apache.avro.file.DataFileWriter$AppendWriteException: org.apache.avro.UnresolvedUnionException: Not in union ["null","float"]: 6.0; rolling back session: {}

org.apache.avro.file.DataFileWriter$AppendWriteException: org.apache.avro.UnresolvedUnionException: Not in union ["null","float"]: 6.0

        at org.apache.avro.file.DataFileWriter.append(DataFileWriter.java:308)

        at org.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream(JdbcCommon.java:219)

        at org.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream(JdbcCommon.java:88)

        at org.apache.nifi.processors.standard.util.JdbcCommon.convertToAvroStream(JdbcCommon.java:78)

        at org.apache.nifi.processors.standard.ExecuteSQL$2.process(ExecuteSQL.java:205)

        at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2377)

        at org.apache.nifi.processors.standard.ExecuteSQL.onTrigger(ExecuteSQL.java:199)

        at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)

        at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1118)

        at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:144)

        at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)

        at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)

        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)

        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)

        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)

        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

        at java.lang.Thread.run(Thread.java:745)

Caused by: org.apache.avro.UnresolvedUnionException: Not in union ["null","float"]: 6.0

        at org.apache.avro.generic.GenericData.resolveUnion(GenericData.java:709)

        at org.apache.avro.generic.GenericDatumWriter.resolveUnion(GenericDatumWriter.java:192)

        at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:110)

        at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:73)

        at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:153)

        at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:143)

        at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:105)

        at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:73)

        at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:60)

        at org.apache.avro.file.DataFileWriter.append(DataFileWriter.java:302)

        ... 18 common frames omitted

 

 

 

 

Thanks

Karthik

Loading...