-
Notifications
You must be signed in to change notification settings - Fork 299
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Make the call to cassandra.describe_keyspace fault tolerant #11
Comments
I don't know how to merge my modifications to my fork. I pasted my solution into gist.github.com/hz, 360995 is a interface, 360996 is request featured with failover and pooling. 360997 is the wrapper for thrift api. 30999 is the revised keyspaceimpl. you do some tricks on getColumn. I can not solve it. |
Sorry, it's pretty hard to see diffs in gists. It's preferable that you push back to your hz/hector repo so I can see diffs and send line comments, but if this isn't working for you, then email me a patch |
Any idea when this problem is likely to be resolved? Occasionally I experience a transport error which causes the call to getKeyspace to fail. When this happens Hector does not recover and all subsequent calls to getKeyspace fail. |
I guess I was just waiting for someone to need this bad enough to implement that... |
Well, http://github.com/Mishail/hector/commit/a8c9a0accd49d1e8f76ad15d8250f608f8a9d755 Though I'm not sure that all is done properly... The code is mostly borrowed from CassandraClusterImpl. And all unit-test are passed (except one, which I marked as @ignore and specified the reason) |
The call to cassandra.describe_keyspace is at CassandraClientImpl.getKeyspace()
This is a "meta" call, which is invoked once per keyspace before any other operation on that keyspace is performed.
This call, if unsuccessful, will not use the failover policy used by all other read/write operations.
It should.
The text was updated successfully, but these errors were encountered: