Repository: beam Updated Branches: refs/heads/master a81c45781 -> b2428ea60
This closes #2119 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2428ea6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2428ea6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b2428ea6 Branch: refs/heads/master Commit: b2428ea60fdc4363bb2734abe1b247f36d0cfe44 Parents: a81c457 3408f60 Author: Thomas Groh <tg...@google.com> Authored: Wed Mar 1 13:05:49 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Mar 1 13:05:49 2017 -0800 ---------------------------------------------------------------------- .../beam/runners/apex/TestApexRunner.java | 10 --- .../beam/runners/flink/TestFlinkRunner.java | 9 --- .../dataflow/testing/TestDataflowRunner.java | 17 ++--- .../testing/TestDataflowRunnerTest.java | 3 +- runners/spark/pom.xml | 4 ++ .../beam/runners/spark/TestSparkRunner.java | 76 ++++++++++++-------- .../beam/runners/spark/ForceStreamingTest.java | 2 + .../main/java/org/apache/beam/sdk/Pipeline.java | 4 +- .../apache/beam/sdk/runners/PipelineRunner.java | 14 ---- .../org/apache/beam/sdk/testing/PAssert.java | 64 +++++++++++++++++ .../apache/beam/sdk/testing/PAssertTest.java | 30 ++++++++ 11 files changed, 154 insertions(+), 79 deletions(-) ----------------------------------------------------------------------
