echauchot commented on a change in pull request #18544:
URL: https://github.com/apache/flink/pull/18544#discussion_r798396384
##########
File path:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/CustomCassandraAnnotatedPojo.java
##########
@@ -21,11 +21,9 @@
import com.datastax.driver.mapping.annotations.Table;
/** Example of Cassandra Annotated POJO class for use with {@link
CassandraPojoInputFormat}. */
-@Table(name = CustomCassandraAnnotatedPojo.TABLE_NAME, keyspace = "flink")
+@Table(name = "batches", keyspace = "flink")
Review comment:
I agree thanks: as we will now add the annotation rather than modifying
the existing one. It will be less confusing
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
