Cloudera Community
Poul
user rank
Explorer

Re: QueryRecord returns "Cannot commit session whi...

by Explorer in Support Questions
‎04-20-2023 01:44 AM
‎04-20-2023 01:44 AM
This is most likely linked to issue nifi.11106 ... View more

Connect local Nifi to central Nifi registry with a...

by Explorer in Support Questions
‎04-20-2023 01:40 AM
‎04-20-2023 01:40 AM
Hi.   I have a use case where I have to connect a local Nifi to a central Nifi registry where I have to use an in between.proxy server. Can that be done and how?   This is not about setting up the proxy. I do have a proxy. Just need to link the two using it.   BR. Poul ... View more
Labels:

QueryRecord returns "Cannot commit session while r...

by Explorer in Support Questions
‎02-08-2023 05:57 AM
‎02-08-2023 05:57 AM
I am using QueryRecord to translate data from one format to another, but once in a while, I am getting this error here. Not sure what to do about and how to handle it. I am using Nifi 1.19.1 [Timer-Driven Process Thread-15] o.a.n.c.r.StandardProcessSession Failed to asynchronously commit session StandardProcessSession[id=25336651] for QueryRecord[id=dba21f2d-ea2b-327b-3692-5eefbb53cd52] java.lang.IllegalStateException: Cannot commit session while reading from FlowFile at org.apache.nifi.controller.repository.StandardProcessSession.validateCommitState(StandardProcessSession.java:245) at org.apache.nifi.controller.repository.StandardProcessSession.checkpoint(StandardProcessSession.java:274) at org.apache.nifi.controller.repository.StandardProcessSession.commit(StandardProcessSession.java:556) at org.apache.nifi.controller.repository.StandardProcessSession.commitAsync(StandardProcessSession.java:510) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:28) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1356) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:246) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102) at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) at java.base/java.util.concurrent.FutureTask.runAndReset(Unknown Source) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) ... View more
Labels:

Re: Nifi registry architecture.

by Explorer in Support Questions
‎09-12-2022 02:33 AM
‎09-12-2022 02:33 AM
Hi. And thanks for your input, the blog post was exact what I where looking for. What I am facing is this part here, e.g. when moving flow between environments, the links to nested flowfiles needs to be updated manually / does not work. Think we will go for solution 1 for now and revert when there is an update. Support for embedded versioned process groups is not fully ready yet when you have multiple Registry instances and you need to export/import things between the instances. You can check the status on NIFI-5029.   ... View more

Nifi registry architecture.

by Explorer in Support Questions
‎09-08-2022 11:45 PM
‎09-08-2022 11:45 PM
Hi.   I have just started on a project, where we want to set up a landscape of nifi instanses, connected to nifi registry. And we are planning on making a dev. environment a test and a prod. The question started, when we made versioned nifi flows with versioned nifi flows inside, for code reuse and easier maintenance. But that cannot be moved easily between nifi registry instanses?   Do we connect all of the nifi instanses to one registry or what is the best practice? Or what are we doing wrong? ... View more
Labels:
Contact Me
Online
Offline
Last Visited
‎05-04-2023 11:02 AM
Community Statistics
Member Since ‎09-08-2022 11:39 PM
Last Visited ‎05-04-2023 11:02 AM
Posts 5