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 <[email protected]> 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/
>
