From f6005593ccf6bdef7c975622d5af39792c7db44c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Isma=C3=ABl=20Mej=C3=ADa?= Date: Sun, 27 Nov 2016 11:39:08 +0100 Subject: [PATCH] [BEAM-1049] Update spark version to 1.6.3 --- runners/spark/pom.xml | 2 +- .../beam/runners/spark/aggregators/AccumulatorSingleton.java | 2 +- .../streaming/SparkRunnerStreamingContextFactory.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/runners/spark/pom.xml b/runners/spark/pom.xml index 88223e2b49c0..da7a72a37a5b 100644 --- a/runners/spark/pom.xml +++ b/runners/spark/pom.xml @@ -34,7 +34,7 @@ UTF-8 UTF-8 - 1.6.2 + 1.6.3 2.2.0 0.9.0.1 3.1.2 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 758372eff762..bc7105fc93ff 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 @@ /** * For resilience, {@link Accumulator}s are required to be wrapped in a Singleton. - * @see accumulators + * @see accumulators */ public class AccumulatorSingleton { 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 af90ff169bb6..d069a1121eb3 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 @@ /** * A {@link JavaStreamingContext} factory for resilience. - * @see how-to-configure-checkpointing + * @see how-to-configure-checkpointing */ public class SparkRunnerStreamingContextFactory implements JavaStreamingContextFactory { private static final Logger LOG =