Hi I have fixed this. It turns out that it was a Denodo issue. It was reporting the wrong datatypes.
Thanks Trevor -----Original Message----- From: Trevor Dunn <[email protected]> Sent: Wednesday, May 6, 2020 1:41 PM To: [email protected] Subject: RE: ExecuteSQL Unable to resolve union for value [CAUTION] EXTERNAL EMAIL .. Hi Matt. The source database is Denodo Data Virtualization Platform, and the table is quite simple Just 9 attributes with some varchar and ints I have included the full stack trace which has the table attributes in it. (I have sanitized the values for privacy purposes) Unable to execute SQL select query SELECT * FROM basin_countries WHERE 1=1 LIMIT 10000 for StandardFlowFileRecord[uuid=59125dfc-ee24-4d8b-b7b9-8d9dc89d5c94,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1588784291500-2, container=default, section=2], offset=195695, length=51],offset=0,name=59125dfc-ee24-4d8b-b7b9-8d9dc89d5c94,size=51] due to org.apache.nifi.processor.exception.ProcessException: java.lang.RuntimeException: Unable to resolve union for value 1 with type java.lang.Integer while appending record {"rank_ind": 1, "basin_name": "The Big Basin", "genetic_unit_name": null, "country_name": "Canada", "region_name": "North America", "country_id": 7090, "gp_id": 680000, "region_id": 2, "alternate_basin_name": "The Basin"}; routing to failure: org.apache.nifi.processor.exception.ProcessException: java.lang.RuntimeException: Unable to resolve union for value 1 with type java.lang.Integer while appending {"rank_ind": 1, "basin_name": "The Big Basin", "genetic_unit_name": null, "country_name": "Canada", "region_name": "North America", "country_id": 7090, "gp_id": 680000, "region_id": 2, "alternate_basin_name": "The Basin"} org.apache.nifi.processor.exception.ProcessException: java.lang.RuntimeException: Unable to resolve union for value 1 with type java.lang.Integer while appending record {"rank_ind": 1, "basin_name": "The Big Basin", "genetic_unit_name": null, "country_name": "Canada", "region_name": "North America", "country_id": 7090, "gp_id": 680000, "region_id": 2, "alternate_basin_name": "The Basin"} at org.apache.nifi.processors.standard.AbstractExecuteSQL.lambda$onTrigger$1(AbstractExecuteSQL.java:301) at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2746) at org.apache.nifi.processors.standard.AbstractExecuteSQL.onTrigger(AbstractExecuteSQL.java:297) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1176) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:213) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) 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:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) -----Original Message----- From: Matt Burgess <[email protected]> Sent: Wednesday, May 6, 2020 12:19 PM To: [email protected] Subject: Re: ExecuteSQL Unable to resolve union for value [CAUTION] EXTERNAL EMAIL .. Trevor, What does your table look like and what DB are you using? On Wed, May 6, 2020 at 1:26 PM Trevor Dunn <[email protected]> wrote: > > Hi I am using ExecuteSQL processor downstream of GenerateTableFetch to pull > data from a table. However when I run the flow I get error below. I > tried a couple of different tables and it is always fails with the same on > integer column. > > I have executed the SQL directly against the source and the SQL works fine. > > > > I am hoping someone can help me. I am using NiFi 1.11.4 > > > > Error: > > Unable to execute SQL select query SELECT * FROM basin_countries WHERE 1=1 > LIMIT 10000 for > StandardFlowFileRecord[uuid=6887eade-45a7-45da-b19f-47465b895885,claim=StandardContentClaim > [resourceClaim=StandardResourceClaim[id=1588733601463-1, container=default, > section=1], offset=20643, > length=51],offset=0,name=81c3e41a-88c4-4e4c-a3fb-4603fbd176aa,size=51] due to > java.lang.RuntimeException: Unable to resolve union for value 1 with type > java.lang.Integer while appending record > > > > Thanks > > Trevor > > > ________________________________ > > This e-mail, including accompanying communications and attachments, is > strictly confidential and only for the intended recipient. Any retention, use > or disclosure not expressly authorised by IHSMarkit is prohibited. This email > is subject to all waivers and other terms at the following link: > https://nam04.safelinks.protection.outlook.com/?url=https%3A%2F%2Fihsmarkit.com%2FLegal%2FEmailDisclaimer.html&data=02%7C01%7CTrevor.Dunn%40ihsmarkit.com%7C0d15736985c940b5b21e08d7f1f578d4%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C0%7C637243908906785687&sdata=5oFK4TiE%2FIHDb1MVfY82mNbDsO5gZu3KB%2Bg4Azi2NpA%3D&reserved=0 > > Please visit > https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.ihsmarkit.com%2Fabout%2Fcontact-us.html&data=02%7C01%7CTrevor.Dunn%40ihsmarkit.com%7C0d15736985c940b5b21e08d7f1f578d4%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C0%7C637243908906785687&sdata=gHyqxRUB2CsCKnvCk2H3%2Bey%2FV0OGM3tkNjM5tjKFOfc%3D&reserved=0 > for contact information on our offices worldwide. ________________________________ This e-mail, including accompanying communications and attachments, is strictly confidential and only for the intended recipient. Any retention, use or disclosure not expressly authorised by IHSMarkit is prohibited. This email is subject to all waivers and other terms at the following link: https://nam04.safelinks.protection.outlook.com/?url=https%3A%2F%2Fihsmarkit.com%2FLegal%2FEmailDisclaimer.html&data=02%7C01%7CTrevor.Dunn%40ihsmarkit.com%7C0d15736985c940b5b21e08d7f1f578d4%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C0%7C637243908906785687&sdata=5oFK4TiE%2FIHDb1MVfY82mNbDsO5gZu3KB%2Bg4Azi2NpA%3D&reserved=0 Please visit https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.ihsmarkit.com%2Fabout%2Fcontact-us.html&data=02%7C01%7CTrevor.Dunn%40ihsmarkit.com%7C0d15736985c940b5b21e08d7f1f578d4%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C0%7C637243908906785687&sdata=gHyqxRUB2CsCKnvCk2H3%2Bey%2FV0OGM3tkNjM5tjKFOfc%3D&reserved=0 for contact information on our offices worldwide. ________________________________ This e-mail, including accompanying communications and attachments, is strictly confidential and only for the intended recipient. Any retention, use or disclosure not expressly authorised by IHSMarkit is prohibited. This email is subject to all waivers and other terms at the following link: https://ihsmarkit.com/Legal/EmailDisclaimer.html Please visit www.ihsmarkit.com/about/contact-us.html for contact information on our offices worldwide.
