Github user Bekreth commented on the issue:
https://github.com/apache/flink/pull/5538
I've been looking into this more in depth and I'm uncertain there is going
to be a cleaner solution. The DataStax annotation parser will fail during
runtime if it can't determine the keyspace either from the Table annotation, or
from the connection. The core Cassandra functionality is built on a stateless
connection though, so embedding the keyspace into there would be a bad idea.
In order to make this work with the current Datastax implementations, it'd
be necessary to extend both MappingManager and AnnotationParser from Datastax
as well as update the CassandraSinkBase to use these extension.
Should I try to make a swing at these changes to see what it entail?
---
