You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/11/27 17:53:22 UTC
[1/2] incubator-beam git commit: [BEAM-1049] Update spark version to
1.6.3
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 <ie...@gmail.com>
Authored: Sun Nov 27 11:39:08 2016 +0100
Committer: Isma�l Mej�a <ie...@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 =
[2/2] incubator-beam git commit: [BEAM-1049] This closes #1437
Posted by jb...@apache.org.
[BEAM-1049] This closes #1437
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/93b6050d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93b6050d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/93b6050d
Branch: refs/heads/master
Commit: 93b6050dcc32c6a2821baea7f255f3bd18a07760
Parents: 8cc43aa f600559
Author: Etienne Chauchot and Jean-Baptiste Onofr� <pa...@apache.org>
Authored: Sun Nov 27 18:53:10 2016 +0100
Committer: Etienne Chauchot and Jean-Baptiste Onofr� <pa...@apache.org>
Committed: Sun Nov 27 18:53:10 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(-)
----------------------------------------------------------------------