You must be using an old Cassandra and/or nodetool; current nodetool calls
forceBlockingFlush which does not try to return a Future over JMX.
On Wed, Apr 20, 2011 at 9:38 AM, Desimpel, Ignace
ignace.desim...@nuance.com wrote:
Using own JMX java code and when using the NodeTool I get the following
exception when calling the forceFlush function.
But it seems that the flushing itself is started although the exception
occurred.
Any idea?
(running jdk 1.6, 64 bits)
Ignace
2011-04-20 16:23:45 INFO ColumnFamilyStore - Enqueuing flush of
Memtable-ReverseIntegerValues@75939304(2274472 bytes, 48892 operations)
2011-04-20 16:23:45 INFO Memtable - Writing
Memtable-ReverseIntegerValues@75939304(2274472 bytes, 48892 operations)
java.rmi.UnmarshalException: error unmarshalling return; nested exception
is:
java.io.WriteAbortedException: writing aborted;
java.io.NotSerializableException: java.util.concurrent.FutureTask
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:173)
at com.sun.jmx.remote.internal.PRef.invoke(Unknown Source)
at javax.management.remote.rmi.RMIConnectionImpl_Stub.invoke(Unknown
Source)
at
javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection.invoke(RMIConnector.java:993)
at
javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:288)
at $Proxy7.forceFlush(Unknown Source)
at
be.landc.services.search.server.db.indexsearch.store.cassandra.CassandraStore$CassNodeProbe.doRepairAll(CassandraStore.java:160)
at
be.landc.services.search.server.db.indexsearch.store.cassandra.CassandraStore$CassNodeProbe.run(CassandraStore.java:141)
Caused by: java.io.WriteAbortedException: writing aborted;
java.io.NotSerializableException: java.util.concurrent.FutureTask
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1332)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
at sun.rmi.server.UnicastRef.unmarshalValue(UnicastRef.java:306)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:155)
... 7 more
Caused by: java.io.NotSerializableException: java.util.concurrent.FutureTask
at
java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1164)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:330)
at sun.rmi.server.UnicastRef.marshalValue(UnicastRef.java:274)
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:315)
at sun.rmi.transport.Transport$1.run(Transport.java:159)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
at
sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
at
sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
at
sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
2011-04-20 16:23:45 INFO SearchServer - == Starting flush for column
family : SearchSpace / ForwardLongValues
2011-04-20 16:23:45 INFO ColumnFamilyStore - Enqueuing flush of
Memtable-ForwardLongValues@710396564(26780468 bytes, 623958 operations)
--
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of DataStax, the source for professional Cassandra support
http://www.datastax.com
