From b58117c6fa7554e6988dbacff7c23478a76887bd Mon Sep 17 00:00:00 2001
From: Kenneth Knowles <klk@google.com>
Date: Fri, 3 Mar 2017 13:34:05 -0800
Subject: [PATCH] Dataflow streaming config for WordCountIT and
 WindowedWordCountIT

---
 examples/java/pom.xml | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index 9da814b1388d..fafd5c892896 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -268,6 +268,31 @@
                   </systemPropertyVariables>
                 </configuration>
               </execution>
+              <execution>
+                <id>dataflow-runner-integration-tests-streaming</id>
+                <goals>
+                  <goal>integration-test</goal>
+                  <goal>verify</goal>
+                </goals>
+                <configuration>
+                  <includes>
+                    <include>WordCountIT.java</include>
+                    <include>WindowedWordCountIT.java</include>
+                  </includes>
+                  <parallel>all</parallel>
+                  <threadCount>4</threadCount>
+                  <systemPropertyVariables>
+                    <beamTestPipelineOptions>
+                      [
+                      "--project=apache-beam-testing",
+                      "--tempRoot=gs://temp-storage-for-end-to-end-tests",
+                      "--runner=org.apache.beam.runners.dataflow.testing.TestDataflowRunner",
+                      "--streaming=true"
+                      ]
+                    </beamTestPipelineOptions>
+                  </systemPropertyVariables>
+                </configuration>
+              </execution>
               <execution>
                 <id>apex-runner-integration-tests</id>
                 <goals>