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 Wed, 24 May 2017 13:53:46 GMT
I upgraded from Ignite 1.9 to Ignite 2.0 and this started happening.  The
stacktrace is below.  Also, I'm including the .sh script that I'm running so
you can see that the only difference between the executions is pointing to
v1.9 versus pointing to v2.0.  My code didn't change, but it fails in 2.0
and works in 1.9.  You'll find the "main" execution code at the bottom.


.sh

#export IGNITE_HOME=/app/ignite/apache-ignite-fabric-1.9.0-bin
export IGNITE_HOME=/app/ignite/apache-ignite-fabric-2.0.0-bin
export IGNITE_HOME_LIBS=${IGNITE_HOME}/libs
export
IGNITE_LIBS=${IGNITE_HOME_LIBS}/*:${IGNITE_HOME_LIBS}/ignite-spring/*:${IGNITE_HOME_LIBS}/ignite-indexing/*:${IGNITE_HOME_LIBS}/ignite-cassandra-store/*:${IGNITE_HOME_LIBS}/ignite-cassandra-serializers/*

java -cp iat2Kafka-0.0.1.jar:conf:libs/*:${IGNITE_LIBS}
com.test.TestCassandraPersistence &


Execution/StackTrace

[user1@host001 app1]$ ./run.sh
[user1@host001 app1]$ [09:43:25]    __________  ________________
[09:43:25]   /  _/ ___/ |/ /  _/_  __/ __/
[09:43:25]  _/ // (7 7    // /  / / / _/
[09:43:25] /___/\___/_/|_/___/ /_/ /___/
[09:43:25]
[09:43:25] ver. 2.0.0#20170430-sha1:d4eef3c6
[09:43:25] 2017 Copyright(C) Apache Software Foundation
[09:43:25]
[09:43:25] Ignite documentation: http://ignite.apache.org
[09:43:25]
[09:43:25] Quiet mode.
[09:43:25]   ^-- Logging to file
'/app/ignite/apache-ignite-fabric-2.0.0-bin/work/log/ignite-de853f44.0.log'
[09:43:25]   ^-- To see **FULL** console log here add -DIGNITE_QUIET=false
or "-v" to ignite.{sh|bat}
[09:43:25]
[09:43:25] OS: Linux 2.6.32-696.el6.x86_64 amd64
[09:43:25] VM information: Java(TM) SE Runtime Environment 1.8.0_131-b11
Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.131-b11
[09:43:25] Configured plugins:
[09:43:25]   ^-- None
[09:43:25]
[09:43:25] Message queue limit is set to 0 which may lead to potential OOMEs
when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes due to
message queues growth on sender and receiver sides.
[09:43:25] Security status [authentication=off, tls/ssl=off]
log4j:WARN No appenders could be found for logger
(org.springframework.beans.factory.support.DefaultListableBeanFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
[09:43:27] Performance suggestions for grid  (fix if possible)
[09:43:27] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
[09:43:27]   ^-- Enable G1 Garbage Collector (add '-XX:+UseG1GC' to JVM
options)
[09:43:27]   ^-- Specify JVM heap max size (add '-Xmx<size>[g|G|m|M|k|K]' to
JVM options)
[09:43:27]   ^-- Set max direct memory size if getting 'OOME: Direct buffer
memory' (add '-XX:MaxDirectMemorySize=<size>[g|G|m|M|k|K]' to JVM options)
[09:43:27]   ^-- Disable processing of calls to System.gc() (add
'-XX:+DisableExplicitGC' to JVM options)
[09:43:27]   ^-- Speed up flushing of dirty pages by OS (alter
vm.dirty_expire_centisecs parameter by setting to 500)
[09:43:27]   ^-- Reduce pages swapping ratio (set vm.swappiness=10)
[09:43:27]   ^-- Avoid direct reclaim and page allocation failures (set
vm.extra_free_kbytes=1240000)
[09:43:27]   ^-- Enable write-behind to persistent store (set
'writeBehindEnabled' to true)
[09:43:27] Refer to this page for more performance suggestions:
https://apacheignite.readme.io/docs/jvm-and-system-tuning
[09:43:27]
[09:43:27] To start Console Management & Monitoring run
ignitevisorcmd.{sh|bat}
[09:43:27]
[09:43:27] Ignite node started OK (id=de853f44)
[09:43:27] Topology snapshot [ver=1, servers=1, clients=0, CPUs=144,
heap=27.0GB]

>>> Cache store example started.
>>> Putting to C*.  Key: [HistoryResultKey = [key: key1, sessionId:
>>> sessionId1, algorithmName: algoName2]], Result: [HistoryResult = [key:
>>> key1, sessionId: sessionId1, sessionTime: 2017-05-24 09:43:27.292,
>>> algorithmName: algoName2, results: results-2017-05-24T09:43:27.298,
>>> analysisTime: 2017-05-24 09:43:27.298, createdDate: 2017-05-24
>>> 09:43:27.298, createdBy: creator, modifiedDate: 2017-05-24 09:43:27.298,
>>> modifiedBy: updater]]
[09:43:38,214][SEVERE][main][CassandraCacheStore] Failed to execute
Cassandra CQL statement: insert into "dev_qlty"."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_qlty"."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:41)
Caused by: class org.apache.ignite.IgniteException: Failed to prepare
Cassandra CQL statement: insert into "dev_qlty"."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:748)
[09:43:38] Ignite node stopped OK [uptime=00:00:10:979]
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:41)
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@72fe8a4f
                        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_qlty"."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_qlty"."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_qlty"."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_qlty"."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_qlty"."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:748)


Run Code

public class TestCassandraPersistence {
	/** Cache name. */
	private static final String CACHE_NAME =
