Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Issue when running ExecuteStateless

avatar
Explorer

I am trying to run flow using executestateless by following tutorial here, (190) Kafka Exactly Once with NiFi - YouTube

Nifi version: 1.16.3 running on kubernetes

My processor is as follow, 

rtambun_1-1701854505453.png

And for ProcessXMLStageDB,

rtambun_2-1701854554329.png

ConsumeJMS connected to IBM MQ. Jar file and truststore file to connect with IBM MQ is included in the Nifi image, i.e. I create custom image to add the necessary requirement to connect to IBM MQ.

This is my ExecuteStateless,

rtambun_3-1701854608700.png

This are the details of the executeStateless process, 

rtambun_4-1701854633971.png

When running i can see following error, 

{"timestamp": "2023-12-06 08:56:07,478", "level": "INFO", "thread": "Timer-Driven Process Thread-1", "logger": "org.apache.nifi.nar.NarUnpacker", "message": "Expanding 107 NAR files with all processors..."}
{"timestamp": "2023-12-06 08:56:07,485", "level": "INFO", "thread": "Timer-Driven Process Thread-1", "logger": "org.apache.nifi.nar.NarUnpacker", "message": "NAR loading process took 7006152 nanoseconds (0 seconds)."}
{"timestamp": "2023-12-06 08:56:07,489", "level": "INFO", "thread": "Timer-Driven Process Thread-1", "logger": "o.a.n.s.bootstrap.StatelessBootstrap", "message": "Unpacked NAR files in 12 millis"}
{"timestamp": "2023-12-06 08:56:07,508", "level": "ERROR", "thread": "Timer-Driven Process Thread-1", "logger": "o.a.n.p.stateless.ExecuteStateless", "message": "ExecuteStateless[id=3e534fb8-018c-1000-0000-000020557ca5] Processing halted: yielding [1 sec]"}
java.lang.NoClassDefFoundError: java/lang/Object
at java.base/java.lang.ClassLoader.defineClass1(Native Method)
at java.base/java.lang.ClassLoader.defineClass(Unknown Source)
at java.base/java.security.SecureClassLoader.defineClass(Unknown Source)
at java.base/java.net.URLClassLoader.defineClass(Unknown Source)
at java.base/java.net.URLClassLoader$1.run(Unknown Source)
at java.base/java.net.URLClassLoader$1.run(Unknown Source)
at java.base/java.security.AccessController.doPrivileged(Native Method)
at java.base/java.net.URLClassLoader.findClass(Unknown Source)
at java.base/java.lang.ClassLoader.loadClass(Unknown Source)
at java.base/java.lang.ClassLoader.loadClass(Unknown Source)
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Unknown Source)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.nextProviderClass(Unknown Source)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(Unknown Source)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(Unknown Source)
at java.base/java.util.ServiceLoader$2.hasNext(Unknown Source)
at java.base/java.util.ServiceLoader$3.hasNext(Unknown Source)
at org.apache.nifi.stateless.bootstrap.StatelessBootstrap.getSingleInstance(StatelessBootstrap.java:341)
at org.apache.nifi.stateless.bootstrap.StatelessBootstrap.createDataflow(StatelessBootstrap.java:69)
at org.apache.nifi.processors.stateless.ExecuteStateless.createDataflow(ExecuteStateless.java:469)
at org.apache.nifi.processors.stateless.ExecuteStateless.getDataflow(ExecuteStateless.java:477)
at org.apache.nifi.processors.stateless.ExecuteStateless.onTrigger(ExecuteStateless.java:497)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1283)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:214)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:103)
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)
Caused by: java.lang.ClassNotFoundException: java.lang.Object
at java.base/java.net.URLClassLoader.findClass(Unknown Source)
at java.base/java.lang.ClassLoader.loadClass(Unknown Source)
at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

Anyone has idea what is going wrong ?

1 REPLY 1

avatar
Community Manager

@rtambun Welcome to the Cloudera Community!

To help you get the best possible solution, I have tagged our NiFi experts @joseomjr @cotopaul @SAMSAL  who may be able to assist you further.

Please keep us updated on your post, and we hope you find a satisfactory solution to your query.


Regards,

Diana Torres,
Community Moderator


Was your question answered? Make sure to mark the answer as the accepted solution.
If you find a reply useful, say thanks by clicking on the thumbs up button.
Learn more about the Cloudera Community: