Loose withCloseTimeout to fix flaky integration test; fix label

Author: Abacn

sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java

@@ -146,7 +146,7 @@ public interface JmsIOITOptions extends IOTestPipelineOptions, StreamingOptions
   @Rule public transient TestPipeline pipelineWrite = TestPipeline.create();
   @Rule public transient TestPipeline pipelineRead = TestPipeline.create();
 
-  @Parameterized.Parameters(name = "with client class {3}")
+  @Parameterized.Parameters(name = "with client class {2}")
   public static Collection<Object[]> connectionFactories() {
     return ImmutableList.of(
         new Object[] {"vm://localhost", "jms.sendAcksAsync=false", ActiveMQConnectionFactory.class},
@@ -304,9 +304,9 @@ private PipelineResult readMessages(JmsIO.AcknowledgeMode acknowledgeMode, Strin
     JmsIO.Read<String> jmsIORead =
         JmsIO.<String>readMessage()
             .withAcknowledgeMode(acknowledgeMode)
-            // Decrease withCloseTimeout to be smaller than pipeline runtime. Direct runner randomly
+            // Decrease withCloseTimeout to be smaller than pipeline timeout. Direct runner randomly
             // closes reader causing cached pending consumer hanging until closeTimeout
-            .withCloseTimeout(Duration.standardSeconds(5));
+            .withCloseTimeout(Duration.standardSeconds(10));
     if (pipelineRead.getOptions().as(JmsIOITOptions.class).getUseConnectionFactoryProviderFn()) {
       jmsIORead =
           jmsIORead.withConnectionFactoryProviderFn(

sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java

@@ -152,7 +152,7 @@ private static TextMessage createTextMessage(Session session, long messageIndex)
       RetryConfiguration.create(1, Duration.standardSeconds(1), null);
   @Rule public final transient TestPipeline pipeline = TestPipeline.create();
 
-  @Parameterized.Parameters(name = "with client class {3}")
+  @Parameterized.Parameters(name = "with client class {2}")
   public static Collection<Object[]> connectionFactories() {
     return Arrays.asList(
         new Object[] {"vm://localhost", "jms.sendAcksAsync=false", ActiveMQConnectionFactory.class},