ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kenan Dalley <kenan.dal...@gm.com>
Subject Re: Ignite to Cassandra change from 1.9 to 2.0
Date Tue, 06 Jun 2017 14:39:18 GMT
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.

Mime
View raw message