Hi, we want to read and write from and to Cassandra.
We found the Flink-Cassandra connector and added the JAR to the lib folder of the running Flink cluster (local machine). Trying to access the Cassandra database by adding the import to a notebook within Apache Zeppelin, resulted in the following error: import org.apache.flink.streaming.connectors.cassandra._ error: object connectors is not a member of package org.apache.flink.streaming import org.apache.flink.streaming.connectors.cassandra._ We have Flink 1.3.2 running. It would be great to see an example of what to implement for reading from Cassandra and another that uses the Cassandra Connector sink (the example from the documentation gave us the error above). We tried to find something but had no luck. Kind regards, Andre
