[GitHub] incubator-beam pull request: Send travis-ci emails to their defaul...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/19 Send travis-ci emails to their default recipients You can merge this pull request into a Git repository by running: $ git pull https://github.com/kennknowles/incubator-beam

[jira] [Updated] (BEAM-87) Allow heap dumps on OOM to be disabled (default)

[ https://issues.apache.org/jira/browse/BEAM-87?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-87: - Assignee: Mark Shields (was: Frances Perry) > Allow heap dumps on OOM to be disabled (default) >

[jira] [Updated] (BEAM-87) Allow heap dumps on OOM to be disabled (default)

[ https://issues.apache.org/jira/browse/BEAM-87?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-87: - Component/s: (was: runner-core) sdk-java-core > Allow heap dumps on OOM to be disabled

[jira] [Updated] (BEAM-89) DataflowPipelineJob should have an API that prints messages but doesn't wait for completion

[ https://issues.apache.org/jira/browse/BEAM-89?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-89: - Assignee: (was: Davor Bonaci) > DataflowPipelineJob should have an API that prints messages but doesn't

[jira] [Commented] (BEAM-89) DataflowPipelineJob should have an API that prints messages but doesn't wait for completion

[ https://issues.apache.org/jira/browse/BEAM-89?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179215#comment-15179215 ] Davor Bonaci commented on BEAM-89: -- Yup; waitToFinish() should do just that -- wait until the job finishes.

[jira] [Updated] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-88: - Assignee: (was: Davor Bonaci) > DataflowPipelineOptions.tempLocation doesn't really default to

Jenkins build is back to normal : beam #10

See

Jenkins build is back to normal : beam » Google Cloud Dataflow Java SDK - Parent #10

See

[jira] [Commented] (BEAM-94) CountingInput should be able to limit the rate at which output is produced

[ https://issues.apache.org/jira/browse/BEAM-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178821#comment-15178821 ] ASF GitHub Bot commented on BEAM-94: GitHub user tgroh opened a pull request:

[2/2] incubator-beam git commit: This closes #14

This closes #14 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/05285702 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/05285702 Diff:

[GitHub] incubator-beam pull request: [BEAM-90] TestCountingSource can thro...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/14 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[1/2] incubator-beam git commit: [BEAM-90] TestCountingSource can throw on checkpointing

Repository: incubator-beam Updated Branches: refs/heads/master 5a7bd8083 -> 052857023 [BEAM-90] TestCountingSource can throw on checkpointing Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/320a75b1

[jira] [Commented] (BEAM-86) CountingSource should expose PTransform<PInput, PCollection> rather than sources directly

[ https://issues.apache.org/jira/browse/BEAM-86?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178804#comment-15178804 ] ASF GitHub Bot commented on BEAM-86: Github user tgroh closed the pull request at:

Build failed in Jenkins: beam #8

See Changes: [markshields] [BEAM-87] Support opt-in for heap dumps [markshields] Clarrify heap file path. [klk] Fix typo [dhalperi] Add CountingInput as a PTransform -- [...truncated 1781 lines...]

Build failed in Jenkins: beam » Google Cloud Dataflow Java SDK - Parent #8

See -- Established TCP socket on 46182 maven32-agent.jar already up to date maven32-interceptor.jar already up to date maven3-interceptor-commons.jar

[GitHub] incubator-beam pull request: [BEAM-86] Add CountingInput as a PTra...

Github user tgroh closed the pull request at: https://github.com/apache/incubator-beam/pull/10 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Created] (BEAM-94) CountingInput should be able to limit the rate at which output is produced

Thomas Groh created BEAM-94: --- Summary: CountingInput should be able to limit the rate at which output is produced Key: BEAM-94 URL: https://issues.apache.org/jira/browse/BEAM-94 Project: Beam

incubator-beam git commit: Add CountingInput as a PTransform

Repository: incubator-beam Updated Branches: refs/heads/master 365029863 -> 5a7bd8083 Add CountingInput as a PTransform This transform produces an unbounded PCollection containing longs based on a CountingSource. Deprecate methods producing a Source in CountingSource. Project:

[GitHub] incubator-beam pull request: [BEAM-87] Support opt-in for heap dum...

Github user mshields822 closed the pull request at: https://github.com/apache/incubator-beam/pull/8 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (BEAM-87) Allow heap dumps on OOM to be disabled (default)

[ https://issues.apache.org/jira/browse/BEAM-87?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178730#comment-15178730 ] ASF GitHub Bot commented on BEAM-87: Github user mshields822 closed the pull request at:

[1/4] incubator-beam git commit: [BEAM-87] Support opt-in for heap dumps

Repository: incubator-beam Updated Branches: refs/heads/master 5e8250411 -> 365029863 [BEAM-87] Support opt-in for heap dumps Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5cd05891 Tree:

[4/4] incubator-beam git commit: Closes #8

Closes #8 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/36502986 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/36502986 Diff:

[2/4] incubator-beam git commit: Clarrify heap file path.

Clarrify heap file path. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/616f898e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/616f898e Diff:

Build failed in Jenkins: beam » Google Cloud Dataflow Java SDK - Parent #7

See -- Established TCP socket on 43584 maven32-agent.jar already up to date maven32-interceptor.jar already up to date maven3-interceptor-commons.jar

Build failed in Jenkins: beam #7

See Changes: [peihe0] [BEAM-80] Swap the order of timers and elements sent to ReduceFnRunner -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1

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

[ https://issues.apache.org/jira/browse/BEAM-80?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178700#comment-15178700 ] ASF GitHub Bot commented on BEAM-80: Github user asfgit closed the pull request at:

[1/2] incubator-beam git commit: [BEAM-80] Swap the order of timers and elements sent to ReduceFnRunner

Repository: incubator-beam Updated Branches: refs/heads/master 7582212f5 -> 5e8250411 [BEAM-80] Swap the order of timers and elements sent to ReduceFnRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: Closes #9

Closes #9 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5e825041 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5e825041 Diff:

[GitHub] incubator-beam pull request: [BEAM-80] Change ReduceFnRunner to pr...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/9 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] incubator-beam pull request: [BEAM-93] Add subnetwork support and ...

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/16 [BEAM-93] Add subnetwork support and increment Dataflow API dependency Add subnetwork to the Dataflow runner through a new option. This support was added in the newest API release, so

[jira] [Commented] (BEAM-93) Support Compute Engine Subnetworks

[ https://issues.apache.org/jira/browse/BEAM-93?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178378#comment-15178378 ] ASF GitHub Bot commented on BEAM-93: GitHub user sammcveety opened a pull request:

[jira] [Created] (BEAM-93) Support Compute Engine Subnetworks

Sam McVeety created BEAM-93: --- Summary: Support Compute Engine Subnetworks Key: BEAM-93 URL: https://issues.apache.org/jira/browse/BEAM-93 Project: Beam Issue Type: Improvement

[GitHub] incubator-beam pull request: Register debuggee prior to job submis...

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/15 Register debuggee prior to job submission @davorbonaci You can merge this pull request into a Git repository by running: $ git pull https://github.com/bjchambers/incubator-beam cdbg

[jira] [Updated] (BEAM-92) Data-dependent sinks

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-92: Component/s: beam-model > Data-dependent sinks > > > Key: BEAM-92

[jira] [Commented] (BEAM-92) Data-dependent sinks

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178173#comment-15178173 ] Daniel Halperin commented on BEAM-92: - Abstractly, this is very easy to accomplish when the Sink is

[jira] [Commented] (BEAM-92) Data-dependent sinks

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178147#comment-15178147 ] Eugene Kirpichov commented on BEAM-92: -- Note: it's not obvious how this API generalizes to streaming

[GitHub] incubator-beam pull request: [BEAM-90] TestCountingSource can thro...

GitHub user mshields822 opened a pull request: https://github.com/apache/incubator-beam/pull/14 [BEAM-90] TestCountingSource can throw on checkpointing You can merge this pull request into a Git repository by running: $ git pull https://github.com/mshields822/incubator-beam

[jira] [Created] (BEAM-92) Data-dependent sinks

Eugene Kirpichov created BEAM-92: Summary: Data-dependent sinks Key: BEAM-92 URL: https://issues.apache.org/jira/browse/BEAM-92 Project: Beam Issue Type: New Feature Reporter: