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%7Cda5b2a4e4ba34991b17808d7f1ea1b44%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C1%7C637243860093915284&sdata=eQHM2VFKxRTgMt%2FQZtOZmiVX2cGVC9IrOJC%2FFQMVXkk%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%7Cda5b2a4e4ba34991b17808d7f1ea1b44%7Cc1156c2fa3bb4fc4ac073eab96da8d10%7C1%7C1%7C637243860093915284&sdata=Qsabo1Cu5x8HYSJ7xy34hXm4XbQmm6ZRgeU1UBz3vmY%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.
