Skip to content

Commit 94da60d

Browse files
committed
review
1 parent f4a7d1d commit 94da60d

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

dd-java-agent/instrumentation/datastax-cassandra-3/src/main/java/datadog/trace/instrumentation/datastax/cassandra/CassandraClientDecorator.java

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -87,14 +87,17 @@ public AgentSpan onResponse(final AgentSpan span, final ResultSet result) {
8787
if (result != null) {
8888
final Host host = result.getExecutionInfo().getQueriedHost();
8989
onPeerConnection(span, host.getSocketAddress());
90-
if (Config.get().isCassandraKeyspaceStatementExtractionEnabled()) {
91-
final ColumnDefinitions defs = result.getColumnDefinitions();
92-
if (defs != null && defs.size() > 0) {
93-
final String keySpace = defs.getKeyspace(0);
94-
if (Strings.isNotBlank(keySpace) && !keySpace.equals(span.getTag(DB_INSTANCE))) {
95-
onInstance(span, keySpace);
90+
try {
91+
if (Config.get().isCassandraKeyspaceStatementExtractionEnabled()) {
92+
final ColumnDefinitions defs = result.getColumnDefinitions();
93+
if (defs != null && defs.size() > 0) {
94+
final String keySpace = defs.getKeyspace(0);
95+
if (Strings.isNotBlank(keySpace) && !keySpace.equals(span.getTag(DB_INSTANCE))) {
96+
onInstance(span, keySpace);
97+
}
9698
}
9799
}
100+
} catch (final Throwable ignored) {
98101
}
99102
}
100103
return span;

0 commit comments

Comments
 (0)