Re: java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
i use a 64 bit machine and gave 6gigs ram it runs on native fedora no vm On Sun, Nov 29, 2009 at 4:22 AM, Mark Robson mar...@gmail.com wrote: 2009/11/28 mobiledream...@gmail.com thanks i dont have more than 1 node ie just one node operation so dunno if the timeout increase will help Presumably this is a test system on a vmware; it may have insufficient memory. I'd say make sure that your test virtual machine (vmware etc) has at least 1.5G of ram allocated and the Java VM is tuned suitably. Don't run on a 32-bit system as this limits the size of the Java heap too small. I'm speculating here, but you didn't give us much to work on. A production Cassandra node should have at least 16G of ram as it's really cheap. Ram doesn't use much power and power is the main consideration for datacentres nowadays. A 64-bit system is necessary as otherwise you'll be limited to a 3G Java heap, which makes having 16G ram pointless. Mark -- Bidegg worlds best auction site http://bidegg.com
at org.apache.cassandra.utils.Cachetable$CacheMonitor.run(Cachetable.java:70)
New error in cassandra - cachetable-timer anyone encounter this thanks at org.apache.cassandra.service.CassandraServer.getSlice(CassandraServer.java:177) at org.apache.cassandra.service.CassandraServer.multigetSliceInternal(CassandraServer.java:252) at org.apache.cassandra.service.CassandraServer.get_slice(CassandraServer.java:215) at org.apache.cassandra.service.Cassandra$Processor$get_slice.process(Cassandra.java:668) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:624) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) ERROR - Fatal exception in thread Thread[CACHETABLE-TIMER-1,5,main] java.lang.OutOfMemoryError: Java heap space at java.util.HashMap.init(HashMap.java:227) at org.apache.cassandra.utils.Cachetable$CacheMonitor.run(Cachetable.java:70) at java.util.TimerThread.mainLoop(Timer.java:512) at java.util.TimerThread.run(Timer.java:462)
Re: java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
thanks i dont have more than 1 node ie just one node operation so dunno if the timeout increase will help but trying it out On Wed, Nov 25, 2009 at 11:16 AM, Freeman, Tim tim.free...@hp.com wrote: I use RpcTimeoutInMillis3/RpcTimeoutInMillis in storage-conf.xml, and for the most part that makes the timeouts go away. My application would rather wait 30 seconds if needed, since it would otherwise retry. YMMV. I hear that Cassandra 0.5 will be better at avoiding the timeouts. Tim Freeman Email: tim.free...@hp.com Desk in Palo Alto: (650) 857-2581 Home: (408) 774-1298 Cell: (408) 348-7536 (No reception business hours Monday, Tuesday, and Thursday; call my desk instead.) *From:* mobiledream...@gmail.com [mailto:mobiledream...@gmail.com] *Sent:* Monday, November 23, 2009 12:26 PM *To:* cassandra-user@incubator.apache.org *Subject:* Re: java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from . this error keeps coming up... any ideas on how to avoid this error? On Wed, Nov 18, 2009 at 11:25 PM, mobiledream...@gmail.com wrote: Can you plase tell what this error is ? ERROR - error writing key ruske *java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .* at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) Errors -- Bidegg worlds best auction site http://bidegg.com -- Bidegg worlds best auction site http://bidegg.com
why do we need the jvm opts ea and Xdebug
JVM_OPTS= \ -ea \ -Xdebug \ Doesnt enable assertions really slow down cassandra
Re: java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
this error keeps coming up... any ideas on how to avoid this error? On Wed, Nov 18, 2009 at 11:25 PM, mobiledream...@gmail.com wrote: Can you plase tell what this error is ? ERROR - error writing key ruske *java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .* at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) Errors -- Bidegg worlds best auction site http://bidegg.com
Re: java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
can you share code on how to split columns in cassdict or batch_insert? thanks On Thu, Nov 19, 2009 at 8:15 AM, Tim Underwood timunderw...@gmail.comwrote: I've seen also. Sometimes it seems random and retrying the call works (I think it might have happened during a compaction). If I try doing a batch_insert on a key with more than 200,000 columns (or so) I always get this exception and have to break the inserts into smaller chunks. -Tim On Wed, Nov 18, 2009 at 11:25 PM, mobiledream...@gmail.com wrote: Can you plase tell what this error is ? ERROR - error writing key ruske *java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .* at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) Errors -- Bidegg worlds best auction site http://bidegg.com
Nov 19 12:28:33 server kernel: possible SYN flooding on port 9160. Sending cookies.
I am getting a syn flooding warning - is this something that anyone else has encountered tail -f /var/log/messages Nov 19 12:28:33 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:29:34 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:30:45 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:31:45 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:32:56 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:34:00 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:35:01 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:36:28 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:37:28 server kernel: possible SYN flooding on port 9160. Sending cookies. Nov 19 12:45:31 server kernel: possible SYN flooding on port 9160. Sending cookies.
Re: java.lang.OutOfMemoryError: unable to create new native thread
yes fedora core 11 any ideas on how to alleviate this issue the conf params are really low too! MemtableSizeInMB32/MemtableSizeInMB !-- ~ The maximum number of columns in millions to store in memory per ~ ColumnFamily before flushing to disk. This is also a per-memtable ~ setting. Use with MemtableSizeInMB to tune memory usage. -- MemtableObjectCountInMillions0.001/MemtableObjectCountInMillions On Tue, Nov 17, 2009 at 11:54 PM, Mark Robson mar...@gmail.com wrote: On Tue, Nov 17, 2009 at 5:01 PM, mobiledream...@gmail.com wrote: I keep getting the error java.lang.OutOfMemoryError: unable to create new native thread Perhaps it's run out of address-space. You are running a 64-bit OS, right? Mark
ERROR [pool-1-thread-373] 2009-11-18 18:04:06,431 StorageProxy.java (line 179) error writing key camaras
*Got a new error from cassandra Operation timed out! Please let me know if this a normal error and how to fix this thanks java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .* at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) *ERROR [pool-1-thread-373] 2009-11-18 18:04:06,431 StorageProxy.java (line 179) error writing key camaras * java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from . at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619)
java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .
Can you plase tell what this error is ? ERROR - error writing key ruske *java.util.concurrent.TimeoutException: Operation timed out - received only 0 responses from .* at org.apache.cassandra.service.QuorumResponseHandler.get(QuorumResponseHandler.java:88) at org.apache.cassandra.service.StorageProxy.insertBlocking(StorageProxy.java:164) at org.apache.cassandra.service.CassandraServer.doInsert(CassandraServer.java:468) at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:448) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:854) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:627) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) Errors
is it possible to do batch_insert using cassandra cassdict?
This is what we need for batch_insert in cassdict but such dictionary
hierarchy works only up to super column level. Any thoughts on how to do
batch_insert or multiple insert in cassdict
Thanks
c =dict(myRow= dict(Supern1= dict(super_column_name= dict(d=3,f=4
*
*
*
insert multiple cols from higher up the hierarchy
c['rowB']['stdcol'] = { 'colA' : 'rowB colA value' , 'colB' : 'rowB
colB value'}
*
c['myRow']['Supern1'] = dict(super_column_name= dict(d=3,f=4))
*In [15]: c['myRow'] = dict(Supern1= dict(super_column_name= dict(d=3,f=4)))
*
---
NotImplementedError Traceback (most recent call last)
/cassdict/cass.pyc in __setitem__(self, key, value, internal)
384 if not internal:
385 #implemented in subclasses
-- 386 raise NotImplementedError
387 return super(Cassdict,self).__setitem__(key,value)
388
NotImplementedError:
In [16]:
Re: TypeError: batch_insert() takes exactly 4 arguments (5 given)
*Latest cassandra causing these problems*? /usr/lib/python2.6/site-packages/Thrift-0.1-py2.6-linux-i686.egg/thrift/Thrift.py:58: DeprecationWarning: BaseException.message has been deprecated as of Python 2.6 /usr/lib/python2.6/site-packages/Thrift-0.1-py2.6-linux-i686.egg/thrift/Thrift.py:99: DeprecationWarning: BaseException.message has been deprecated as of Python 2.6 /home/mark/work/common/lazyboy/connection.py:101: DeprecationWarning: BaseException.message has been deprecated as of Python 2.6 if tx.message: /home/mark/work/common/lazyboy/connection.py:102: DeprecationWarning: BaseException.message has been deprecated as of Python 2.6 message = tx.message Traceback (most recent call last): File simplecass.py, line 8, in module x.save() File /home/mark/work/common/lazyboy/record.py, line 168, in save client.batch_insert(*self._get_batch_args(self.key, changed)) File /home/mark/work/common/lazyboy/connection.py, line 106, in func raise ErrorThriftMessage(message) lazyboy.exceptions.ErrorThriftMessage: Internal error processing batch_insert ERROR - Internal error processing batch_insert java.lang.NullPointerException at org.apache.cassandra.service.CassandraServer.batch_insert(CassandraServer.java:328) at org.apache.cassandra.service.Cassandra$Processor$batch_insert.process(Cassandra.java:691) at org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:560) at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:253) 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:619) On Tue, Nov 3, 2009 at 2:59 PM, mobiledream...@gmail.com wrote: in this simple example http://pastie.org/682435 i got this error http://pastie.org/682436 Can you please clarify what is the bug this uses latest cassandra from git and latest lazyboy from git THanks -- Bidegg worlds best auction site http://bidegg.com
java.net.BindException: Cannot assign requested address
I get the following error when i try to start cassandra from the latest git. If it is very obvious on what is going wrong here, Please point out thanks bin/cassandra -f Listening for transport dt_socket at address: DEBUG - Loading settings from bin/../conf/storage-conf.xml DEBUG - Syncing log with a period of 1000 DEBUG - opening keyspace Keyspace1 DEBUG - adding Super1 as 0 DEBUG - adding Standard2 as 1 DEBUG - adding Standard1 as 2 DEBUG - adding StandardByUUID1 as 3 DEBUG - adding LocationInfo as 4 DEBUG - adding HintsColumnFamily as 5 DEBUG - opening keyspace system INFO - Saved Token not found. Using 169157697452904505324380333709918946833 ERROR - Exception encountered during startup. java.net.BindException: Cannot assign requested address at sun.nio.ch.Net.bind(Native Method) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:119) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52) at org.apache.cassandra.net.MessagingService.listen(MessagingService.java:235) at org.apache.cassandra.service.StorageService.start(StorageService.java:285) at org.apache.cassandra.service.CassandraServer.start(CassandraServer.java:73) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:94) at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:166) Exception encountered during startup. java.net.BindException: Cannot assign requested address at sun.nio.ch.Net.bind(Native Method) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:119) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52) at org.apache.cassandra.net.MessagingService.listen(MessagingService.java:235) at org.apache.cassandra.service.StorageService.start(StorageService.java:285) at org.apache.cassandra.service.CassandraServer.start(CassandraServer.java:73) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:94) at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:166)
TypeError: batch_insert() takes exactly 4 arguments (5 given)
in this simple example http://pastie.org/682435 i got this error http://pastie.org/682436 Can you please clarify what is the bug this uses latest cassandra from git and latest lazyboy from git THanks
Re: java.net.BindException: Cannot assign requested address
if i leave it empty i get the error if i give 0.0.0.0 it works On Tue, Nov 3, 2009 at 2:58 PM, Sammy Yu temi...@gmail.com wrote: Hi, I would check to see the ListenAddress in storage-conf.xml to see if it's an address that assigned to this machine. Cheers, Sammy On Tue, Nov 3, 2009 at 2:44 PM, mobiledream...@gmail.com wrote: I get the following error when i try to start cassandra from the latest git. If it is very obvious on what is going wrong here, Please point out thanks bin/cassandra -f Listening for transport dt_socket at address: DEBUG - Loading settings from bin/../conf/storage-conf.xml DEBUG - Syncing log with a period of 1000 DEBUG - opening keyspace Keyspace1 DEBUG - adding Super1 as 0 DEBUG - adding Standard2 as 1 DEBUG - adding Standard1 as 2 DEBUG - adding StandardByUUID1 as 3 DEBUG - adding LocationInfo as 4 DEBUG - adding HintsColumnFamily as 5 DEBUG - opening keyspace system INFO - Saved Token not found. Using 169157697452904505324380333709918946833 ERROR - Exception encountered during startup. java.net.BindException: Cannot assign requested address at sun.nio.ch.Net.bind(Native Method) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:119) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52) at org.apache.cassandra.net.MessagingService.listen(MessagingService.java:235) at org.apache.cassandra.service.StorageService.start(StorageService.java:285) at org.apache.cassandra.service.CassandraServer.start(CassandraServer.java:73) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:94) at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:166) Exception encountered during startup. java.net.BindException: Cannot assign requested address at sun.nio.ch.Net.bind(Native Method) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:119) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52) at org.apache.cassandra.net.MessagingService.listen(MessagingService.java:235) at org.apache.cassandra.service.StorageService.start(StorageService.java:285) at org.apache.cassandra.service.CassandraServer.start(CassandraServer.java:73) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:94) at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:166) -- Bidegg worlds best auction site http://bidegg.com
Re: TypeError: unhashable instance
wat is record-refactor branch of Lazyboy how do i get it ? On Wed, Aug 26, 2009 at 6:16 PM, i...@digg.com wrote: On Aug 26, 2009, at 5:42 PM, mobiledream...@gmail.com wrote: Resyncing to ian eure digg lazyboy - still not working same error persists Please try the record-refactor branch of Lazyboy. This will be merged to master and 0.6.0 should be out in a week or so. I haven't run the examples, but things are pretty much working for me. - Ian -- Bidegg worlds best auction site http://bidegg.com
Re: Newbe´s question
just running your example
python /tmp/columnfamily.py
{'table': 'Keyspace1', 'superkey': None, 'key':
'f8b29cc4193b42bc8a188615855cfa4e', 'family': 'Standard1', 'supercol': None}
{'username': 'ieure', 'email': 'i...@digg.com'}
True
Traceback (most recent call last):
File /tmp/columnfamily.py, line 65, in module
u.save() # - {'username': 'ieure', 'email': 'i...@digg.com'}
File /home/mark/work/common/lazyboy/columnfamily.py, line 127, in save
self.load(self.pk.key)
File /home/mark/work/common/lazyboy/columnfamily.py, line 92, in load
self._clean()
File /home/mark/work/common/lazyboy/columnfamily.py, line 46, in _clean
map(self.__delitem__, self.keys())
File /home/mark/work/common/lazyboy/columnfamily.py, line 86, in
__delitem__
self._deleted[self._columns[item]] = True
TypeError: unhashable instance
On Wed, Aug 26, 2009 at 6:11 PM, i...@digg.com wrote:
Don't call __hash__, there is no such method.
On Aug 26, 2009, at 5:39 PM, mobiledream...@gmail.com wrote:
any ideas on how 2 fix this?
Traceback (most recent call last):
File /tmp/a.py, line 3, in module
print cassandra.ttypes.Column().__hash__()
AttributeError: Column instance has no attribute '__hash__'
*
#!/usr/bin/python
import cassandra.ttypes
print cassandra.ttypes.Column().__hash__()
*
On Wed, Aug 26, 2009 at 5:13 PM, Evan Weaver ewea...@gmail.com
ewea...@gmail.com wrote:
Clients section in the README.txt seems best to me.
Evan
On Wed, Aug 26, 2009 at 5:09 PM, Ian Holsman i...@holsman.net
i...@holsman.net wrote:
isn't there a way to use svn:external or svn:link to pull them in from
their
own repos?
(not sure how legal it would be).
On Aug 27, 2009, at 10:03 AM, Jonathan Ellis wrote:
I thought about that, but I really don't want Cassandra committers to
have to be in the business of updating them all when we make changes,
and having them in the repo creates that expectation even in contrib.
On Wed, Aug 26, 2009 at 6:57 PM, Ian Holsman i...@holsman.net
i...@holsman.net wrote:
would it be worthwhile to start including these clients in the core
codebase? in some kind of 'client' or 'contrib' directory?
maybe even mentioning the 'popular' clients that people use in the
readme
(with links to them) would be good.
On Aug 27, 2009, at 9:18 AM, Sal Fuentes wrote:
Just would like to say great job so far.
On Wed, Aug 26, 2009 at 4:01 PM, Ian Eure i...@digg.com
i...@digg.com wrote:
On Aug 25, 2009, at 2:46 PM, Drew Schleck wrote:
For anyone using my branch of Lazyboy, Ian Eure pulled my work,
improved it, and more. You ought to switch back to his version.
I'm doing some heavy refactoring all this week, to bring it up to
Cassandra trunk and simplify/genericize it wherever possible. I
should
have
something to show in a day or two.
Feel free to contact me if you have questions or requests.
- Ian
--
Salvador Fuentes Jr.
323-540-4SAL
--
Ian Holsman
i...@holsman.neti...@holsman.net
--
Ian Holsman
i...@holsman.neti...@holsman.net
--
Evan Weaver
--
Bidegg worlds best auction site
http://bidegg.comhttp://bidegg.com
--
Bidegg worlds best auction site
http://bidegg.com
Re: MVCC
I always thought cassandra had free multiple versions and we needed to manually delete the older versions On Mon, Aug 3, 2009 at 8:56 AM, Jonathan Ellis jbel...@gmail.com wrote: On Mon, Aug 3, 2009 at 10:49 AM, Jun Raojun...@almaden.ibm.com wrote: Ivan, The original cassandra keeps multiple versions of the column data. No, it didn't. (It had versioning-related bugs but multiple versions a la Bigtable was never part of the design.) -Jonathan -- Bidegg worlds best auction site http://bidegg.com
ERROR - Fatal error: Unable to load class org.apache.cassandra.db.marshal.Name for CompareWith attribute
Hi Guys How do we fix this ? thanks bin/cassandra -f Listening for transport dt_socket at address: DEBUG - Loading settings from bin/../conf/storage-conf.xml ERROR - Fatal error: Unable to load class org.apache.cassandra.db.marshal.Name for CompareWith attribute Bad configuration; unable to start server
ERROR - Fatal error: ColumnSort is no longer an accepted attribute. Use CompareWith instead.
commit efc9b60686595c6a6107c865e7eaca7972edf5d0 using this commit * bin/cassandra -f Listening for transport dt_socket at address: DEBUG - Loading settings from bin/../conf/storage-conf.xml ERROR - Fatal error: ColumnSort is no longer an accepted attribute. Use CompareWith instead. Bad configuration; unable to start server * the same commit works in a different server, how do i debug this? commit efc9b60686595c6a6107c865e7eaca7972edf5d0 Author: Eric Evans eev...@apache.org Date: Tue Jul 21 17:40:35 2009 + add perl namespace to thrift interface Patch by Anthony Molinaro; reviewed by eevans for CASSANDRA-310 git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/tr...@79640
Re: ERROR - Fatal error: Unable to load class org.apache.cassandra.db.marshal.Name for CompareWith attribute
so what happened to ColumnSort param and jus recompiling the old cassandra code now generates this error - really odd On Sun, Aug 2, 2009 at 8:23 PM, Michael Greene michael.gre...@gmail.comwrote: That's the error that would be printed if you had CompareWith=Name set, which is invalid. Valid values for CompareWith are listed in the XML file, and are: AsciiType UTF8Type BytesType UUIDType LongType Michael On Sun, Aug 2, 2009 at 10:20 PM, Tom Melendez tom.melen...@gmail.comwrote: Is your configuration valid? xmllint storage-conf.xml Any changes to your configuration lately? Thanks, Tom On Sun, Aug 2, 2009 at 8:10 PM, mobiledream...@gmail.com wrote: Hi Guys How do we fix this ? thanks bin/cassandra -f Listening for transport dt_socket at address: DEBUG - Loading settings from bin/../conf/storage-conf.xml ERROR - Fatal error: Unable to load class org.apache.cassandra.db.marshal.Name for CompareWith attribute Bad configuration; unable to start server -- Bidegg worlds best auction site http://bidegg.com
does lazyboy allow keys or column names to be in utf8
*as you know by now plain cassandra does not take utf8 for column names or keys* does lazy boy let cassandra store column names or keys in ut8 using pickle.dumps or cpickle.dumps or some other method thanks
Re: lazy boy example using column family
1.Even though this is not the preferred way of using column families 2. and since the easy way of adding new column families has not yet been implemented Can you show me how to do super column families in cassandra lazyboy a simple eg., of storing a tag for a key so Super1:Tag:key - value is a list of tags thanks On Mon, Jul 27, 2009 at 12:38 AM, Mark Robson mar...@gmail.com wrote: 2009/7/27 mobiledream...@gmail.com i m trying to use cassandra in a mode where everytime i create a new columnfamily i do not want to restart all the nodes In my opinion you should not be doing that anyway. Because families can have as many columns as you like anyway, it should not normally be necessary to create new families. And when you do, it will probably be part of a major release that will have some impact on your infrastructure. You should define an operational procedure for restarting all the nodes for occasional use by ops engineers; they could choose to automate it. Restarting all nodes isn't that onerous provided it's not done too often. It's not going to take a few hours, even if you have quite a few. Mark -- Bidegg worlds best auction site http://bidegg.com
lazy boy example using column family
i m trying to use cassandra in a mode where everytime i create a new columnfamily i do not want to restart all the nodes a way to do this is to use super column family 1. i m also trying to figure out how to use super column families in cassandra using LAZYBOY 2. plain cassandra does not take utf8 for column names or keys does lazy boy let cassandra store column names or keys in ut8 using pickle.dumps or cpickle.dumps or some other method thanks
digg lazyboy - superfamily example
http://github.com/digg/lazyboy/blob/9fb89977c479b03159a868524a99e465e5d072e8/examples/columnfamily.py thanks for the column family example, i m trying to use super column family in lazy boy is it possible to add a simple example for using supercolumns
Fwd: what is mosso?
does cassandra run on mosso? -- Forwarded message -- From: mobiledream...@gmail.com Date: Thu, Jul 23, 2009 at 10:29 AM Subject: what is mosso? To: Jonathan Ellis jbel...@gmail.com What is mosso and what does rackspace use cassandra for? -- Bidegg worlds best auction site http://bidegg.com
Re: keys and column names cannot be utf-8
Still gives error - x.search and x.related are unicode words and when they
are used as key or column name the following erros come up
x.search
Out[5]: u'\ucd5c\uc9c4\uc2e4 \uc774\ud63c'
In [6]: x.related
Out[6]: u'\ucd5c\uc9c4\uc2e4 \uc774\ud63c'
In [7]: client.insert('Table1', x.search, ColumnPath('Super1', 'Related',
x.related), pickle.dumps(dict(count=1)), time.time(), 0)
ERROR: An unexpected error occurred while tokenizing input
The following traceback may be corrupted or invalid
The error message is: ('EOF in multi-line statement', (1149, 0))
---
TApplicationException Traceback (most recent call last)
/home/mark/ipython console in module()
/home/mark/work/common/cassandra/Cassandra.pyc in insert(self, table, key,
column_path, value, timestamp, block_for)
359
360 self.send_insert(table, key, column_path, value, timestamp,
block_for)
-- 361 self.recv_insert()
362
363 def send_insert(self, table, key, column_path, value, timestamp,
block_for):
/home/mark/work/common/cassandra/Cassandra.pyc in recv_insert(self)
380 x.read(self._iprot)
381 self._iprot.readMessageEnd()
-- 382 raise x
383 result = insert_result()
384 result.read(self._iprot)
TApplicationException: Internal error processing insert
INFO - Cassandra starting up...
DEBUG - insert
ERROR - Internal error processing insert
java.lang.NullPointerException
at
org.apache.cassandra.service.ThriftValidation.validateColumnPath(ThriftValidation.java:61)
at
org.apache.cassandra.service.CassandraServer.insert(CassandraServer.java:262)
at
org.apache.cassandra.service.Cassandra$Processor$insert.process(Cassandra.java:927)
at
org.apache.cassandra.service.Cassandra$Processor.process(Cassandra.java:796)
at
org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:252)
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:619)
On Tue, Jul 21, 2009 at 3:04 PM, Jonathan Ellis jbel...@gmail.com wrote:
did you check to make sure all the nodes were running and had no
exceptions in their logs?
On Tue, Jul 21, 2009 at 4:46 PM, mobiledream...@gmail.com wrote:
Strange this happened. in the 4 server nodes that run cassandra, the conf
file had
ConfA
ColumnFamily ColumnSort=Name
Name=Standard1 FlushPeriodInMinutes=60/
ColumnFamily ColumnSort=Name Name=Standard2/
ColumnFamily ColumnSort=Time Name=StandardByTime1/
ColumnFamily ColumnType=Super Name=Super1/
I changed it to the following and doing nodeprobe after restarting
cassandra, the other 3 nodes are down,
ConfB
ColumnFamily ColumnSort=Name
Name=Standard1 CompareWith=UTF8Type FlushPeriodInMinutes=60/
ColumnFamily
ColumnSort=Name CompareWith=UTF8Type Name=Standard2/
ColumnFamily
ColumnSort=Time CompareWith=UTF8Type Name=StandardByTime1/
ColumnFamily ColumnType=Super CompareWith=UTF8Type
CompareSubcolumnsWith=UTF8Type Name=Super1/
If i revert ConfB and set ConfA, all 4 nodes show up in nodeprobe in all
the
4 nodes
I m unsure how to debug this
On Tue, Jul 21, 2009 at 2:32 PM, mobiledream...@gmail.com wrote:
if this would be the conf/storage-conf.xml
ColumnFamily ColumnSort=Name
Name=Standard1 CompareWith=UTF8Type FlushPeriodInMinutes=60/
ColumnFamily
ColumnSort=Name CompareWith=UTF8Type Name=Standard2/
ColumnFamily
ColumnSort=Time CompareWith=UTF8Type Name=StandardByTime1/
ColumnFamily ColumnType=Super CompareWith=UTF8Type
CompareSubcolumnsWith=UTF8Type Name=Super1/
Jonathan can you clarify if this will guarantee proper python thrift
utf8
behavior thanks
On Tue, Jul 21, 2009 at 2:29 PM, Jonathan Ellis jbel...@gmail.com
wrote:
you may also want to specify CompareSubcolumnsWith.
On Tue, Jul 21, 2009 at 4:27 PM, mobiledream...@gmail.com wrote:
thanks jonathan
trying this
ColumnFamily
ColumnType=Super CompareWith=UTF8Type Name=Super1/
On Tue, Jul 21, 2009 at 2:24 PM, Jonathan Ellis jbel...@gmail.com
wrote:
On Tue, Jul 21, 2009 at 4:21 PM, Jonathan Ellisjbel...@gmail.com
wrote:
does this work in python thrift
probably not, given the thrift utf8 bugs.
to correct myself: now that we are using binary data in the thrift
api
it can't screw us over. so yes, UTF8Type should be fine.
--
Bidegg worlds best auction site
http://bidegg.com
--
Bidegg worlds best auction site
http://bidegg.com
--
Bidegg worlds best auction site
http://bidegg.com
--
Bidegg worlds best auction site
http://bidegg.com
Re: AttributeError: 'str' object has no attribute 'write'
Thanks Gasol wuthis helped
On Sun, Jul 19, 2009 at 7:22 PM, Gasol Wu gasol...@gmail.com wrote:
Hi Ian,
http://issues.apache.org/jira/browse/CASSANDRA-139
1.regeneration python client
cd $CASSANDRA_HOME/interface
thrift --gen py cassandra.thrift
2.recompile cassandra
cd $CASSANDRA_HOME
ant
3.modify your code.
below is my php code that i changed.
old:
$client-insert($table, $i, 'Standard1:md5', md5($i), $time, $block);
new trunk:
$cp_md5 = new cassandra_ColumnPath(array('column_family' = 'Standard1',
'column' = 'md5'));
$client-insert($table, $i, $cp_md5, md5($i), $time, $block);
On Mon, Jul 20, 2009 at 7:46 AM, Ian Holsman i...@holsman.net wrote:
hi Gasol.
shouldn't regeneration of the interface be part of the build process?
On 20/07/2009, at 3:29 AM, Gasol Wu wrote:
hi,
the cassandra.thrift has changed.
u need to generate new python client and compile class again.
On Mon, Jul 20, 2009 at 1:18 AM, mobiledream...@gmail.com wrote:
Hi guys
the new trunk cassandra doesnt work for a simple insert, how do we get
this working
client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)
---
AttributeErrorTraceback (most recent call
last)
/home/mark/work/cexperiments/ipython console in module()
/home/mark/work/common/cassandra/Cassandra.py in insert(self, table, key,
column_path, value, timestamp, block_for)
358 - block_for
359
-- 360 self.send_insert(table, key, column_path, value, timestamp,
block_for)
361 self.recv_insert()
362
/home/mark/work/common/cassandra/Cassandra.py in send_insert(self, table,
key, column_path, value, timestamp, block_for)
370 args.timestamp = timestamp
371 args.block_for = block_for
-- 372 args.write(self._oprot)
373 self._oprot.writeMessageEnd()
374 self._oprot.trans.flush()
/home/mark/work/common/cassandra/Cassandra.py in write(self, oprot)
1923 if self.column_path != None:
1924 oprot.writeFieldBegin('column_path', TType.STRUCT, 3)
- 1925 self.column_path.write(oprot)
1926 oprot.writeFieldEnd()
1927 if self.value != None:
AttributeError: 'str' object has no attribute 'write'
In [4]: client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)
--
Bidegg worlds best auction site
http://bidegg.com
--
Ian Holsman
i...@holsman.net
--
Bidegg worlds best auction site
http://bidegg.com
how to delete an entire column family
In Super-column family Super1 there is a column family Related How do i delete the entire related column family thanks
AttributeError: 'str' object has no attribute 'write'
*Hi guys *
*the new trunk cassandra doesnt work for a simple insert, how do we get this
working*
*
*
*client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)*
---
AttributeErrorTraceback (most recent call last)
/home/mark/work/cexperiments/ipython console in module()
/home/mark/work/common/cassandra/Cassandra.py in insert(self, table, key,
column_path, value, timestamp, block_for)
358 - block_for
359
-- 360 self.send_insert(table, key, column_path, value, timestamp,
block_for)
361 self.recv_insert()
362
/home/mark/work/common/cassandra/Cassandra.py in send_insert(self, table,
key, column_path, value, timestamp, block_for)
370 args.timestamp = timestamp
371 args.block_for = block_for
-- 372 args.write(self._oprot)
373 self._oprot.writeMessageEnd()
374 self._oprot.trans.flush()
/home/mark/work/common/cassandra/Cassandra.py in write(self, oprot)
1923 if self.column_path != None:
1924 oprot.writeFieldBegin('column_path', TType.STRUCT, 3)
- 1925 self.column_path.write(oprot)
1926 oprot.writeFieldEnd()
1927 if self.value != None:
AttributeError: 'str' object has no attribute 'write'
In [4]: client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)
--
Bidegg worlds best auction site
http://bidegg.com
New cassandra in trunk - breaks python thrift interface (was AttributeError: 'str' object has no attribute 'write')
Hey Gasol wu
i regenerated the new thrift interface using
*thrift -gen py cassandra.thrift*
client.insert('Table1', 'tofu', 'Super1:Related:tofu stew',
pickle.dumps(dict(count=1)), time.time(), 0)
---
AttributeErrorTraceback (most recent call last)
/home/mark/work/cexperiments/ipython console in module()
/home/mark/work/common/cassandra/Cassandra.py in insert(self, table, key,
column_path, value, timestamp, block_for)
358 - block_for
359
-- 360 self.send_insert(table, key, column_path, value, timestamp,
block_for)
361 self.recv_insert()
362
/home/mark/work/common/cassandra/Cassandra.py in send_insert(self, table,
key, column_path, value, timestamp, block_for)
370 args.timestamp = timestamp
371 args.block_for = block_for
-- 372 args.write(self._oprot)
373 self._oprot.writeMessageEnd()
374 self._oprot.trans.flush()
/home/mark/work/common/cassandra/Cassandra.py in write(self, oprot)
1923 if self.column_path != None:
1924 oprot.writeFieldBegin('column_path', TType.STRUCT, 3)
*- 1925 self.column_path.write(oprot)*
1926 oprot.writeFieldEnd()
1927 if self.value != None:
AttributeError: 'str' object has no attribute 'write'
On Sun, Jul 19, 2009 at 10:29 AM, Gasol Wu gasol...@gmail.com wrote:
hi,
the cassandra.thrift has changed.
u need to generate new python client and compile class again.
On Mon, Jul 20, 2009 at 1:18 AM, mobiledream...@gmail.com wrote:
*Hi guys *
*the new trunk cassandra doesnt work for a simple insert, how do we get
this working*
*
*
*client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)*
---
AttributeErrorTraceback (most recent call
last)
/home/mark/work/cexperiments/ipython console in module()
/home/mark/work/common/cassandra/Cassandra.py in insert(self, table, key,
column_path, value, timestamp, block_for)
358 - block_for
359
-- 360 self.send_insert(table, key, column_path, value, timestamp,
block_for)
361 self.recv_insert()
362
/home/mark/work/common/cassandra/Cassandra.py in send_insert(self, table,
key, column_path, value, timestamp, block_for)
370 args.timestamp = timestamp
371 args.block_for = block_for
-- 372 args.write(self._oprot)
373 self._oprot.writeMessageEnd()
374 self._oprot.trans.flush()
/home/mark/work/common/cassandra/Cassandra.py in write(self, oprot)
1923 if self.column_path != None:
1924 oprot.writeFieldBegin('column_path', TType.STRUCT, 3)
- 1925 self.column_path.write(oprot)
1926 oprot.writeFieldEnd()
1927 if self.value != None:
AttributeError: 'str' object has no attribute 'write'
In [4]: client.insert('Table1', 'tofu', 'Super1:Related:tofu
stew',pickle.dumps(dict(count=1)), time.time(), 0)
--
Bidegg worlds best auction site
http://bidegg.com
--
Bidegg worlds best auction site
http://bidegg.com
python thrift cassandra: get_slice_super vs get_slice_super_by_names
*Why doesnt res return ColumnFamily Related whereas res2 works just fine
thanks?*
timestamp = time.time()
res = client.get_slice_super('Table1', kw, 'Super1','','',True,0,1000)
print *res*
[]
res2 = client.get_slice_super_by_names('Table1', 'tofu', 'Super1',
['Related',])[0]
print res2
[superColumn_t(name='Related', columns=[column_t(columnName='tofu calories',
value=(dp1\nS'count'\np2\nI1\ns., timestamp=1247980687),
column_t(columnName='tofu festival', value=(dp1\nS'count'\np2\nI1\ns.,
timestamp=1247980687), column_t(columnName='tofu marinade',
value=(dp1\nS'count'\np2\nI1\ns., timestamp=1247980687),
column_t(columnName='tofu recipe', value=(dp1\nS'count'\np2\nI1\ns.,
timestamp=1247980687), column_t(columnName='tofu recipes',
value=(dp1\nS'count'\np2\nI1\ns., timestamp=1247980687),
column_t(columnName='tofu recipes easy', value=(dp1\nS'count'\np2\nI1\ns.,
timestamp=1247980687), column_t(columnName='tofu scramble',
value=(dp1\nS'count'\np2\nI1\ns., timestamp=1247980687),
column_t(columnName='tofu stir fry', value=(dp1\nS'count'\np2\nI1\ns.,
timestamp=1247980687), column_t(columnName='tofurkey',
value=(dp1\nS'count'\np2\nI1\ns., timestamp=1247980687),
column_t(columnName='tofutti', value=(dp1\nS'count'\np2\nI1\ns.,
timestamp=1247980687)])]
--
Bidegg worlds best auction site
http://bidegg.com
Fwd: WARN - Unable to find a live Endpoint we might be out of live nodes , This is dangerous !!!!
Why do the other nodes go down, in each of the nodes if i run nodprobe the results show that the other nodes are down 226.229.123.185:7001 up 226.129.12.117:7001 down 226.229.123.116:7001 down 226.229.112.134:7001 down Token(165434480505148814142836593307761304854) On Fri, Jul 17, 2009 at 12:18 AM, mobiledream...@gmail.com wrote: What does this mean? DEBUG - clearing DEBUG - remove WARN - Unable to find a live Endpoint we might be out of live nodes , This is dangerous WARN - Unable to find a live Endpoint we might be out of live nodes , This is dangerous DEBUG - locally writing writing key tofu to 11.12.13.0:7000 -- Bidegg worlds best auction site http://bidegg.com -- Bidegg worlds best auction site http://bidegg.com
keep-alive between cassandra ring nodes
i have encountered a peculiar issue in cassandra i have 2 seeds and 2 nodes all the 4 nodes carry the same 2 seeds in the storage-conf.xml so they discover each other once started, but the problem is after they discover each other But after a while nodeprobe shows that the other 3 nodes are down on each one of the 4 nodes, ie only the current node is alive is there a way to do a keep-alive kind of thing between the different cassandra ndoes -- Bidegg worlds best auction site http://bidegg.com
Re: one server or more servers?
some one in the group said a min of 2 seeds is necessary. i ll set the listenAddress to blank but i think it might be a problem of ports being blocked by fedora Can someone please list the ports used by cassandra to access the outside seeds and find the ring network? And if there are any users using fedora - can you show me how to open those ports so cassandra can gossip its way into a ring network right now i have 4 island cassandra nodes :( On Wed, Jul 15, 2009 at 9:24 PM, Evan Weaver ewea...@gmail.com wrote: Oh, yeah, definitely set ListenAddress to blank. 0.0.0.0 doesn't mean all interfaces for some reason I forget. Evan On Wed, Jul 15, 2009 at 9:23 PM, Evan Weaverewea...@gmail.com wrote: Try with only one seed. Not every host has to be in the seeds. Evan On Wed, Jul 15, 2009 at 8:52 PM, mobiledream...@gmail.com wrote: in Seeds can we specify domain name instead of ip address right now seeds is specifying ip address On Wed, Jul 15, 2009 at 4:49 PM, Evan Weaver ewea...@gmail.com wrote: I sometimes have to use 127.0.0.1, at least when ListenAddress is blank (auto-discover). Dunno if that has changed. Looks like this if you're successful: $ bin/nodeprobe --host 10.224.17.13 ring Token(124007023942663924846758258675932114665) 3 10.224.17.13 |--| Token(106858063638814585506848525974047690568) 3 10.224.17.19 | ^ Token(141130545721235451315477340120224986045) 3 10.224.17.14 |--| Evan On Wed, Jul 15, 2009 at 4:24 PM, Michael Greene michael.gre...@gmail.com wrote: The port you're looking for is typically 8080, but if you only specify the host and not the port it shoudl work just fine. bin/nodeprobe -host localhost Michael On Wed, Jul 15, 2009 at 6:18 PM, mobiledream...@gmail.com wrote: bin]$ ./nodeprobe -host localhost -port Error connecting to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:149) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:111) at org.apache.cassandra.tools.NodeProbe.main(NodeProbe.java:470) Caused by: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:304) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:267) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:246) ... 13 more On Wed, Jul 15, 2009 at 4:17 PM, mobiledream...@gmail.com wrote: port 7002 doesnt trying nodeprobe On Wed, Jul 15, 2009 at 4:03 PM, Anthony Molinaro antho...@alumni.caltech.edu wrote: Alternatively if you are using the 0.3 release you can point a browser at port 7002 of one of the boxes and should see all the nodes in the list. -Anthony On Wed, Jul 15, 2009 at 05:40:27PM -0500, Michael Greene wrote: You can use the nodeprobe utility in bin/ to contact each node and make sure they see the same information. Run it with no arguments to see the commands you can pass it. There is also an open issue at https://issues.apache.org/jira/browse/CASSANDRA-252 for making this a little more automatic (instead of having to run nodeprobe on
Re: one server or more servers?
port 7002 doesnt trying nodeprobe On Wed, Jul 15, 2009 at 4:03 PM, Anthony Molinaro antho...@alumni.caltech.edu wrote: Alternatively if you are using the 0.3 release you can point a browser at port 7002 of one of the boxes and should see all the nodes in the list. -Anthony On Wed, Jul 15, 2009 at 05:40:27PM -0500, Michael Greene wrote: You can use the nodeprobe utility in bin/ to contact each node and make sure they see the same information. Run it with no arguments to see the commands you can pass it. There is also an open issue at https://issues.apache.org/jira/browse/CASSANDRA-252 for making this a little more automatic (instead of having to run nodeprobe on each node and check the results by hand, you can just pass in all the servers that you think should be able to see each other) but there's no code for this yet. Michael On Wed, Jul 15, 2009 at 5:33 PM, mobiledream...@gmail.com wrote: Mark and Jonathan I have started cassandra on 4 servers with all 4 of them as seeds how do i know all 4 are now part of the datastore are there ways to test this thanks a lot On Tue, Jul 14, 2009 at 8:30 AM, Mark Robson mar...@gmail.com wrote: 2009/7/14 mobiledream...@gmail.com 1. If you only have 3 production servers, Cassandra may not do much for you. You will probably only care if you have lots more servers. 3 servers is a reasonable minimum for a test / dev environment At How many servers does cassandra start really performing? or how many servers is an ideal setup say for a game 10? It can use any number, three is probably a reasonable minimum, I don't know what the maximum is. If you have a small number of servers, there is probably no reason to use Cassandra; you can more usefully use a conventional database with replication or sharding. The reason you might want to use Cassandra is to scale writes a lot, to levels you couldn't reach with more conventional databases. In all likelihood, an application would use Cassandra to store high-volume high-write data alongside a more conventional database to store smaller, less frequently changing stuff. It appears to me that Cassandra 0.3 is only really useful if running on a homogenous cluster of dedicated servers with reasonable amounts of memory / storage (But not necessarily high spec servers of CPU, IO speed or internal redundancy). Once the load balancing is implemented in 0.5 (according to current plans) it will become more useful for heterogenous environments. Mark -- Bidegg worlds best auction site http://bidegg.com -- Anthony Molinaro antho...@alumni.caltech.edu -- Bidegg worlds best auction site http://bidegg.com
Re: one server or more servers?
bin]$ ./nodeprobe -host localhost -port Error connecting to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:149) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:111) at org.apache.cassandra.tools.NodeProbe.main(NodeProbe.java:470) Caused by: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:304) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:267) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:246) ... 13 more On Wed, Jul 15, 2009 at 4:17 PM, mobiledream...@gmail.com wrote: port 7002 doesnt trying nodeprobe On Wed, Jul 15, 2009 at 4:03 PM, Anthony Molinaro antho...@alumni.caltech.edu wrote: Alternatively if you are using the 0.3 release you can point a browser at port 7002 of one of the boxes and should see all the nodes in the list. -Anthony On Wed, Jul 15, 2009 at 05:40:27PM -0500, Michael Greene wrote: You can use the nodeprobe utility in bin/ to contact each node and make sure they see the same information. Run it with no arguments to see the commands you can pass it. There is also an open issue at https://issues.apache.org/jira/browse/CASSANDRA-252 for making this a little more automatic (instead of having to run nodeprobe on each node and check the results by hand, you can just pass in all the servers that you think should be able to see each other) but there's no code for this yet. Michael On Wed, Jul 15, 2009 at 5:33 PM, mobiledream...@gmail.com wrote: Mark and Jonathan I have started cassandra on 4 servers with all 4 of them as seeds how do i know all 4 are now part of the datastore are there ways to test this thanks a lot On Tue, Jul 14, 2009 at 8:30 AM, Mark Robson mar...@gmail.com wrote: 2009/7/14 mobiledream...@gmail.com 1. If you only have 3 production servers, Cassandra may not do much for you. You will probably only care if you have lots more servers. 3 servers is a reasonable minimum for a test / dev environment At How many servers does cassandra start really performing? or how many servers is an ideal setup say for a game 10? It can use any number, three is probably a reasonable minimum, I don't know what the maximum is. If you have a small number of servers, there is probably no reason to use Cassandra; you can more usefully use a conventional database with replication or sharding. The reason you might want to use Cassandra is to scale writes a lot, to levels you couldn't reach with more conventional databases. In all likelihood, an application would use Cassandra to store high-volume high-write data alongside a more conventional database to store smaller, less frequently changing stuff. It appears to me that Cassandra 0.3 is only really useful if running on a homogenous cluster of dedicated servers with reasonable amounts of memory / storage (But not necessarily high spec servers of CPU, IO speed or internal redundancy). Once the load balancing is implemented in 0.5 (according to current plans) it will become more useful for heterogenous environments. Mark -- Bidegg worlds best auction site http://bidegg.com --
Re: one server or more servers?
cassandra]$ bin/nodeprobe -host 127.0.0.1 ring DEBUG - Loading settings from bin/../conf/storage-conf.xml Token(14446472026035954629218078815970965332) 1 0.0.0.0|--| none of the servers r picking up the ring - all 4 servers are on the seeds! how do i make them pick the other 4 in the ring should listen be made blank right now listen addres is 0.0.0.0 ListenAddress0.0.0.0/ListenAddress On Wed, Jul 15, 2009 at 8:49 PM, mobiledream...@gmail.com wrote: bin/nodeprobe -host 127.0.0.1 ring DEBUG - Loading settings from bin/../conf/storage-conf.xml Token(24598770870836697279577556965837538135) 1 0.0.0.0|--| this means the ring is not working? On Wed, Jul 15, 2009 at 4:49 PM, Evan Weaver ewea...@gmail.com wrote: I sometimes have to use 127.0.0.1, at least when ListenAddress is blank (auto-discover). Dunno if that has changed. Looks like this if you're successful: $ bin/nodeprobe --host 10.224.17.13 ring Token(124007023942663924846758258675932114665) 3 10.224.17.13 |--| Token(106858063638814585506848525974047690568) 3 10.224.17.19 | ^ Token(141130545721235451315477340120224986045) 3 10.224.17.14 |--| Evan On Wed, Jul 15, 2009 at 4:24 PM, Michael Greenemichael.gre...@gmail.com wrote: The port you're looking for is typically 8080, but if you only specify the host and not the port it shoudl work just fine. bin/nodeprobe -host localhost Michael On Wed, Jul 15, 2009 at 6:18 PM, mobiledream...@gmail.com wrote: bin]$ ./nodeprobe -host localhost -port Error connecting to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:149) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:111) at org.apache.cassandra.tools.NodeProbe.main(NodeProbe.java:470) Caused by: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:304) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:267) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:246) ... 13 more On Wed, Jul 15, 2009 at 4:17 PM, mobiledream...@gmail.com wrote: port 7002 doesnt trying nodeprobe On Wed, Jul 15, 2009 at 4:03 PM, Anthony Molinaro antho...@alumni.caltech.edu wrote: Alternatively if you are using the 0.3 release you can point a browser at port 7002 of one of the boxes and should see all the nodes in the list. -Anthony On Wed, Jul 15, 2009 at 05:40:27PM -0500, Michael Greene wrote: You can use the nodeprobe utility in bin/ to contact each node and make sure they see the same information. Run it with no arguments to see the commands you can pass it. There is also an open issue at https://issues.apache.org/jira/browse/CASSANDRA-252 for making this a little more automatic (instead of having to run nodeprobe on each node and check the results by hand, you can just pass in all the servers that you think should be able to see each other) but there's no code for this yet. Michael On Wed, Jul 15, 2009 at 5:33 PM, mobiledream...@gmail.com wrote: Mark and Jonathan I have started cassandra on 4 servers with all 4 of them as seeds how do i know all 4 are now part of the datastore are there ways to test
Re: one server or more servers?
in Seeds can we specify domain name instead of ip address right now seeds is specifying ip address On Wed, Jul 15, 2009 at 4:49 PM, Evan Weaver ewea...@gmail.com wrote: I sometimes have to use 127.0.0.1, at least when ListenAddress is blank (auto-discover). Dunno if that has changed. Looks like this if you're successful: $ bin/nodeprobe --host 10.224.17.13 ring Token(124007023942663924846758258675932114665) 3 10.224.17.13 |--| Token(106858063638814585506848525974047690568) 3 10.224.17.19 | ^ Token(141130545721235451315477340120224986045) 3 10.224.17.14 |--| Evan On Wed, Jul 15, 2009 at 4:24 PM, Michael Greenemichael.gre...@gmail.com wrote: The port you're looking for is typically 8080, but if you only specify the host and not the port it shoudl work just fine. bin/nodeprobe -host localhost Michael On Wed, Jul 15, 2009 at 6:18 PM, mobiledream...@gmail.com wrote: bin]$ ./nodeprobe -host localhost -port Error connecting to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:149) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:111) at org.apache.cassandra.tools.NodeProbe.main(NodeProbe.java:470) Caused by: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is: java.io.EOFException at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:304) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:267) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:246) ... 13 more On Wed, Jul 15, 2009 at 4:17 PM, mobiledream...@gmail.com wrote: port 7002 doesnt trying nodeprobe On Wed, Jul 15, 2009 at 4:03 PM, Anthony Molinaro antho...@alumni.caltech.edu wrote: Alternatively if you are using the 0.3 release you can point a browser at port 7002 of one of the boxes and should see all the nodes in the list. -Anthony On Wed, Jul 15, 2009 at 05:40:27PM -0500, Michael Greene wrote: You can use the nodeprobe utility in bin/ to contact each node and make sure they see the same information. Run it with no arguments to see the commands you can pass it. There is also an open issue at https://issues.apache.org/jira/browse/CASSANDRA-252 for making this a little more automatic (instead of having to run nodeprobe on each node and check the results by hand, you can just pass in all the servers that you think should be able to see each other) but there's no code for this yet. Michael On Wed, Jul 15, 2009 at 5:33 PM, mobiledream...@gmail.com wrote: Mark and Jonathan I have started cassandra on 4 servers with all 4 of them as seeds how do i know all 4 are now part of the datastore are there ways to test this thanks a lot On Tue, Jul 14, 2009 at 8:30 AM, Mark Robson mar...@gmail.com wrote: 2009/7/14 mobiledream...@gmail.com 1. If you only have 3 production servers, Cassandra may not do much for you. You will probably only care if you have lots more servers. 3 servers is a reasonable minimum for a test / dev environment At How many servers does cassandra start really performing? or how many servers is an ideal setup say for a game 10? It can use any number, three is probably a reasonable minimum, I don't know
Re: problem running cassandra
Hey jonathan thanks a lot fedoraI searched and found that the problem was i hadnt setup JAVA_HOME once i set it up it worked immediately But i m trying to setup the cassandra web inerface. Can you show me how to setup cassandra Thanks a lot On Thu, Jul 9, 2009 at 10:27 AM, Jonathan Ellis jbel...@gmail.com wrote: what version are you trying to run? on what platform? On Thu, Jul 9, 2009 at 12:04 PM, mobiledream...@gmail.com wrote: I did set it up as the readme file instructed but i encountered this error, Can you please suggest how i fix this thanks cassandra]$ bin/cassandra -f Listening for transport dt_socket at address: Exception in thread main java.lang.NoClassDefFoundError: org/apache/cassandra/service/CassandraDaemon Caused by: java.lang.ClassNotFoundException: org.apache.cassandra.service.CassandraDaemon at java.net.URLClassLoader$1.run(URLClassLoader.java:200) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:188) at java.lang.ClassLoader.loadClass(ClassLoader.java:307) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) at java.lang.ClassLoader.loadClass(ClassLoader.java:252) at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320) Could not find the main class: org.apache.cassandra.service.CassandraDaemon. Program will exit. -- Bidegg worlds best auction site http://bidegg.com
