open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable sporadically failing test (#10570)

This commit is contained in:
Trask Stalnaker 2024-02-16 00:38:37 -08:00 committed by GitHub
parent 807e0c2f9b
commit b1dfdf04a9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
instrumentation/cassandra/cassandra-4.4/testing/src/main/java/io/opentelemetry/testing/cassandra/v4_4/AbstractCassandra44Test.java
View File

@ -25,12 +25,9 @@ import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Named.named; import static org.junit.jupiter.api.Named.named;
import com.datastax.oss.driver.api.core.CqlSession; import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.CqlSessionBuilder;
import com.datastax.oss.driver.internal.core.metadata.SniEndPoint;
import io.opentelemetry.api.trace.SpanKind; import io.opentelemetry.api.trace.SpanKind;
import io.opentelemetry.cassandra.v4.common.AbstractCassandraTest; import io.opentelemetry.cassandra.v4.common.AbstractCassandraTest;
import io.opentelemetry.instrumentation.api.semconv.network.internal.NetworkAttributes; import io.opentelemetry.instrumentation.api.semconv.network.internal.NetworkAttributes;
import java.net.InetSocketAddress;
import java.util.stream.Stream; import java.util.stream.Stream;
import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.Arguments; import org.junit.jupiter.params.provider.Arguments;
@ -154,10 +151,11 @@ public abstract class AbstractCassandra44Test extends AbstractCassandraTest {
"users")))); "users"))));
} }
@Override // TODO (trask) this is causing sporadic test failures
protected CqlSessionBuilder addContactPoint(CqlSessionBuilder sessionBuilder) { // @Override
InetSocketAddress address = new InetSocketAddress("localhost", cassandraPort); // protected CqlSessionBuilder addContactPoint(CqlSessionBuilder sessionBuilder) {
sessionBuilder.addContactEndPoint(new SniEndPoint(address, "localhost")); // InetSocketAddress address = new InetSocketAddress("localhost", cassandraPort);
return sessionBuilder; // sessionBuilder.addContactEndPoint(new SniEndPoint(address, "localhost"));
} // return sessionBuilder;
// }
} }