2012-05-07 18 views
1

Cassandra 1.1の一部のCFでローキャッシングを有効にしようとしています。cassandra 1.1でキャッシュ容量を設定できません。

UPDATE COLUMN FAMILY Users WITH rows_cached=2000 AND row_cache_provider='SerializingCacheProvider'; 

私はCLIでコマンド上で実行した場合、それはその後、私はnodetool setcachecapacity nodetool -h cssa01-04 setcachecapacity keyspace1ユーザー200000 2000

それの別のアプローチを試みたエラーに

java.lang.IllegalArgumentException: No enum const class org.apache.cassandra.cli.CliClient$ColumnFamilyArgument.ROWS_CACHED 

を与えますエラーを出す

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) 

xこれ?

おかげ マニッシュ

答えて

3

Cassandra 1.1では、個々の列ファミリのキャッシュ容量を設定する必要がなくなりました。代わりに、caching = rows_onlyだけでなく、cassandra.yamlの合計キャッシュサイズを設定してください。

詳細はhttp://www.datastax.com/dev/blog/caching-in-cassandra-1-1を参照してください。私はここカサンドラ-1.1のキャッシュを有効にする方法を説明してきた

+0

おかげJonethanをreply.Questionのための私のmind.Ifのユーザーには、私たちが使用可能に非常に小さいdata.Ifを持って熱いのCF用の行キャッシュを有効にしますグローバル・ロー・キャッシュを使用すると、他のCFからのデータがメモリに格納され、結果が平均になります。 ...そうなら、その場合何をすべきか? –

+1

CQLを使用してCFを更新する方法を明確にするために、ALTER TABLE Users WITH caching = 'rows_only'; –

0

私はカサンドラのコードに十分慣れていないんだけど、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(); 
    } 
関連する問題