Jenkins build is back to normal : beam_MavenVerify #47

2016-03-10 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_MavenVerify ยป Google Cloud Dataflow Java SDK - All #45

2016-03-10 Thread Apache Jenkins Server
See Changes: [tgroh] Implement InProcessEvaluationContext [tgroh] fixup! Implement InProcessEvaluationContext [tgroh] fixup! Implement InProcessEvaluationContext [tgroh]

[5/6] incubator-beam git commit: Undo

2016-03-10 Thread kenn
Undo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1e3d86d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1e3d86d Diff:

[jira] [Commented] (BEAM-80) Support combiner lifting for (Keyed)CombineWithContext

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-80?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15190141#comment-15190141 ] ASF GitHub Bot commented on BEAM-80: GitHub user peihe opened a pull request:

[GitHub] incubator-beam pull request: Ken noticed was closed due to a spuri...

2016-03-10 Thread mshields822
GitHub user mshields822 opened a pull request: https://github.com/apache/incubator-beam/pull/38 Ken noticed was closed due to a spurious commit message in the spark runner commit. Sigh. You can merge this pull request into a Git repository by running: $ git pull

[38/50] [abbrv] incubator-beam git commit: Update README to latest version (0.4.0).

2016-03-10 Thread amitsela
Update README to latest version (0.4.0). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/922508c0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/922508c0 Diff:

[07/50] [abbrv] incubator-beam git commit: Set the RDD's name from the PValue's name, to help diagnosis.

2016-03-10 Thread amitsela
Set the RDD's name from the PValue's name, to help diagnosis. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5069eedb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5069eedb Diff:

