This closes #1393
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/875631f0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/875631f0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/875631f0 Branch: refs/heads/master Commit: 875631f07b1e4556afec28dc850bd7fe2d07444b Parents: d93e9a8 dafd5be Author: Sela <ans...@paypal.com> Authored: Sun Nov 20 19:26:52 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Sun Nov 20 19:26:52 2016 +0200 ---------------------------------------------------------------------- .../runners/spark/SparkPipelineOptions.java | 6 -- .../apache/beam/runners/spark/SparkRunner.java | 5 +- .../spark/translation/EvaluationContext.java | 59 +++++++++++++------- .../SparkRunnerStreamingContextFactory.java | 3 +- .../streaming/EmptyStreamAssertionTest.java | 3 +- .../streaming/FlattenStreamingTest.java | 4 +- .../streaming/KafkaStreamingTest.java | 11 ++-- .../ResumeFromCheckpointStreamingTest.java | 3 +- .../streaming/SimpleStreamingWordCountTest.java | 4 +- .../streaming/utils/PAssertStreaming.java | 8 ++- .../SparkTestPipelineOptionsForStreaming.java | 1 - 11 files changed, 60 insertions(+), 47 deletions(-) ----------------------------------------------------------------------