[solr-sandbox] branch main updated: Fix up test. (#54)

[markrmiller]

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git


The following commit(s) were added to refs/heads/main by this push:
     new 8754d0d  Fix up test. (#54)
8754d0d is described below

commit 8754d0d82836f8bb76f61a72e2eb84ed1ffcd34c
Author: Mark Robert Miller <markrmil...@apache.org>
AuthorDate: Wed Apr 12 13:54:26 2023 -0500

    Fix up test. (#54)
---
 .../org/apache/solr/crossdc/SolrAndKafkaIntegrationTest.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/crossdc-producer/src/test/java/org/apache/solr/crossdc/SolrAndKafkaIntegrationTest.java
 
b/crossdc-producer/src/test/java/org/apache/solr/crossdc/SolrAndKafkaIntegrationTest.java
index ebdd879..c3bb2e5 100644
--- 
a/crossdc-producer/src/test/java/org/apache/solr/crossdc/SolrAndKafkaIntegrationTest.java
+++ 
b/crossdc-producer/src/test/java/org/apache/solr/crossdc/SolrAndKafkaIntegrationTest.java
@@ -70,8 +70,8 @@ import static org.mockito.Mockito.spy;
   private static String ALT_COLLECTION = "collection2";
   private static Thread.UncaughtExceptionHandler uceh;
 
-  @BeforeClass
-  public static void beforeSolrAndKafkaIntegrationTest() throws Exception {
+  @Before
+  public void beforeSolrAndKafkaIntegrationTest() throws Exception {
     uceh = Thread.getDefaultUncaughtExceptionHandler();
     Thread.setDefaultUncaughtExceptionHandler((t, e) -> {
       log.error("Uncaught exception in thread " + t, e);
@@ -127,8 +127,8 @@ import static org.mockito.Mockito.spy;
 
   }
 
-  @AfterClass
-  public static void afterSolrAndKafkaIntegrationTest() throws Exception {
+  @After
+  public void afterSolrAndKafkaIntegrationTest() throws Exception {
     ObjectReleaseTracker.clear();
 
     if (solrCluster1 != null) {
@@ -144,7 +144,7 @@ import static org.mockito.Mockito.spy;
     consumer = null;
 
     try {
-      kafkaCluster.deleteAllTopicsAndWait(5000);
+      // kafkaCluster.deleteAllTopicsAndWait(5000);
       kafkaCluster.stop();
       kafkaCluster = null;
     } catch (Exception e) {
@@ -294,7 +294,7 @@ import static org.mockito.Mockito.spy;
   private void assertClusterEventuallyHasDocs(SolrClient client, String 
collection, String query, int expectedNumDocs) throws Exception {
     QueryResponse results = null;
     boolean foundUpdates = false;
-    for (int i = 0; i < 20; i++) {
+    for (int i = 0; i < 100; i++) {
       client.commit(collection);
       results = client.query(collection, new SolrQuery(query));
       if (results.getResults().getNumFound() == expectedNumDocs) {