Repository: incubator-beam Updated Branches: refs/heads/master ac0875de8 -> 3144363c0
Closes #743 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3144363c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3144363c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3144363c Branch: refs/heads/master Commit: 3144363c067e8bd5d1b83aca2f4057b6bc33ed04 Parents: c314e67 ac0875d Author: Dan Halperin <dhalp...@google.com> Authored: Wed Aug 3 23:01:15 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Aug 3 23:01:15 2016 -0700 ---------------------------------------------------------------------- .../runners/spark/SparkPipelineOptions.java | 6 ++++ .../apache/beam/runners/spark/SparkRunner.java | 14 +++------ .../runners/spark/SparkRunnerRegistrar.java | 6 ++-- .../spark/SparkStreamingPipelineOptions.java | 32 -------------------- .../beam/runners/spark/TestSparkRunner.java | 2 -- .../apache/beam/runners/spark/DeDupTest.java | 2 +- .../beam/runners/spark/EmptyInputTest.java | 2 +- .../beam/runners/spark/SimpleWordCountTest.java | 4 +-- .../runners/spark/SparkRunnerRegistrarTest.java | 2 +- .../apache/beam/runners/spark/TfIdfTest.java | 2 +- .../beam/runners/spark/io/AvroPipelineTest.java | 2 +- .../beam/runners/spark/io/NumShardsTest.java | 2 +- .../io/hadoop/HadoopFileFormatPipelineTest.java | 2 +- .../spark/translation/CombineGloballyTest.java | 2 +- .../spark/translation/CombinePerKeyTest.java | 2 +- .../spark/translation/DoFnOutputTest.java | 6 ++-- .../translation/MultiOutputWordCountTest.java | 2 +- .../spark/translation/SerializationTest.java | 2 +- .../spark/translation/SideEffectsTest.java | 8 ++--- .../streaming/FlattenStreamingTest.java | 8 ++--- .../streaming/KafkaStreamingTest.java | 13 ++++---- .../streaming/SimpleStreamingWordCountTest.java | 8 ++--- .../streaming/utils/EmbeddedKafkaCluster.java | 4 ++- 23 files changed, 49 insertions(+), 84 deletions(-) ----------------------------------------------------------------------