无法在 cassandra 1.1 中设置缓存容量答案

【问题标题】：Unable to set cache capacity in cassandra 1.1无法在 cassandra 1.1 中设置缓存容量
【发布时间】：2012-05-24 14:00:39
【问题描述】：

我正在尝试为 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

然后我尝试了nodetool setcachecapacity的另一种方法 nodetool -h cssa01-04 setcachecapacity keyspace1 用户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)

知道如何解决这个问题吗？

谢谢马尼什

【问题讨论】：

标签： cassandra

【解决方案1】：

在 Cassandra 1.1 中，您不再需要在各个列族上设置缓存容量。相反，只需在 cassandra.yaml 中设置缓存=rows_only 以及总缓存大小。

【讨论】：

感谢 Jonethan 的回复。我心中的问题。如果用户想为数据非常少的热 CF 启用行缓存。如果我们启用全局行缓存，那么来自其他 CF 的数据将在内存中导致磨损结果。我说得对吗？ ...如果是，在这种情况下应该怎么做？
阐明如何通过 CQL 更新 CF：ALTER TABLE Users WITH caching='rows_only';

【解决方案2】：

我对 Cassandra 的代码不够熟悉，但是 CLHM 的前提是容量不能为负数。高温

  /**
   * 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();
    }

【讨论】：

【解决方案3】：

我在这里描述了如何为 Cassandra-1.1 启用缓存：Caching in Cassandra-1.1

【讨论】：