commit d3e82b1114dcdf7a04723c5227255552c369d0be
author Maytas Monsereenusorn <maytasm@apache.org> Wed Jul 14 21:14:38 2021 +0700
committer GitHub <noreply@github.com> Wed Jul 14 21:14:38 2021 +0700
tree 8e355e5f41331f9a22f1d283c820e2cbb253fc3f
parent ace4b807f4a2798728ecbf28c65420423dc2b482

speed up test (#11442)

integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractStreamIndexingTest.java

diff --git a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractStreamIndexingTest.java b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractStreamIndexingTest.java
index ed1811a..c118069 100644
--- a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractStreamIndexingTest.java
+++ b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractStreamIndexingTest.java
@@ -373,7 +373,6 @@
     try (
         final Closeable closer1 = createResourceCloser(generatedTestConfig1);
         final Closeable closer2 = createResourceCloser(generatedTestConfig2);
-        final StreamEventWriter streamEventWriter = createStreamEventWriter(config, transactionEnabled)
     ) {
       final String taskSpec1 = generatedTestConfig1.getStreamIngestionPropsTransform()
                                                  .apply(getResourceAsString(SUPERVISOR_SPEC_TEMPLATE_PATH));
@@ -385,44 +384,6 @@
       generatedTestConfig1.setSupervisorId(indexer.submitSupervisor(taskSpec1));
       generatedTestConfig2.setSupervisorId(indexer.submitSupervisor(taskSpec2));
       LOG.info("Submitted supervisors");
-      // Start generating the data
-      final StreamGenerator streamGenerator1 = new WikipediaStreamEventStreamGenerator(
-          new JsonEventSerializer(jsonMapper),
-          EVENTS_PER_SECOND,
-          CYCLE_PADDING_MS
-      );
-      streamGenerator1.run(
-          generatedTestConfig1.getStreamName(),
-          streamEventWriter,
-          TOTAL_NUMBER_OF_SECOND,
-          FIRST_EVENT_TIME
-      );
-      final StreamGenerator streamGenerator2 = new WikipediaStreamEventStreamGenerator(
-          new JsonEventSerializer(jsonMapper),
-          EVENTS_PER_SECOND,
-          CYCLE_PADDING_MS
-      );
-      streamGenerator2.run(
-          generatedTestConfig2.getStreamName(),
-          streamEventWriter,
-          TOTAL_NUMBER_OF_SECOND,
-          FIRST_EVENT_TIME
-      );
-      // Verify supervisors are healthy before termination
-      ITRetryUtil.retryUntil(
-          () -> SupervisorStateManager.BasicState.RUNNING.equals(indexer.getSupervisorStatus(generatedTestConfig1.getSupervisorId())),
-          true,
-          10000,
-          30,
-          "Waiting for supervisor1 to be healthy"
-      );
-      ITRetryUtil.retryUntil(
-          () -> SupervisorStateManager.BasicState.RUNNING.equals(indexer.getSupervisorStatus(generatedTestConfig2.getSupervisorId())),
-          true,
-          10000,
-          30,
-          "Waiting for supervisor2 to be healthy"
-      );
 
       // Sleep for 10 secs to make sure that at least one cycle of supervisor auto cleanup duty ran
       Thread.sleep(10000);