From d2c7dd5c2b94bb8b53abb903fd92a2231cb7038a Mon Sep 17 00:00:00 2001
From: Kenneth Knowles <klk@google.com>
Date: Mon, 23 Jan 2017 20:30:04 -0800
Subject: [PATCH] WIP: maven config for streaming RoS in Dataflow

---
 runners/google-cloud-dataflow-java/pom.xml | 46 ++++++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/runners/google-cloud-dataflow-java/pom.xml b/runners/google-cloud-dataflow-java/pom.xml
index bfcb189232fb..a2fc5a0b6037 100644
--- a/runners/google-cloud-dataflow-java/pom.xml
+++ b/runners/google-cloud-dataflow-java/pom.xml
@@ -81,6 +81,52 @@
     </profile>
   </profiles>
 
+  <profiles>
+    <!-- A profile that adds an integration test phase for streaming if and only if
+         the streamingValidatesRunnerPipelineOptions maven property has been set.
+         It should be set to a valid PipelineOptions JSON string. -->
+    <profile>
+      <id>streaming-runnable-on-service-tests</id>
+      <activation>
+        <property><name>streamingValidatesRunnerPipelineOptions</name></property>
+      </activation>
+      <build>
+        <pluginManagement>
+          <plugins>
+            <plugin>
+              <groupId>org.apache.maven.plugins</groupId>
+              <artifactId>maven-surefire-plugin</artifactId>
+              <executions>
+
+                <!-- Execution in addition to the default runnable-on-service-tests execution -->
+                <execution>
+                  <id>streaming-runnable-on-service-tests</id>
+                  <phase>integration-test</phase>
+                  <goals>
+                    <goal>test</goal>
+                  </goals>
+                  <configuration>
+                    <groups>org.apache.beam.sdk.testing.RunnableOnService</groups>
+                    <parallel>all</parallel>
+                    <threadCount>4</threadCount>
+                    <dependenciesToScan>
+                      <dependency>org.apache.beam:beam-sdks-java-core</dependency>
+                    </dependenciesToScan>
+                    <systemPropertyVariables>
+                      <beamTestPipelineOptions>
+                        ${streamingRunnableOnServicePipelineOptions}
+                      </beamTestPipelineOptions>
+                    </systemPropertyVariables>
+                  </configuration>
+                </execution>
+              </executions>
+            </plugin>
+          </plugins>
+        </pluginManagement>
+      </build>
+    </profile>
+  </profiles>
+
   <build>
     <resources>
       <resource>