CancellationException after cleanEmbeddedCassandra()

[Reik Schatz]

I am using cassandra-unit 1.1.1.2 against Cassandra 1.1.1. Has anyone seen the Exception below after calling EmbeddedCassandraServerHelper.cleanEmbeddedCassandra() in a @AfterClass annotated method? It does not affect my test just looks a bit ugly in the log. I was wondering how to do a proper shutdown.

INFO  CassandraDaemon - Stop listening to thrift clients

INFO  Gossiper - Announcing shutdown

DEBUG DebuggableThreadPoolExecutor - Task cancelled

java.util.concurrent.CancellationException

at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:250)

at java.util.concurrent.FutureTask.get(FutureTask.java:111)

at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor.extractThrowable(DebuggableThreadPoolExecutor.java:182)

at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor.logExceptionsAfterExecute(DebuggableThreadPoolExecutor.java:146)

at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor.afterExecute(DebuggableScheduledThreadPoolExecutor.java:50)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1118)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)

at java.lang.Thread.run(Thread.java:722)

INFO  MessagingService - Waiting for messaging service to quiesce

INFO  MessagingService - MessagingService shutting down server thread.

[Jérémy SEVELLEC]

Hi Reik,

You use cassandra in debug mode in your dev environnement?

It's seems to be a debug message of cassandra, so not sure it's really "important".

But anyway, do you have this stacktrace if try you call EmbeddedCassandraServerHelper.cleanEmbeddedCassandra() somewhere else?

Can you give us a test with the dataset to be able to reproduce?

Regards,

Jérémy

2012/11/2 Reik Schatz <reik....@gmail.com>

--
Jérémy