Using QueryDatabaseTable processor in MiNiFi

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

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-0000-000000000000; 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.<init>(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-0000-000000000000
2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup DBCPConnectionPool[id=c42fe292-fe4b-3423-0000-000000000000] added to StandardProcessGroup[identifier=f56cb9ff-f706-328b-0000-000000000000]

Did I forget to do something?

Thanks,
Jeff

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Using QueryDatabaseTable processor in MiNiFi

Aldrin Piri
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 <[hidden email]> 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-0000-000000000000; 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.<init>(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-0000-000000000000
2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup DBCPConnectionPool[id=c42fe292-fe4b-3423-0000-000000000000] added to StandardProcessGroup[identifier=f56cb9ff-f706-328b-0000-000000000000]

Did I forget to do something?

Thanks,
Jeff


Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

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 <[hidden email]> 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 <[hidden email]> 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-0000-000000000000; 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.<init>(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-0000-000000000000
2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup DBCPConnectionPool[id=c42fe292-fe4b-3423-0000-000000000000] added to StandardProcessGroup[identifier=f56cb9ff-f706-328b-0000-000000000000]

Did I forget to do something?

Thanks,
Jeff



Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

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 <[hidden email]> 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 <[hidden email]> 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 <[hidden email]> 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-0000-000000000000; 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.<init>(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-0000-000000000000
2017-07-27 09:32:54,925 INFO [main] o.a.nifi.groups.StandardProcessGroup DBCPConnectionPool[id=c42fe292-fe4b-3423-0000-000000000000] added to StandardProcessGroup[identifier=f56cb9ff-f706-328b-0000-000000000000]

Did I forget to do something?

Thanks,
Jeff




Loading...