[12/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.3.0

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.3.0 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d7a35bdf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d7a35bdf Diff:

[45/50] [abbrv] incubator-beam git commit: Add spark-streaming support to spark-dataflow

2016-03-10 Thread amitsela
Add spark-streaming support to spark-dataflow Add support for application name and streaming (default: false) Add pipeline options for streaming Add print output as an unbounded write Add default window strategy to represent Spark streaming micro-batches as fixed windows This translator

[22/50] [abbrv] incubator-beam git commit: Update README to latest version (0.2.2).

2016-03-10 Thread amitsela
Update README to latest version (0.2.2). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/27349adc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/27349adc Diff:

[46/50] [abbrv] incubator-beam git commit: First wave of changes from feedback

2016-03-10 Thread amitsela
First wave of changes from feedback Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1229b009 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1229b009 Diff:

[42/50] [abbrv] incubator-beam git commit: The example needs --inputFile, not --input, to designate the input file

2016-03-10 Thread amitsela
The example needs --inputFile, not --input, to designate the input file Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f930380b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f930380b

[44/50] [abbrv] incubator-beam git commit: Add spark-streaming support to spark-dataflow

2016-03-10 Thread amitsela
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7a2e9a72/runners/spark/src/main/java/com/cloudera/dataflow/spark/streaming/SparkStreamingPipelineOptions.java -- diff --git

[04/50] [abbrv] incubator-beam git commit: Add a system property, dataflow.spark.directBroadcast, to allow pipelines to bypass coders for broadcasts.

2016-03-10 Thread amitsela
Add a system property, dataflow.spark.directBroadcast, to allow pipelines to bypass coders for broadcasts. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2d00b3bd Tree:

[16/50] [abbrv] incubator-beam git commit: Avoid warning email by not running codecov unless it was configured; update jacoco and shade plugins

2016-03-10 Thread amitsela
Avoid warning email by not running codecov unless it was configured; update jacoco and shade plugins Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3b1441f4 Tree:

[40/50] [abbrv] incubator-beam git commit: Update README to latest version (0.4.1).

2016-03-10 Thread amitsela
Update README to latest version (0.4.1). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4b98c163 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4b98c163 Diff:

[jira] [Commented] (BEAM-6) Import Spark Runner code

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15189926#comment-15189926 ] ASF GitHub Bot commented on BEAM-6: --- Github user asfgit closed the pull request at:

[14/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.2.3

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.2.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/fe0b8e9a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fe0b8e9a Diff:

[01/50] [abbrv] incubator-beam git commit: Implement getAggregatorValues.

2016-03-10 Thread amitsela
Repository: incubator-beam Updated Branches: refs/heads/master 0442a2416 -> b2b5f429f Implement getAggregatorValues. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/89e2bb52 Tree:

[34/50] [abbrv] incubator-beam git commit: Add tests for Spark 1.4 / 1.5 in Travis

2016-03-10 Thread amitsela
Add tests for Spark 1.4 / 1.5 in Travis Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/87797015 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/87797015 Diff:

[25/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare for next development iteration

2016-03-10 Thread amitsela
[maven-release-plugin] prepare for next development iteration Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/72167a2c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/72167a2c Diff:

[36/50] [abbrv] incubator-beam git commit: Correct input parameter is --inputFile

2016-03-10 Thread amitsela
Correct input parameter is --inputFile Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0c84c9d7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0c84c9d7 Diff:

[41/50] [abbrv] incubator-beam git commit: Add support for writes with HadoopIO. This allows Hadoop FileOutputFormats to be used with Spark Dataflow, as long as they implement the ShardNameTemplateAwa

2016-03-10 Thread amitsela
Add support for writes with HadoopIO. This allows Hadoop FileOutputFormats to be used with Spark Dataflow, as long as they implement the ShardNameTemplateAware interface. This is easily achieved by subclassing the desired FileOutputFormat class, see TemplatedSequenceFileOutputFormat for an

[23/50] [abbrv] incubator-beam git commit: Prevent possible NPE.

2016-03-10 Thread amitsela
Prevent possible NPE. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44158622 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/44158622 Diff:

[11/50] [abbrv] incubator-beam git commit: Remove some HadoopIO.Read.Bound factory methods and fluent setters; always set key/value at creation

2016-03-10 Thread amitsela
Remove some HadoopIO.Read.Bound factory methods and fluent setters; always set key/value at creation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b47a8d0a Tree:

[32/50] [abbrv] incubator-beam git commit: Update README to latest version (0.4.2).

2016-03-10 Thread amitsela
Update README to latest version (0.4.2). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/90c49b4f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/90c49b4f Diff:

[08/50] [abbrv] incubator-beam git commit: More cleanup. View.AsSingleton is already exercised by the TfIdf test.

2016-03-10 Thread amitsela
More cleanup. View.AsSingleton is already exercised by the TfIdf test. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/78d66145 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/78d66145 Diff:

[15/50] [abbrv] incubator-beam git commit: Only accumulate outputs from one call to processContext, rather than for the whole partition.

2016-03-10 Thread amitsela
Only accumulate outputs from one call to processContext, rather than for the whole partition. Fixes https://github.com/cloudera/spark-dataflow/issues/61. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[20/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.4.0

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.4.0 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ec8d59c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5ec8d59c Diff:

[29/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.4.2

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.4.2 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b8949b81 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b8949b81 Diff:

[21/50] [abbrv] incubator-beam git commit: Fix bug where values written to the output in DoFn#startBundle and DoFn#finishBundle were being ignored. Introduced in 62830a0.

2016-03-10 Thread amitsela
Fix bug where values written to the output in DoFn#startBundle and DoFn#finishBundle were being ignored. Introduced in 62830a0. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/76815589 Tree:

[26/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.2.2

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.2.2 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ebf70534 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ebf70534 Diff:

[33/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare release spark-dataflow-0.4.1

2016-03-10 Thread amitsela
[maven-release-plugin] prepare release spark-dataflow-0.4.1 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3e767f5a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3e767f5a Diff:

[13/50] [abbrv] incubator-beam git commit: [maven-release-plugin] prepare for next development iteration

2016-03-10 Thread amitsela
[maven-release-plugin] prepare for next development iteration Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4ec8c606 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4ec8c606 Diff:

[18/50] [abbrv] incubator-beam git commit: Update to dataflow 0.4.150727.

2016-03-10 Thread amitsela
Update to dataflow 0.4.150727. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/89945bf6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/89945bf6 Diff:

[jira] [Commented] (BEAM-91) Retractions

2016-03-10 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1513#comment-1513 ] Daniel Halperin commented on BEAM-91: - This is the BEAM version of