Change the timeout for spark startup and waitForStopped, also wiremock will use dynamic ports

Author: vikasrathee-cs

src/test/java/io/cdap/plugin/http/etl/BaseHttpBatchSourceETLTest.java

@@ -64,7 +64,7 @@ public abstract class BaseHttpBatchSourceETLTest extends HydratorTestBase {
   public TestName name = new TestName();
 
   @Rule
-  public WireMockRule wireMockRule = new WireMockRule();
+  public WireMockRule wireMockRule = new WireMockRule(0);
 
   private static final ArtifactSummary APP_ARTIFACT = new ArtifactSummary("data-pipeline", "3.2.0");
 

src/test/java/io/cdap/plugin/http/etl/HttpSourceETLTest.java

@@ -42,7 +42,7 @@ public abstract class HttpSourceETLTest extends HydratorTestBase {
   @Rule
   public TestName testName = new TestName();
   @Rule
-  public WireMockRule wireMockRule = new WireMockRule();
+  public WireMockRule wireMockRule = new WireMockRule(0);
 
   @Test
   public void testIncrementAnIndex() throws Exception {

src/test/java/io/cdap/plugin/http/etl/HttpStreamingSourceETLTest.java

@@ -100,7 +100,7 @@ private ProgramManager startPipeline(Map<String, String> properties) throws Exce
 
     ProgramManager programManager =
       deployETL(sourceConfig, sinkConfig, "HTTPStreaming_" + testName.getMethodName());
-    programManager.startAndWaitForRun(ProgramRunStatus.RUNNING, 30, TimeUnit.SECONDS);
+    programManager.startAndWaitForRun(ProgramRunStatus.RUNNING, 120, TimeUnit.SECONDS);
 
     return programManager;
   }
@@ -121,7 +121,7 @@ private List<StructuredRecord> waitForRecords(ProgramManager programManager,
       }));
 
     programManager.stop();
-    programManager.waitForStopped(10, TimeUnit.SECONDS);
+    programManager.waitForStopped(120, TimeUnit.SECONDS);
 
     outputManager.get();
     return MockSink.readOutput(outputManager);