我正在尝试为Cassandra 1.1中的一些CF启用行缓存。
UPDATE COLUMN FAMILY Users WITH rows_cached=2000 AND row_cache_provider='SerializingCacheProvider';
如果我在CLI中运行上述命令,则会出现错误
java.lang.IllegalArgumentException: No enum const class org.apache.cassandra.cli.CliClient$ColumnFamilyArgument.ROWS_CACHED
然后我尝试了另一种方法节点工具设置缓存容量节点工具cssa01-04 setcachecapacity keyspace1 -h 200000 2000
它会给出一个错误
Exception in thread "main" java.lang.IllegalArgumentException
at com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap.setCapacity(ConcurrentLinkedHashMap.java:291)
at org.apache.cassandra.cache.ConcurrentLinkedHashCache.setCapacity(ConcurrentLinkedHashCache.java:87)
at org.apache.cassandra.cache.InstrumentingCache.updateCapacity(InstrumentingCache.java:79)
at org.apache.cassandra.cache.InstrumentingCache.setCapacity(InstrumentingCache.java:84)
at org.apache.cassandra.service.CacheService.setKeyCacheCapacityInMB(CacheService.java:243)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:93)
at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:27)
at com.sun.jmx.mbeanserver.MBeanIntrospector.invokeSetter(MBeanIntrospector.java:238)
at com.sun.jmx.mbeanserver.PerInterface.setAttribute(PerInterface.java:84)
at com.sun.jmx.mbeanserver.MBeanSupport.setAttribute(MBeanSupport.java:240)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.setAttribute(DefaultMBeanServerInterceptor.java:762)
at com.sun.jmx.mbeanserver.JmxMBeanServer.setAttribute(JmxMBeanServer.java:699)
at javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1450)
at javax.management.remote.rmi.RMIConnectionImpl.access$200(RMIConnectionImpl.java:72)
at javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1265)
at javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1360)
at javax.management.remote.rmi.RMIConnectionImpl.setAttribute(RMIConnectionImpl.java:683)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:305)
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)
你知道怎么解决这个问题吗?
谢谢Manish
发布于 2012-05-09 11:26:33
在Cassandra 1.1中,您不再需要在单个列族上设置缓存容量。相反,只需在cassandra.yaml中设置caching=rows_only和总缓存大小即可。
有关更多详细信息,请参阅http://www.datastax.com/dev/blog/caching-in-cassandra-1-1。
发布于 2012-05-08 10:35:14
我对Cassandra的代码不够熟悉,但CLHM的前提是容量不能为负。HTH
/**
* Sets the maximum weighted capacity of the map and eagerly evicts entries
* until it shrinks to the appropriate size.
*
* @param capacity the maximum weighted capacity of the map
* @throws IllegalArgumentException if the capacity is negative
*/
public void setCapacity(long capacity) {
if (capacity < 0) {
throw new IllegalArgumentException();
}
发布于 2012-05-24 14:00:39
我已经在这里描述了如何为Cassandra-1.1启用缓存:Caching in Cassandra-1.1
https://stackoverflow.com/questions/10481529
复制相似问题