Cassandra Sink for Cassandra 3.x?

[kshoga1]

Hello,

When trying to use the Cassandra Sink, I'm getting this error (according to others) because I am using Cassandra 3.x. "com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces" Apparently as of Cassandra 3.x the table "system_schema.keyspaces" is used.

Do you have plans for a new or updated Cassandra Sink to allow for use with Cassandra 3.x?

Thank you!

[gsautereau]

Hello,

Just for information, if you don't already try this: Just replacing the cassandra driver in lib folder of stratio-ingestion with cassandra3's one: cassandra-driver-core-3.0.1-shaded.jar worked for me