I've got to be missing something simple here, but I'm having trouble with
Ignite calling C* with the POJO key that I'm supplying it when it tries to
"cache.get". Whenever I try to supply the "cache.get" method with my POJO
key, it complains that it's null when it tries to execute the CQL. I've
included a link to my project below.
This is the call in the application:
final Test1 value3 = cache.get(new
Test1Key("test123"));
With Test1Key as:
Exception Thrown
*java.lang.IllegalStateException: Failed to execute CommandLineRunner* at
org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:779)
~[spring-boot-1.5.1.RELEASE.jar:1.5.1.RELEASE] at
org.springframework.boot.SpringApplication.callRunners(SpringApplication.java:760)
~[spring-boot-1.5.1.RELEASE.jar:1.5.1.RELEASE] at
org.springframework.boot.SpringApplication.afterRefresh(SpringApplication.java:747)
~[spring-boot-1.5.1.RELEASE.jar:1.5.1.RELEASE] at
org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
~[spring-boot-1.5.1.RELEASE.jar:1.5.1.RELEASE] at
com.gm.examples.cassandra_persistence_store.Application.main(Application.java:55)
[classes/:na]*Caused by: javax.cache.integration.CacheLoaderException: class
org.apache.ignite.IgniteException: Failed to execute Cassandra CQL
statement: select "column_1", "column_2", "column_3", "column_4",
"column_5", "column_6", "column_7", "column_8", "column_9" from
"dev_qlty"."test1" where "my_id"=?;* at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.loadFromStore(GridCacheStoreManagerAdapter.java:327)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.load(GridCacheStoreManagerAdapter.java:282)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.loadAllFromStore(GridCacheStoreManagerAdapter.java:418)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.loadAll(GridCacheStoreManagerAdapter.java:384)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$15.call(GridCacheAdapter.java:2024)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$15.call(GridCacheAdapter.java:2022)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6608)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.closure.GridClosureProcessor$2.body(GridClosureProcessor.java:959)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
~[ignite-core-2.2.0.jar:2.2.0] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
~[na:1.8.0_92] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
~[na:1.8.0_92] at java.lang.Thread.run(Thread.java:745)
~[na:1.8.0_92]*Caused by: org.apache.ignite.IgniteException: Failed to
execute Cassandra CQL statement: select "column_1", "column_2", "column_3",
"column_4", "column_5", "column_6", "column_7", "column_8", "column_9" from
"dev_qlty"."test1" where "my_id"=?;* at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:185)
~[ignite-cassandra-store-2.2.0.jar:2.2.0] at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.load(CassandraCacheStore.java:189)
~[ignite-cassandra-store-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.CacheStoreBalancingWrapper.load(CacheStoreBalancingWrapper.java:98)
~[ignite-core-2.2.0.jar:2.2.0] at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.loadFromStore(GridCacheStoreManagerAdapter.java:316)
~[ignite-core-2.2.0.jar:2.2.0] ... 11 common frames omitted*Caused by:
org.apache.ignite.IgniteException: Failed to execute Cassandra CQL
statement: select "column_1", "column_2", "column_3", "column_4",
"column_5", "column_6", "column_7", "column_8", "column_9" from
"dev_qlty"."test1" where "my_id"=?;* at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:167)
~[ignite-cassandra-store-2.2.0.jar:2.2.0] ... 14 common frames
omittedCaused
by: com.datastax.driver.core.exceptions.InvalidQueryException: Invalid null
value in condition for column my_id at
com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
~[cassandra-driver-core-3.0.0.jar:na] at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:144)
~[ignite-cassandra-store-2.2.0.jar:2.2.0] ... 14 common frames
omitted*Caused by:
com.datastax.driver.core.exceptions.InvalidQueryException: Invalid null
value in condition for column my_id* at
com.datastax.driver.core.Responses$Error.asException(Responses.java:136)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:179)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:184)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.RequestHandler.access$2500(RequestHandler.java:43)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:798)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:617)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1005)
~[cassandra-driver-core-3.0.0.jar:na] at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:928)
~[cassandra-driver-core-3.0.0.jar:na] at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
~[netty-handler-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
~[netty-codec-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)
~[netty-codec-4.0.33.Final.jar:4.0.33.Final] at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)
~[netty-codec-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
~[netty-transport-4.0.33.Final.jar:4.0.33.Final] at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
~[netty-common-4.0.33.Final.jar:4.0.33.Final] ... 1 common frames omitted
Attached IntelliJ project
(replace the C* server name & keyspace/pw to run - I also did not include
the Ignite jars that are referenced with "systemPath")
test_cassandra.zip
<http://apache-ignite-users.70518.x6.nabble.com/file/t653/test_cassandra.zip>
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
