[BEAM-294] This closes #884
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/20467832 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/20467832 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/20467832 Branch: refs/heads/master Commit: 2046783235f0011e6003a2a9254b26aa5c3c27b9 Parents: b21c35d e233e5f Author: Jean-Baptiste Onofré <[email protected]> Authored: Fri Aug 26 09:39:35 2016 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Fri Aug 26 09:39:35 2016 +0200 ---------------------------------------------------------------------- runners/spark/pom.xml | 2 +- .../main/java/org/apache/beam/runners/spark/SparkRunner.java | 2 +- .../java/org/apache/beam/runners/spark/TestSparkRunner.java | 2 +- .../beam/runners/spark/aggregators/NamedAggregators.java | 2 +- .../org/apache/beam/runners/spark/examples/WordCount.java | 2 +- .../runners/spark/io/hadoop/ShardNameTemplateHelper.java | 6 +++--- .../apache/beam/runners/spark/translation/DoFnFunction.java | 2 +- .../runners/spark/translation/SparkPipelineTranslator.java | 2 +- .../beam/runners/spark/translation/SparkRuntimeContext.java | 2 +- .../beam/runners/spark/translation/TransformTranslator.java | 4 ++-- .../translation/streaming/StreamingTransformTranslator.java | 8 ++++---- .../org/apache/beam/runners/spark/util/BroadcastHelper.java | 4 ++-- .../runners/spark/translation/TransformTranslatorTest.java | 2 +- .../spark/translation/streaming/KafkaStreamingTest.java | 2 +- 14 files changed, 21 insertions(+), 21 deletions(-) ----------------------------------------------------------------------
