beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/2] beam git commit: Dataflow streaming config for WordCountIT and WindowedWordCountIT
Date Mon, 20 Mar 2017 20:46:02 GMT
Repository: beam
Updated Branches:
  refs/heads/master 6fa1fca4f -> 32f7e0c71


Dataflow streaming config for WordCountIT and WindowedWordCountIT


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b58117c6
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b58117c6
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b58117c6

Branch: refs/heads/master
Commit: b58117c6fa7554e6988dbacff7c23478a76887bd
Parents: 3fde7b2
Author: Kenneth Knowles <klk@google.com>
Authored: Fri Mar 3 13:34:05 2017 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Fri Mar 3 15:44:54 2017 -0800

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


http://git-wip-us.apache.org/repos/asf/beam/blob/b58117c6/examples/java/pom.xml
----------------------------------------------------------------------
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index 9da814b..fafd5c8 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -269,6 +269,31 @@
                 </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>
                   <goal>integration-test</goal>


Mime
View raw message