I don't really get, what you trying to do here: val sharedRDDConsumer = igniteContext.fromCache("sharedRDDProducer")
it looks like a mistake Here is example of using ignite sql from spark in java: https://github.com/apache/ignite/blob/master/examples/src/main/spark/org/apache/ignite/examples/spark/SharedRDDExample.java the same for scala: https://github.com/apache/ignite/blob/master/examples/src/main/scala/org/apache/ignite/scalar/examples/spark/ScalarSharedRDDExample.scala 2017-11-08 19:02 GMT+03:00 future expert <futureexpert2...@gmail.com>: > Thanks. I currently do not have indexed types for cache > "sharedRDDProducer" as i currently add it as below. > > *val sharedRDDProducer: IgniteRDD[String, String] = > igniteContext.fromCache[String, String]("sharedRDDProducer")* > *sharedRDDProducer.savePairs(jsonRdd)* > > Is the indexed types needed for sharedRDDProducer as well? If so, how can > I add it? > > Also, I am getting the below exception with all the different types of > datasets when trying to do a *sharedRDDConsumer.first() or > **sharedRDDConsumer.take(5).foreach(println). > *I think that something is wrong with the saved sharedRDDProducer. Could > it be an Ignite version issue? > > java.lang.NumberFormatException: For input string: "1%lo" > at java.lang.NumberFormatException.forInputString(NumberFormatE > xception.java:65) > > > I tried the below example using [Int, Int] rdd as well but the SQL part at > the end is giving the same exception. Do you have a working SQL query > sample in scala using [string, string] pair rdd? Thanks. > > https://github.com/apache/ignite/blob/master/examples/ > src/main/scala/org/apache/ignite/scalar/examples/spark/ > ScalarSharedRDDExample.scala > > > > > On Wed, Nov 8, 2017 at 6:27 AM, ezhuravlev <e.zhuravlev...@gmail.com> > wrote: > >> Do you have indexed types for cache "sharedRDDProducer"? >> >> like >> >> cacheCfg.setIndexedTypes(String.class, String.class); >> >> Evgenii >> >> >> >> -- >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >> > >