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/
>>
>
>
