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.
