Any suggestions on the below will be really appreciated.
Thanks.
On Wed, Nov 8, 2017 at 11:00 AM, future expert <futureexpert2...@gmail.com>
wrote:
> I am just trying to retrieve the already cached shared-rdd(
> sharedRDDProducer) back from cache. I have also tried like below too
> without success.
>
> *val *sharedRDDConsumer*: IgniteRDD[String, String] =
> igniteContext.fromCache[String, String]("*sharedRDDProducer*")*
>
> I am getting the same error even when running the below example program
>
> Exception : class javax.cache.CacheException
> Message : class org.apache.ignite.internal.pro
> cessors.query.IgniteSQLException: Failed to parse query: select _val from
> String
>
> Also, not sure why the retrieved RDD count() always shows 1 instead of the
> actual recordcount!
>
> Thanks.
>
>
> On Wed, Nov 8, 2017 at 8:45 AM, Evgenii Zhuravlev <
> e.zhuravlev...@gmail.com> wrote:
>
>> 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/ScalarSh
>> aredRDDExample.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/ma
>>> in/scala/org/apache/ignite/scalar/examples/spark/ScalarShare
>>> dRDDExample.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/
>>>>
>>>
>>>
>>
>
