Open elad opened 9 years ago
I am seeing the same problem with cassandra 2.1.0-2 while adding new node. Any solution?
Hello,
We have not yet tried hdfs2cass with Cassandra 2.1. Therefore I can't be of much help at this time.
The 'unknown type' error probably comes from the difference in streaming protocol between 2.0.11 (depended on by hdfs2cass) and 2.1 (used by your Cassandra instance). I'd suggest bumping Cassandra version hdfs2cass depends on to whatever your cluster is on. Chances are it will just work.
Moreover, I'm still puzzled by this:
java.io.IOException: CF b9dda069-4d0a-37c3-b0e8-8c4cf88a4a9f was dropped during streaming
Does this mean the table got dropped? Why? Is this a cause, or just an effect of some other errors?
I'd suggest bumping Cassandra version hdfs2cass depends on to whatever your cluster is on. Chances are it will just work.
It doesn't. :/
It looks like CASSANDRA-8924 might be related and helpful in resolving this issue, I'll look into it when I get a chance.
Patched version of hdfs2cass (CASSANDRA-8924, Cassandra 2.1.6) at https://github.com/meyarivan/hdfs2cass might be helpful
I can confirm this fixes streaming to Cassandra 2.1.6, thanks!
@meyarivan could you please create a pull request so that there's a better chance @rzvoncek or someone else merges these changes?
Hello,
I'm seeing a problem with hdfs2cass when I try to load Avro files on HDFS to Cassandra (2.1.2) using CQL.
I've attached logs (below) for both hdfs2cass and Cassandra. Note that for the latter, an "Unknown type 72" exception is thrown during deserialization.
If I modify the code to use the Thrift protocol (in ExternalSSTableLoaderClient) instead, loading is fine.
Any ideas on what it is I'm doing wrong, or what should change to make this work?
Thanks!
Hdfs2cass:
Logs from Cassandra: