Repository: incubator-beam Updated Branches: refs/heads/master 8cc43aa70 -> 93b6050dc
[BEAM-1049] Update spark version to 1.6.3 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f6005593 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f6005593 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f6005593 Branch: refs/heads/master Commit: f6005593ccf6bdef7c975622d5af39792c7db44c Parents: 8cc43aa Author: Ismaël MejÃa <ieme...@gmail.com> Authored: Sun Nov 27 11:39:08 2016 +0100 Committer: Ismaël MejÃa <ieme...@gmail.com> Committed: Sun Nov 27 14:49:06 2016 +0100 ---------------------------------------------------------------------- runners/spark/pom.xml | 2 +- .../beam/runners/spark/aggregators/AccumulatorSingleton.java | 2 +- .../translation/streaming/SparkRunnerStreamingContextFactory.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f6005593/runners/spark/pom.xml ---------------------------------------------------------------------- diff --git a/runners/spark/pom.xml b/runners/spark/pom.xml index 88223e2..da7a72a 100644 --- a/runners/spark/pom.xml +++ b/runners/spark/pom.xml @@ -34,7 +34,7 @@ <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> - <spark.version>1.6.2</spark.version> + <spark.version>1.6.3</spark.version> <hadoop.version>2.2.0</hadoop.version> <kafka.version>0.9.0.1</kafka.version> <dropwizard.metrics.version>3.1.2</dropwizard.metrics.version> http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f6005593/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AccumulatorSingleton.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AccumulatorSingleton.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AccumulatorSingleton.java index 758372e..bc7105f 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AccumulatorSingleton.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AccumulatorSingleton.java @@ -24,7 +24,7 @@ import org.apache.spark.api.java.JavaSparkContext; /** * For resilience, {@link Accumulator}s are required to be wrapped in a Singleton. - * @see <a href="https://spark.apache.org/docs/1.6.2/streaming-programming-guide.html#accumulators-and-broadcast-variables";>accumulators</a> + * @see <a href="https://spark.apache.org/docs/1.6.3/streaming-programming-guide.html#accumulators-and-broadcast-variables";>accumulators</a> */ public class AccumulatorSingleton { http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f6005593/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java index af90ff1..d069a11 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java @@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory; /** * A {@link JavaStreamingContext} factory for resilience. - * @see <a href="https://spark.apache.org/docs/1.6.2/streaming-programming-guide.html#how-to-configure-checkpointing";>how-to-configure-checkpointing</a> + * @see <a href="https://spark.apache.org/docs/1.6.3/streaming-programming-guide.html#how-to-configure-checkpointing";>how-to-configure-checkpointing</a> */ public class SparkRunnerStreamingContextFactory implements JavaStreamingContextFactory { private static final Logger LOG =
