Skip to content

Commit

Permalink
[fix][test] Prevent OOM in test by not spying invocations in SimplePr…
Browse files Browse the repository at this point in the history
…oducerConsumerTest (apache#23486)
  • Loading branch information
lhotari authored Oct 21, 2024
1 parent 9db5f01 commit 7367f1c
Showing 1 changed file with 0 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -91,13 +91,10 @@
import org.apache.pulsar.PulsarVersion;
import org.apache.pulsar.broker.BrokerTestUtil;
import org.apache.pulsar.broker.PulsarService;
import org.apache.pulsar.broker.ServiceConfiguration;
import org.apache.pulsar.broker.service.ServerCnx;
import org.apache.pulsar.broker.service.persistent.PersistentTopic;
import org.apache.pulsar.broker.storage.ManagedLedgerStorage;
import org.apache.pulsar.broker.storage.ManagedLedgerStorageClass;
import org.apache.pulsar.broker.testcontext.PulsarTestContext;
import org.apache.pulsar.broker.testcontext.SpyConfig;
import org.apache.pulsar.client.admin.PulsarAdminException;
import org.apache.pulsar.client.api.schema.GenericRecord;
import org.apache.pulsar.client.impl.BatchMessageIdImpl;
Expand Down Expand Up @@ -155,14 +152,6 @@ protected void setup() throws Exception {
super.producerBaseSetup();
}

@Override
protected PulsarTestContext.Builder createPulsarTestContextBuilder(ServiceConfiguration conf) {
return super.createPulsarTestContextBuilder(conf)
.spyConfig(SpyConfig.builder()
.managedLedgerStorage(SpyConfig.SpyType.SPY_ALSO_INVOCATIONS)
.build());
}

@AfterMethod(alwaysRun = true)
public void cleanupAfterMethod() throws Exception {
try {
Expand Down

0 comments on commit 7367f1c

Please sign in to comment.