Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5538
We would have to pass the keyspace via the constructor as the
`Configuration` approach doesn't work for streaming.
Generally speaking it isn't a problem to set the keyspace when creating the
connection. But I would like to know what happens if a POJO comes along that
explicitly sets the keyspace; is ignored, respected or will it cause an
exception?---
