beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [1/2] incubator-beam git commit: [BEAM-1049] Update spark version to 1.6.3
Date Sun, 27 Nov 2016 17:53:22 GMT
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 <iemejia@gmail.com>
Authored: Sun Nov 27 11:39:08 2016 +0100
Committer: Ismaël Mejía <iemejia@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 =


Mime
View raw message