ExecuteScript with apache Ignite

[Carlos Manuel Fernandes (DSI)]

Hello,

I am trying to connect Nifi with Apache Ignite  to put  some data  on Ignite 
cache using ExecuteScript because  putIgniteCache  and GetIgniteCache 
processors are bounded to an older Ignite version.

I made Test1 (below) using standalone groovy without Nifi and work Well.   
Test2(below) using Nifi groovy ExecuteScript  in Ignition.start  always  run on 
error:  java.lang.ClassNotFoundException: 
org.apache.ignite.configuration.IgniteConfiguration. I am certain the two Grabs 
work well  because  I haven't errors on Import statements and  the jars are in 
the grapes Folder.

Any idea?

Thanks
Carlos

Test1 - StandAlone groovy program (work well)


@Grab ('org.apache.ignite:ignite-core:2.8.1')
@Grab ('org.apache.ignite:ignite-spring:2.8.1')

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition

Ignition.setClientMode(true);

// Here, we provide the cache configuration file
Ignite objIgnite = Ignition.start("c:\\tmp\\ignite\\first-config.xml");

// create cache if not already existing
IgniteCache<Integer, String> objIgniteCache = 
objIgnite.getOrCreateCache("myFirstIgniteCache");

// Populating the cache with few values
objIgniteCache.put(1, "salman");
objIgniteCache.put(2, "Abhishek");
objIgniteCache.put(3, "Siddharth");
objIgniteCache.put(4, "Dev");

// Get these items from cache
System.out.println(objIgniteCache.get(1));
System.out.println(objIgniteCache.get(2));
System.out.println(objIgniteCache.get(3));
System.out.println(objIgniteCache.get(4));
Ignition.stop(true);



Test2 - ExecuteScript groovy code (don't work)

@Grab ('org.apache.ignite:ignite-core:2.8.1')
@Grab ('org.apache.ignite:ignite-spring:2.8.1')

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition

def flowFile = session.get()
if (!flowFile) return

try {
       Ignition.setClientMode(true);

       // Here, we provide the cache configuration file
       log.info("Before Ignite")
       Ignite objIgnite = Ignition.start("/apps/nifi-scripts/first-config.xml");
       log.info("After Ignite")

       // create cache if not already existing
       IgniteCache<Integer, String> objIgniteCache = 
objIgnite.getOrCreateCache("myFirstIgniteCache");

       // Populating the cache with few values
       log.info("Put on cache")
       objIgniteCache.put(1, "salman");
       objIgniteCache.put(2, "Abhishek");
       objIgniteCache.put(3, "Siddharth");
       objIgniteCache.put(4, "carlos");

       // Get these items from cache
       log.info("get from cache")
       System.out.println(objIgniteCache.get(1));
       System.out.println(objIgniteCache.get(2));
       System.out.println(objIgniteCache.get(3));
       System.out.println(objIgniteCache.get(4));

       log.info("cachequery for 4 is :${objIgniteCache.get(4)}")
       Ignition.stop(true);
       session.transfer(flowFile, REL_SUCCESS)
}
catch(Exception e) {
       log.error('Error:', e)
       session.transfer(flowFile, REL_FAILURE)
}
finally {

       log.info("end")
}


Caused by: java.lang.ClassNotFoundException: 
org.apache.ignite.configuration.IgniteConfiguration
        at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at org.springframework.util.ClassUtils.forName(ClassUtils.java:251)
        at 
org.springframework.beans.factory.support.AbstractBeanDefinition.resolveBeanClass(AbstractBeanDefinition.java:408)
        at 
org.springframework.beans.factory.support.AbstractBeanFactory.doResolveBeanClass(AbstractBeanFactory.java:1444)
        at 
org.springframework.beans.factory.support.AbstractBeanFactory.resolveBeanClass(AbstractBeanFactory.java:1389)
        ... 37 common frames omitted