ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From future expert <futureexpert2...@gmail.com>
Subject Failed to parse query: exception with Scala
Date Wed, 08 Nov 2017 05:45:07 GMT
Ignite version: 2.1


   - I get the below exception when trying to query the shared pair rdd
   using sql.

Exception   : class javax.cache.CacheException
    Message     : class
org.apache.ignite.internal.processors.query.IgniteSQLException:
Failed to parse query: select _key, _val from String
    Cause       : class
org.apache.ignite.internal.processors.query.IgniteSQLException:
Failed to parse query: select _key, _val from String
    Stack Trace : org.apache.ignite.internal.processors.cache.
IgniteCacheProxy.query(IgniteCacheProxy.java:807)


Please see below.
*val jsonRdd = rawRdd.map(x => (x.id <http://x.id>, x.json))*
*val sharedRDDProducer: IgniteRDD[String, String] =
igniteContext.fromCache[String, String]("sharedRDDProducer")*
*sharedRDDProducer.savePairs(jsonRdd)*

*val sharedRDDConsumer = igniteContext.fromCache("sharedRDDProducer")*
*val df = sharedRDDConsumer.sql("select _key, _val from String")*
*df.show(10)*


   - I have also tried using the below and it gives the same error.

*val cacheCfg = new CacheConfiguration[String, String]()*
*cacheCfg.setName("sharedRDDConsumer")*
*cacheCfg.setIndexedTypes(classOf[String], classOf[String])*
*val sharedRDD = igniteContext.fromCache(cacheCfg)*



   - Also, getting the below exception when trying
*sharedRDDConsumer.take(5).foreach(println).
   *Not sure if this is related to the above issue.

java.lang.NumberFormatException: For input string: "1%lo"
at java.lang.NumberFormatException.forInputString(
NumberFormatException.java:65)



   - The other thing i noticed is that the *count()* on
*sharedRDDConsumer *always
   gives 1 whereas *count() *on *jsonRdd *gives the valid record count of
   the jsonRdd*. *Is this the expected behavior of the IgniteRDD?

Kindly let me know if there are any suggestions. Thanks.

Mime
View raw message