Ok, I have finally been able to get back to this.
First, I switched the @QuerySqlField annotations back to the fields from the
setters as instructed. Then I executed with a minimal persistence settings
xml file which only defined the strategy as POJO, but did not specify the
field/column combinations. That was left to the classes themselves. This
still failed, and it might be due to the same reason why I was told to
switch my @QuerySqlField annotations from the fields to the setters in the
first place. The fields aren't public, so unless the reflection api is set
to look for Annotations on private fields for the definitions, they will not
be found.
Second, I changed to use a persistence settings xml file that specified the
field/column combination, and that worked. This is definitely not the way I
want to proceed, but it will work for now.
Stacktrace
[07:21:21] Ignite node started OK (id=682a9f97)
[07:21:21] Topology snapshot [ver=1, servers=1, clients=0, CPUs=8,
heap=7.1GB]
>>> Cache store example started.
>>> Putting to C*. Key: [HistoryResultKey = [key: key1, sessionId:
>>> sessionId1, algorithmName: algoName2]], Result: [HistoryResult = [key:
>>> key1, sessionId: sessionId1, sessionTime: 2017-06-06 07:21:21.013,
>>> algorithmName: algoName2, results: results-2017-06-06T07:21:21.018,
>>> analysisTime: 2017-06-06 07:21:21.018, createdDate: 2017-06-06
>>> 07:21:21.018, createdBy: creator, modifiedDate: 2017-06-06 07:21:21.018,
>>> modifiedBy: updater]]
[07:21:33,243][SEVERE][main][CassandraCacheStore] Failed to execute
Cassandra CQL statement: insert into "dev_keyspace"."HistoryResult"
("algorithmname", "sessionid", "key", "analysistime", "createdby",
"createddate", "modifiedby", "modifieddate", "results", "sessiontime")
values (?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
class org.apache.ignite.IgniteException: Failed to execute Cassandra CQL
statement: insert into "dev_keyspace"."HistoryResult" ("algorithmname",
"sessionid", "key", "analysistime", "createdby", "createddate",
"modifiedby", "modifieddate", "results", "sessiontime") values
(?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:167)
at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.write(CassandraCacheStore.java:276)
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.put(GridCacheStoreManagerAdapter.java:568)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.update(GridCacheMapEntry.java:4404)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.call(GridCacheMapEntry.java:4226)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.call(GridCacheMapEntry.java:3966)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree$Invoke.invokeClosure(BPlusTree.java:2966)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree$Invoke.access$6200(BPlusTree.java:2860)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree.invokeDown(BPlusTree.java:1696)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree.invoke(BPlusTree.java:1585)
at
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl$CacheDataStoreImpl.invoke(IgniteCacheOffheapManagerImpl.java:925)
at
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.invoke(IgniteCacheOffheapManagerImpl.java:326)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry.innerUpdate(GridCacheMapEntry.java:1693)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateSingle(GridDhtAtomicCache.java:2386)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1792)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal(GridDhtAtomicCache.java:1630)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.sendSingleRequest(GridNearAtomicAbstractUpdateFuture.java:299)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFuture.map(GridNearAtomicSingleUpdateFuture.java:480)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFuture.mapOnTopology(GridNearAtomicSingleUpdateFuture.java:440)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.map(GridNearAtomicAbstractUpdateFuture.java:248)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.update0(GridDhtAtomicCache.java:1162)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.put0(GridDhtAtomicCache.java:651)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2345)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2322)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1519)
at
com.gm.srvr.TestCassandraPersistence.main(TestCassandraPersistence.java:42)
Caused by: class org.apache.ignite.IgniteException: Failed to prepare
Cassandra CQL statement: insert into "dev_keyspace"."HistoryResult"
("algorithmname", "sessionid", "key", "analysistime", "createdby",
"createddate", "modifiedby", "modifieddate", "results", "sessiontime")
values (?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.prepareStatement(CassandraSessionImpl.java:620)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:137)
... 25 more
Caused by: com.datastax.driver.core.exceptions.InvalidQueryException:
Unknown identifier algorithmname
at
com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)
at
com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at
com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:98)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.prepareStatement(CassandraSessionImpl.java:602)
... 26 more
Caused by: com.datastax.driver.core.exceptions.InvalidQueryException:
Unknown identifier algorithmname
at
com.datastax.driver.core.Responses$Error.asException(Responses.java:136)
at
com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:220)
at
com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:196)
at
com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTransform(Futures.java:1442)
at
com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTransform(Futures.java:1433)
at
com.google.common.util.concurrent.Futures$AbstractChainingFuture.run(Futures.java:1408)
at
com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:456)
at
com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:817)
at
com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:753)
at
com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:613)
at
com.datastax.driver.core.Connection$Future.onSet(Connection.java:1174)
at
com.datastax.driver.core.Connection$Future.onSet(Connection.java:1168)
at
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:184)
at
com.datastax.driver.core.RequestHandler.access$2500(RequestHandler.java:43)
at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:798)
at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:617)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1005)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:928)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
at java.lang.Thread.run(Thread.java:745)
[07:21:33] Ignite node stopped OK [uptime=00:00:12:285]
Exception in thread "main" javax.cache.integration.CacheWriterException:
class
org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException:
Failed to update keys (retry update if possible).: [HistoryResultKey = [key:
key1, sessionId: sessionId1, algorithmName: algoName2]]
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1404)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.cacheException(IgniteCacheProxy.java:2641)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1526)
at
com.gm.srvr.TestCassandraPersistence.main(TestCassandraPersistence.java:42)
Caused by: class
org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException:
Failed to update keys (retry update if possible).: [HistoryResultKey = [key:
key1, sessionId: sessionId1, algorithmName: algoName2]]
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.onPrimaryError(GridNearAtomicAbstractUpdateFuture.java:397)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFuture.onPrimaryResponse(GridNearAtomicSingleUpdateFuture.java:250)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture$1.apply(GridNearAtomicAbstractUpdateFuture.java:303)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture$1.apply(GridNearAtomicAbstractUpdateFuture.java:300)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicAbstractUpdateFuture.map(GridDhtAtomicAbstractUpdateFuture.java:366)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1900)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal(GridDhtAtomicCache.java:1630)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.sendSingleRequest(GridNearAtomicAbstractUpdateFuture.java:299)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFuture.map(GridNearAtomicSingleUpdateFuture.java:480)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateFuture.mapOnTopology(GridNearAtomicSingleUpdateFuture.java:440)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.map(GridNearAtomicAbstractUpdateFuture.java:248)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.update0(GridDhtAtomicCache.java:1162)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.put0(GridDhtAtomicCache.java:651)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2345)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2322)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1519)
... 1 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
update keys.
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.UpdateErrors.addFailedKey(UpdateErrors.java:108)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateResponse.addFailedKey(GridNearAtomicUpdateResponse.java:329)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateSingle(GridDhtAtomicCache.java:2521)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1792)
... 11 more
Suppressed: class org.apache.ignite.IgniteCheckedException:
Runtime
failure on search row:
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl$SearchRow@36bed37a
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree.invoke(BPlusTree.java:1612)
at
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl$CacheDataStoreImpl.invoke(IgniteCacheOffheapManagerImpl.java:925)
at
org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.invoke(IgniteCacheOffheapManagerImpl.java:326)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry.innerUpdate(GridCacheMapEntry.java:1693)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateSingle(GridDhtAtomicCache.java:2386)
... 12 more
Caused by: class org.apache.ignite.IgniteCheckedException: class
org.apache.ignite.IgniteException: Failed to execute Cassandra CQL
statement: insert into "dev_keyspace"."HistoryResult" ("algorithmname",
"sessionid", "key", "analysistime", "createdby", "createddate",
"modifiedby", "modifieddate", "results", "sessiontime") values
(?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.put(GridCacheStoreManagerAdapter.java:579)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.update(GridCacheMapEntry.java:4404)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.call(GridCacheMapEntry.java:4226)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry$AtomicCacheUpdateClosure.call(GridCacheMapEntry.java:3966)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree$Invoke.invokeClosure(BPlusTree.java:2966)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree$Invoke.access$6200(BPlusTree.java:2860)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree.invokeDown(BPlusTree.java:1696)
at
org.apache.ignite.internal.processors.cache.database.tree.BPlusTree.invoke(BPlusTree.java:1585)
... 16 more
Caused by: javax.cache.integration.CacheWriterException: class
org.apache.ignite.IgniteException: Failed to execute Cassandra CQL
statement: insert into "dev_keyspace"."HistoryResult" ("algorithmname",
"sessionid", "key", "analysistime", "createdby", "createddate",
"modifiedby", "modifieddate", "results", "sessiontime") values
(?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
... 24 more
Caused by: class org.apache.ignite.IgniteException: Failed to
execute
Cassandra CQL statement: insert into "dev_keyspace"."HistoryResult"
("algorithmname", "sessionid", "key", "analysistime", "createdby",
"createddate", "modifiedby", "modifieddate", "results", "sessiontime")
values (?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:185)
at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.write(CassandraCacheStore.java:276)
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.put(GridCacheStoreManagerAdapter.java:568)
... 23 more
Caused by: class org.apache.ignite.IgniteException: Failed to
execute
Cassandra CQL statement: insert into "dev_keyspace"."HistoryResult"
("algorithmname", "sessionid", "key", "analysistime", "createdby",
"createddate", "modifiedby", "modifieddate", "results", "sessiontime")
values (?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:167)
... 25 more
Caused by: class org.apache.ignite.IgniteException: Failed to
prepare
Cassandra CQL statement: insert into "dev_keyspace"."HistoryResult"
("algorithmname", "sessionid", "key", "analysistime", "createdby",
"createddate", "modifiedby", "modifieddate", "results", "sessiontime")
values (?,?,?,?,?,?,?,?,?,?) using ttl 2592000;
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.prepareStatement(CassandraSessionImpl.java:620)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:137)
... 25 more
Caused by:
com.datastax.driver.core.exceptions.InvalidQueryException:
Unknown identifier algorithmname
at
com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)
at
com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at
com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:98)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.prepareStatement(CassandraSessionImpl.java:602)
... 26 more
Caused by:
com.datastax.driver.core.exceptions.InvalidQueryException:
Unknown identifier algorithmname
at
com.datastax.driver.core.Responses$Error.asException(Responses.java:136)
at
com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:220)
at
com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:196)
at
com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTransform(Futures.java:1442)
at
com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTransform(Futures.java:1433)
at
com.google.common.util.concurrent.Futures$AbstractChainingFuture.run(Futures.java:1408)
at
com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:456)
at
com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:817)
at
com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:753)
at
com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:613)
at
com.datastax.driver.core.Connection$Future.onSet(Connection.java:1174)
at
com.datastax.driver.core.Connection$Future.onSet(Connection.java:1168)
at
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:184)
at
com.datastax.driver.core.RequestHandler.access$2500(RequestHandler.java:43)
at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:798)
at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:617)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1005)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:928)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
at java.lang.Thread.run(Thread.java:745)
Disconnected from the target VM, address: '127.0.0.1:39960', transport:
'socket'
Process finished with exit code 1
HistoryResult Class
public class HistoryResult {
@QuerySqlField
private String key;
@QuerySqlField(name = "session_id")
private String sessionId;
@QuerySqlField(name = "session_time")
private Date sessionTime;
@QuerySqlField(name = "algorithm_name")
private String algorithmName;
@QueryTextField
private String results;
@QuerySqlField(name = "analysis_time")
private Date analysisTime;
@QuerySqlField(name = "created_dt")
private Date createdDate;
@QuerySqlField(name = "created_by")
private String createdBy;
@QuerySqlField(name = "modified_dt")
private Date modifiedDate;
@QuerySqlField(name = "modified_by")
private String modifiedBy;
...
HistoryResultKey Class
public class HistoryResultKey {
@AffinityKeyMapped
@QuerySqlField(index = true, groups = { "historyResultPK" })
private String key;
@QuerySqlField(index = true, groups = { "historyResultPK" }, name =
"session_id")
private String sessionId;
@QuerySqlField(index = true, groups = { "historyResultPK" }, name =
"algorithm_name")
private String algorithmName;
...
Persistence Settings [DOES NOT WORK]
<persistence keyspace="dev_keyspace" table="HistoryResult" ttl="2592000">
<tableOptions>
comment = 'Test table for Ignite/Cassandra connection'
AND read_repair_chance = 0.2
</tableOptions>
<keyPersistence class="com.model.HistoryResultKey" strategy="POJO" />
<valuePersistence class="com.model.HistoryResult" strategy="POJO" />
</persistence>
Persistence Settings [DOES WORK]
<persistence keyspace="dev_keyspace" table="HistoryResult" ttl="2592000">
<tableOptions>
comment = 'Test table for Ignite/Cassandra connection'
AND read_repair_chance = 0.2
</tableOptions>
<keyPersistence class="com.model.HistoryResultKey" strategy="POJO">
<partitionKey>
<field name="key"/>
</partitionKey>
<clusterKey>
<field name="sessionId" column="session_id"/>
<field name="algorithmName" column="algorithm_name"/>
</clusterKey>
</keyPersistence>
<valuePersistence class="com.model.HistoryResult" strategy="POJO">
<field name="key"/>
<field name="sessionId" column="session_id"/>
<field name="sessionTime" column="session_time"/>
<field name="algorithmName" column="algorithm_name"/>
<field name="results"/>
<field name="analysisTime" column="analysis_time"/>
<field name="createdDate" column="created_dt"/>
<field name="createdBy" column="created_by"/>
<field name="modifiedDate" column="modified_dt"/>
<field name="modifiedBy" column="modified_by"/>
</valuePersistence>
</persistence>
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Ignite-to-Cassandra-change-from-1-9-to-2-0-tp13099p13422.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
