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,
And for ProcessXMLStageDB,
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,
This are the details of the executeStateless process,
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 ?