This closes #1364
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dbbd5e44 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dbbd5e44 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/dbbd5e44 Branch: refs/heads/master Commit: dbbd5e44800586c3f1a2efc58b91d79126c843d3 Parents: 2011102 dd740ee Author: Sela <ans...@paypal.com> Authored: Wed Nov 16 01:51:51 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Wed Nov 16 01:51:51 2016 +0200 ---------------------------------------------------------------------- .../runners/spark/ProvidedSparkContextTest.java | 2 - .../metrics/sink/NamedAggregatorsTest.java | 4 +- .../beam/runners/spark/io/AvroPipelineTest.java | 5 +-- .../beam/runners/spark/io/NumShardsTest.java | 5 +-- .../io/hadoop/HadoopFileFormatPipelineTest.java | 5 +-- .../spark/translation/SideEffectsTest.java | 34 ++++++--------- .../streaming/EmptyStreamAssertionTest.java | 5 ++- .../streaming/FlattenStreamingTest.java | 5 ++- .../streaming/KafkaStreamingTest.java | 5 ++- .../ResumeFromCheckpointStreamingTest.java | 5 ++- .../streaming/SimpleStreamingWordCountTest.java | 5 ++- .../utils/SparkTestPipelineOptions.java | 42 +++++++++++++++++++ .../SparkTestPipelineOptionsForStreaming.java | 44 ++++++++++++++++++++ .../streaming/utils/TestPipelineOptions.java | 25 ----------- .../utils/TestPipelineOptionsForStreaming.java | 44 -------------------- 15 files changed, 121 insertions(+), 114 deletions(-) ----------------------------------------------------------------------
