Re: Using QueryDatabaseTable processor in MiNiFi

[Aldrin Piri]

Okay, thanks for the update.  Figuring out where things went awry would be
helpful to make that process easier.  We certainly have a lot of room to
improve on our documentation.



On Thu, Jul 27, 2017 at 3:27 PM, Jeff Zemerick  wrote:

> I went through the steps again and it worked fine so it was total user
> failure somewhere on my part. I am curious as to where I went wrong so I am
> trying to reproduce it to see if it's worth any documentation updates.
>
> Thanks,
> Jeff
>
>
> On Thu, Jul 27, 2017 at 10:09 AM, Aldrin Piri 
> wrote:
>
>> Hey Jeff,
>>
>> Could you please provide a full nifi-app.log of the startup?
>>
>> Thanks,
>> Aldrin
>>
>> On Thu, Jul 27, 2017 at 10:04 AM, Jeff Zemerick 
>> wrote:
>>
>>> I have a small flow that was exported from NiFi and it uses a
>>> QueryDatabaseTable processor. When the flow is converted to yaml and set in
>>> MiNiFi I get the following error in MiNiFi's app log:
>>>
>>> ERROR [main] o.apache.nifi.controller.FlowController Could not create
>>> Processor of type org.apache.nifi.processors.standard.QueryDatabaseTable
>>> for ID 9570c06a-837b-3ac0--; creating "Ghost"
>>> implementation
>>> org.apache.nifi.controller.exception.ProcessorInstantiationException:
>>> Unable to find bundle for coordinate default:unknown:unversioned
>>> at org.apache.nifi.controller.FlowController.instantiateProcess
>>> or(FlowController.java:1162)
>>> at org.apache.nifi.controller.FlowController.createProcessor(Fl
>>> owController.java:1080)
>>> at org.apache.nifi.controller.FlowController.createProcessor(Fl
>>> owController.java:1053)
>>> at org.apache.nifi.controller.StandardFlowSynchronizer.addProce
>>> ssGroup(StandardFlowSynchronizer.java:1054)
>>> at org.apache.nifi.controller.StandardFlowSynchronizer.addProce
>>> ssGroup(StandardFlowSynchronizer.java:1175)
>>> at org.apache.nifi.controller.StandardFlowSynchronizer.sync(Sta
>>> ndardFlowSynchronizer.java:312)
>>> at org.apache.nifi.controller.FlowController.synchronize(FlowCo
>>> ntroller.java:1544)
>>> at org.apache.nifi.persistence.StandardXMLFlowConfigurationDAO.
>>> load(StandardXMLFlowConfigurationDAO.java:84)
>>> at org.apache.nifi.controller.StandardFlowService.loadFromBytes
>>> (StandardFlowService.java:720)
>>> at org.apache.nifi.controller.StandardFlowService.load(Standard
>>> FlowService.java:533)
>>> at org.apache.nifi.minifi.MiNiFiServer.start(MiNiFiServer.java:113)
>>> at org.apache.nifi.minifi.MiNiFi.(MiNiFi.java:140)
>>> at org.apache.nifi.minifi.MiNiFi.main(MiNiFi.java:239)
>>>
>>> I verified in the log that the QueryDatabaseTable processor is being
>>> loaded during MiNiFi's start up. Just above this message I can see that the
>>> DBCP controller service seems to be ok:
>>>
>>> 2017-07-27 09:32:54,877 INFO [main] 
>>> o.a.n.c.s.StandardControllerServiceProvider
>>> Created Controller Service of type org.apache.nifi.dbcp.DBCPConnectionPool
>>> with identifier c42fe292-fe4b-3423--
>>> 2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup
>>> DBCPConnectionPool[id=c42fe292-fe4b-3423--] added to
>>> StandardProcessGroup[identifier=f56cb9ff-f706-328b--]
>>>
>>> Did I forget to do something?
>>>
>>> Thanks,
>>> Jeff
>>>
>>>
>>
>

Re: Using QueryDatabaseTable processor in MiNiFi

[Jeff Zemerick]

I went through the steps again and it worked fine so it was total user
failure somewhere on my part. I am curious as to where I went wrong so I am
trying to reproduce it to see if it's worth any documentation updates.

Thanks,
Jeff


On Thu, Jul 27, 2017 at 10:09 AM, Aldrin Piri  wrote:

