diff --git a/ddtrace/contrib/cassandra/session.py b/ddtrace/contrib/cassandra/session.py
index d00c7fa120a..e407b4a00d4 100644
--- a/ddtrace/contrib/cassandra/session.py
+++ b/ddtrace/contrib/cassandra/session.py
@@ -253,9 +253,7 @@ def _sanitize_query(span, query):
         # reset query if a string is available
         resource = getattr(query, "query_string", query)
     elif t == 'BatchStatement':
-        resource = 'BatchStatement'
-        q = "; ".join(q[1] for q in query._statements_and_parameters[:2])
-        span.set_tag("cassandra.query", q)
+        resource = '; '.join(q[1] for q in query._statements_and_parameters[:2])
         span.set_metric("cassandra.batch_size", len(query._statements_and_parameters))
     elif t == 'BoundStatement':
         ps = getattr(query, 'prepared_statement', None)
diff --git a/tests/contrib/cassandra/test.py b/tests/contrib/cassandra/test.py
index a92519218da..f65d26e2dab 100644
--- a/tests/contrib/cassandra/test.py
+++ b/tests/contrib/cassandra/test.py
@@ -264,9 +264,15 @@ def test_batch_statement(self):
         spans = writer.pop()
         eq_(len(spans), 1)
         s = spans[0]
-        eq_(s.resource, 'BatchStatement')
+        eq_(
+            s.resource,
+            (
+                'INSERT INTO test.person_write (name, age, description) VALUES (\'Joe\', 1, \'a\'); '
+                'INSERT INTO test.person_write (name, age, description) VALUES (\'Jane\', 2, \'b\')'
+            )
+        )
         eq_(s.get_metric('cassandra.batch_size'), 2)
-        assert 'test.person' in s.get_tag('cassandra.query')
+        assert s.get_tag('cassandra.query') is None
 
 
 class TestCassPatchDefault(CassandraBase):