[
https://issues.apache.org/jira/browse/NIFI-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435208#comment-15435208
]
Charles Bryan Clifford commented on NIFI-2200:
----------------------------------------------
This issue is not a bug.
The QueryDatabaseTable documentation does not state that (any variation of) SQL
syntax can be used to initialize the literal string value of the table name
property.
Using an SQL statement to initialize a literal string value of a single table
name is not an appropriate technique. Support such a technique requires a NiFi
processor to also be an SQL query parser (of 1 unidentified SQL syntax out of
many possible variations), and that is just not an realistic expectation.
> QueryDatabaseTable subquery
> ---------------------------
>
> Key: NIFI-2200
> URL: https://issues.apache.org/jira/browse/NIFI-2200
> Project: Apache NiFi
> Issue Type: Bug
> Reporter: Nabegh
>
> QueryDatabaseTable throws an exception if given a subquery as the table name
> with a where condition.
> For example, Table Name =
> (select * from table_name where condition = value) t
> will throw the following error
> 2016-07-07 16:23:22,668 ERROR [Timer-Driven Process Thread-7]
> o.a.n.p.standard.QueryDatabaseTable
> QueryDatabaseTable[id=354261e7-cfa5-4809-a60c-a9c5136faa70] Failed to process
> session due to org.apache.nifi.processor.exception.FlowFileHandlingException:
> StandardFlowFileRecord[uuid=5b7fca67-9fd6-4dd3-9cc4-f2a0bfcf7095,claim=,offset=0,name=196391993568910,size=0]
> transfer relationship not specified:
> org.apache.nifi.processor.exception.FlowFileHandlingException:
> StandardFlowFileRecord[uuid=5b7fca67-9fd6-4dd3-9cc4-f2a0bfcf7095,claim=,offset=0,name=196391993568910,size=0]
> transfer relationship not specified
> 2016-07-07 16:23:22,671 ERROR [Timer-Driven Process Thread-7]
> o.a.n.p.standard.QueryDatabaseTable
> org.apache.nifi.processor.exception.FlowFileHandlingException:
> StandardFlowFileRecord[uuid=5b7fca67-9fd6-4dd3-9cc4-f2a0bfcf7095,claim=,offset=0,name=196391993568910,size=0]
> transfer relationship not specified
> at
> org.apache.nifi.controller.repository.StandardProcessSession.checkpoint(StandardProcessSession.java:212)
> ~[nifi-framework-core-0.6.1.jar:0.6.1]
> at
> org.apache.nifi.controller.repository.StandardProcessSession.commit(StandardProcessSession.java:282)
> ~[nifi-framework-core-0.6.1.jar:0.6.1]
> at
> org.apache.nifi.processors.standard.QueryDatabaseTable.onTrigger(QueryDatabaseTable.java:348)
> ~[na:na]
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1059)
> ~[nifi-framework-core-0.6.1.jar:0.6.1]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136)
> [nifi-framework-core-0.6.1.jar:0.6.1]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
> [nifi-framework-core-0.6.1.jar:0.6.1]
> at
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:123)
> [nifi-framework-core-0.6.1.jar:0.6.1]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> [na:1.8.0_91]
> at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
> [na:1.8.0_91]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
> [na:1.8.0_91]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
> [na:1.8.0_91]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [na:1.8.0_91]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [na:1.8.0_91]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