> Hey Jeff,
>
> Could you please provide a full nifi-app.log of the startup?
>
> Thanks,
> Aldrin
>
> On Thu, Jul 27, 2017 at 10:04 AM, Jeff Zemerick 
> wrote:
>
>> I have a small flow that was exported from NiFi and it uses a
>> QueryDatabaseTable processor. When the flow is converted to yaml and set in
>> MiNiFi I get the following error in MiNiFi's app log:
>>
>> ERROR [main] o.apache.nifi.controller.FlowController Could not create
>> Processor of type org.apache.nifi.processors.standard.QueryDatabaseTable
>> for ID 9570c06a-837b-3ac0--; creating "Ghost"
>> implementation
>> org.apache.nifi.controller.exception.ProcessorInstantiationException:
>> Unable to find bundle for coordinate default:unknown:unversioned
>> at org.apache.nifi.controller.FlowController.instantiateProcess
>> or(FlowController.java:1162)
>> at org.apache.nifi.controller.FlowController.createProcessor(Fl
>> owController.java:1080)
>> at org.apache.nifi.controller.FlowController.createProcessor(Fl
>> owController.java:1053)
>> at org.apache.nifi.controller.StandardFlowSynchronizer.addProce
>> ssGroup(StandardFlowSynchronizer.java:1054)
>> at org.apache.nifi.controller.StandardFlowSynchronizer.addProce
>> ssGroup(StandardFlowSynchronizer.java:1175)
>> at org.apache.nifi.controller.StandardFlowSynchronizer.sync(Sta
>> ndardFlowSynchronizer.java:312)
>> at org.apache.nifi.controller.FlowController.synchronize(FlowCo
>> ntroller.java:1544)
>> at org.apache.nifi.persistence.StandardXMLFlowConfigurationDAO.
>> load(StandardXMLFlowConfigurationDAO.java:84)
>> at org.apache.nifi.controller.StandardFlowService.loadFromBytes
>> (StandardFlowService.java:720)
>> at org.apache.nifi.controller.StandardFlowService.load(Standard
>> FlowService.java:533)
>> at org.apache.nifi.minifi.MiNiFiServer.start(MiNiFiServer.java:113)
>> at org.apache.nifi.minifi.MiNiFi.(MiNiFi.java:140)
>> at org.apache.nifi.minifi.MiNiFi.main(MiNiFi.java:239)
>>
>> I verified in the log that the QueryDatabaseTable processor is being
>> loaded during MiNiFi's start up. Just above this message I can see that the
>> DBCP controller service seems to be ok:
>>
>> 2017-07-27 09:32:54,877 INFO [main] 
>> o.a.n.c.s.StandardControllerServiceProvider
>> Created Controller Service of type org.apache.nifi.dbcp.DBCPConnectionPool
>> with identifier c42fe292-fe4b-3423--
>> 2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup
>> DBCPConnectionPool[id=c42fe292-fe4b-3423--] added to
>> StandardProcessGroup[identifier=f56cb9ff-f706-328b--]
>>
>> Did I forget to do something?
>>
>> Thanks,
>> Jeff
>>
>>
>

Using QueryDatabaseTable processor in MiNiFi

[Jeff Zemerick]

I have a small flow that was exported from NiFi and it uses a
QueryDatabaseTable processor. When the flow is converted to yaml and set in
MiNiFi I get the following error in MiNiFi's app log:

ERROR [main] o.apache.nifi.controller.FlowController Could not create
Processor of type org.apache.nifi.processors.standard.QueryDatabaseTable
for ID 9570c06a-837b-3ac0--; creating "Ghost" implementation
org.apache.nifi.controller.exception.ProcessorInstantiationException:
Unable to find bundle for coordinate default:unknown:unversioned
at
org.apache.nifi.controller.FlowController.instantiateProcessor(FlowController.java:1162)
at
org.apache.nifi.controller.FlowController.createProcessor(FlowController.java:1080)
at
org.apache.nifi.controller.FlowController.createProcessor(FlowController.java:1053)
at
org.apache.nifi.controller.StandardFlowSynchronizer.addProcessGroup(StandardFlowSynchronizer.java:1054)
at
org.apache.nifi.controller.StandardFlowSynchronizer.addProcessGroup(StandardFlowSynchronizer.java:1175)
at
org.apache.nifi.controller.StandardFlowSynchronizer.sync(StandardFlowSynchronizer.java:312)
at
org.apache.nifi.controller.FlowController.synchronize(FlowController.java:1544)
at
org.apache.nifi.persistence.StandardXMLFlowConfigurationDAO.load(StandardXMLFlowConfigurationDAO.java:84)
at
org.apache.nifi.controller.StandardFlowService.loadFromBytes(StandardFlowService.java:720)
at
org.apache.nifi.controller.StandardFlowService.load(StandardFlowService.java:533)
at org.apache.nifi.minifi.MiNiFiServer.start(MiNiFiServer.java:113)
at org.apache.nifi.minifi.MiNiFi.(MiNiFi.java:140)
at org.apache.nifi.minifi.MiNiFi.main(MiNiFi.java:239)

I verified in the log that the QueryDatabaseTable processor is being loaded
during MiNiFi's start up. Just above this message I can see that the DBCP
controller service seems to be ok:

2017-07-27 09:32:54,877 INFO [main]
o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of
type org.apache.nifi.dbcp.DBCPConnectionPool with identifier
c42fe292-fe4b-3423--
2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup
DBCPConnectionPool[id=c42fe292-fe4b-3423--] added to
StandardProcessGroup[identifier=f56cb9ff-f706-328b--]

Did I forget to do something?

Thanks,
Jeff