This closes #1272
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/14e093a0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/14e093a0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/14e093a0 Branch: refs/heads/apex-runner Commit: 14e093a0a574c8c3920a83c38e411a06b29bf44b Parents: 46fbfe0 90a75d1 Author: Sela <ans...@paypal.com> Authored: Sat Nov 5 00:02:22 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Sat Nov 5 00:02:22 2016 +0200 ---------------------------------------------------------------------- .../runners/spark/SparkPipelineOptions.java | 3 +-- .../SparkRunnerStreamingContextFactory.java | 23 +++++--------------- .../streaming/EmptyStreamAssertionTest.java | 3 +-- .../streaming/FlattenStreamingTest.java | 6 ++--- .../streaming/KafkaStreamingTest.java | 6 ++--- .../ResumeFromCheckpointStreamingTest.java | 3 +-- .../streaming/SimpleStreamingWordCountTest.java | 3 +-- .../utils/TestOptionsForStreaming.java | 12 +++++----- 8 files changed, 19 insertions(+), 40 deletions(-) ----------------------------------------------------------------------
