From e3ea99bd881f75462f14d39ca221d2e0ab649e0c Mon Sep 17 00:00:00 2001
From: Etienne Chauchot <echauchot@apache.org>
Date: Fri, 31 Jul 2020 15:26:23 +0200
Subject: [PATCH] [BEAM-10471] fix a wrong comment

---
 .../java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java b/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java
index 8611b855dd30..1e7410755360 100644
--- a/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java
+++ b/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java
@@ -379,7 +379,8 @@ public void testWrite() {
                 .withPort(cassandraPort)
                 .withKeyspace(CASSANDRA_KEYSPACE)
                 .withEntity(ScientistWrite.class));
-    // table to write to is specified in the entity in @Table annotation (in that case scientist)
+    // table to write to is specified in the entity in @Table annotation (in that case
+    // scientist_write)
     pipeline.run();
 
     List<Row> results = getRows(CASSANDRA_TABLE_WRITE);