HistoryResult.class.getSimpleName();

	/** Global HistoryResultKey to use across entire example. */
	private static HistoryResultKey key = new HistoryResultKey("key1",
"sessionId1", "algoName2");

	public static void main(final String[] args) {
		try (Ignite ignite = Ignition.start("conf/cassandra-ignite.xml")) {
			System.out.println(StringUtils.EMPTY);
			System.out.println(">>> Cache store example started.");

			try (IgniteCache<HistoryResultKey, HistoryResult> cache = ignite
					.getOrCreateCache(new CacheConfiguration<HistoryResultKey,
HistoryResult>(
							TestCassandraPersistence.CACHE_NAME))) {

				// Write to C*
				final HistoryResult result = TestCassandraPersistence
						.generateHistoryResultFromKey(TestCassandraPersistence.key);
				System.out.println(String.format(">>> Putting to C*.  Key: [%s], Result:
[%s]",
						TestCassandraPersistence.key, result));
				cache.put(TestCassandraPersistence.key, result);

				// Clear cache
				System.out.println(StringUtils.EMPTY);
				System.out.println(">>> Clearing cache...");
				cache.clear(TestCassandraPersistence.key);

				// Read from C*
				System.out.println(StringUtils.EMPTY);
				System.out.println(">>> Cache retrieve example started.");
				final HistoryResult result2 = cache.get(TestCassandraPersistence.key);
				System.out.println(String.format(">>> Read from C*.  Key: [%s], Result:
[%s]",
						TestCassandraPersistence.key, result2));
			}
			System.out.println(StringUtils.EMPTY);
		}
	}

	private static HistoryResult generateHistoryResultFromKey(final
HistoryResultKey key) {
		HistoryResult result = null;
		if (key != null) {
			result = new HistoryResult(key.getkey(), key.getSessionId(),
Timestamp.valueOf(LocalDateTime.now()),
					key.getAlgorithmName(), "results-" + LocalDateTime.now(),
Timestamp.valueOf(LocalDateTime.now()),
					Timestamp.valueOf(LocalDateTime.now()), "creator",
Timestamp.valueOf(LocalDateTime.now()),
					"updater");
		}
		return result;
	}
}




--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-to-Cassandra-change-from-1-9-to-2-0-tp13099p13112.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Mime
View raw message