[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=15203109#comment-15203109 ] Davor Bonaci commented on BEAM-80: -- Pei, is this complete? > Support combiner lifting for

[jira] [Commented] (BEAM-96) Support composing combine functions

[ https://issues.apache.org/jira/browse/BEAM-96?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203110#comment-15203110 ] Davor Bonaci commented on BEAM-96: -- Pei, is this done? > Support composing combine functions >

[jira] [Updated] (BEAM-122) GlobalWindow and allowedLateness can cause inconsistent timer interpretation

[ https://issues.apache.org/jira/browse/BEAM-122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-122: -- Assignee: Mark Shields (was: Frances Perry) > GlobalWindow and allowedLateness can cause inconsistent

[jira] [Created] (BEAM-134) Investigate use of AutoValue

Scott Wegner created BEAM-134: - Summary: Investigate use of AutoValue Key: BEAM-134 URL: https://issues.apache.org/jira/browse/BEAM-134 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-126) KafkaWindowedWordCountExample fails with JobName invalid

[ https://issues.apache.org/jira/browse/BEAM-126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201682#comment-15201682 ] William McCarthy commented on BEAM-126: --- Sweet. Thank you! > KafkaWindowedWordCountExample fails with

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

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

[2/8] incubator-beam git commit: Add casts to fix mvn verify errors

Add casts to fix mvn verify errors Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f06e2a97 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f06e2a97 Diff:

Jenkins build became unstable: beam_MavenVerify #14

See

[jira] [Resolved] (BEAM-125) PubSubIO.Read should be implemented by an UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-125. -- Resolution: Duplicate I went ahead and assigned that one to you. Feel free to change the

[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner

[ https://issues.apache.org/jira/browse/BEAM-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-133: -- Component/s: (was: runner-spark) project-management > Test flakiness in the Spark

[jira] [Commented] (BEAM-133) Test flakiness in the Spark runner

[ https://issues.apache.org/jira/browse/BEAM-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202292#comment-15202292 ] Davor Bonaci commented on BEAM-133: --- Marking resolved for now. > Test flakiness in the Spark runner >

[jira] [Assigned] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-116: --- Assignee: Maximilian Michels > Change runners artifactId to runners-parent >

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

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

Jenkins build is back to stable : beam_MavenVerify » Spark Beam Runner #23

See

[GitHub] incubator-beam pull request: Filter Synthetic Methods in PipelineO...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/41 --- 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] [Commented] (BEAM-118) Add DisplayData to SDK

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

Re: Jenkins build became unstable: beam_MavenVerify #14

Looks like the cached MapR Hadoop dependencies issue is back.. I didn't push anything lately, and the only commit was unrelated. On Thu, Mar 17, 2016 at 4:54 PM Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See > >

[GitHub] incubator-beam pull request: [BEAM-116] change runners artifactId ...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/59 [BEAM-116] change runners artifactId to runners-parent You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/incubator-beam BEAM-116

[1/2] incubator-beam git commit: [BEAM-96] Add composed `CombineFn` builders in `CombineFns`

Repository: incubator-beam Updated Branches: refs/heads/master ac63fd6d4 -> c30326007 [BEAM-96] Add composed `CombineFn` builders in `CombineFns` * `compose()` or `composeKeyed()` are used to start composition * `with()` is used to add an input-transformation, a `CombineFn` and an output

[jira] [Updated] (BEAM-133) Test flakiness in the Spark runner

[ https://issues.apache.org/jira/browse/BEAM-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-133: -- Assignee: Davor Bonaci (was: Amit Sela) > Test flakiness in the Spark runner >

[jira] [Resolved] (BEAM-104) Capability matrix for Beam website

[ https://issues.apache.org/jira/browse/BEAM-104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tyler Akidau resolved BEAM-104. --- Resolution: Fixed Pull requests: https://github.com/apache/incubator-beam-site/pull/2

Re: Jenkins build became unstable: beam_MavenVerify #14

It looks like nowadays, when enabling "Use private Maven repository", you also need to select a strategy. If you want to shield the build against pollution of the local Maven repository by other builds (which I highly recommend, speaking from experience), you should use "Local to the workspace".

[GitHub] incubator-beam pull request: Minor Javadoc fixes

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/49 --- 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 109] Combine.PerKey ignores gro...

GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/63 [Beam 109] Combine.PerKey ignores grouping also by windows You can merge this pull request into a Git repository by running: $ git pull https://github.com/amitsela/incubator-beam

[2/3] incubator-beam-site git commit: Capability matrix page + blog post: - Content as discussed in this thread: http://mail-archives.apache.org/mod_mbox/incubator-beam-dev/201603.mbox/%3CCAB8MnHW6mE3

Capability matrix page + blog post: - Content as discussed in this thread: http://mail-archives.apache.org/mod_mbox/incubator-beam-dev/201603.mbox/%3CCAB8MnHW6mE3GXvemDStCvn_1zMxqXj0ZWLJBgO9hNuHed9ue%2Bw%40mail.gmail.com%3E and as iterated upon by relevant committers in this doc:

Jenkins build became unstable: beam_MavenVerify » Spark Beam Runner #22

See

Jenkins build is back to stable : beam_MavenVerify #15

See

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197806#comment-15197806 ] Kenneth Knowles commented on BEAM-116: -- +1. I reverted it to "runners" but I am convinced by what you

[jira] [Created] (BEAM-136) PipelineOptionsFactory should detect all runners

Daniel Halperin created BEAM-136: Summary: PipelineOptionsFactory should detect all runners Key: BEAM-136 URL: https://issues.apache.org/jira/browse/BEAM-136 Project: Beam Issue Type:

[jira] [Closed] (BEAM-126) KafkaWindowedWordCountExample fails with JobName invalid

[ https://issues.apache.org/jira/browse/BEAM-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-126. --- Resolution: Fixed Thank you for reporting! Fixed with 81d5ff5a561ebcf323caea5bdc4363353e5e60dd.

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201804#comment-15201804 ] Jean-Baptiste Onofré commented on BEAM-116: --- FYI, the PR that I did about the "renaming" already

[3/3] incubator-beam-site git commit: This closes #3

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

[jira] [Closed] (BEAM-11) Integrate Spark runner with Beam

[ https://issues.apache.org/jira/browse/BEAM-11?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-11. - Resolution: Fixed Closed by PR-42 > Integrate Spark runner with Beam > > >

[jira] [Created] (BEAM-120) Integrate DisplayData into DirectPipelineRunner

Scott Wegner created BEAM-120: - Summary: Integrate DisplayData into DirectPipelineRunner Key: BEAM-120 URL: https://issues.apache.org/jira/browse/BEAM-120 Project: Beam Issue Type: Sub-task

incubator-beam git commit: [flink] improvements to the Kafka Example

Repository: incubator-beam Updated Branches: refs/heads/master 0f137169e -> ef1e32dee [flink] improvements to the Kafka Example - use timestamp extractor after ingestion - fix coder runtime exception - correct logging Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo

[1/2] incubator-beam git commit: Close Readers in InProcess Read Evaluators

Repository: incubator-beam Updated Branches: refs/heads/master d39346823 -> 5b5c0e28f Close Readers in InProcess Read Evaluators The readers were formerly left open, which prevents release of any resources that should be released. Project:

[jira] [Created] (BEAM-135) Utilities for "batching" elements in a DoFn

Ben Chambers created BEAM-135: - Summary: Utilities for "batching" elements in a DoFn Key: BEAM-135 URL: https://issues.apache.org/jira/browse/BEAM-135 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-127) Support for Unbounded sinks in Streaming

[ https://issues.apache.org/jira/browse/BEAM-127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202872#comment-15202872 ] Maximilian Michels commented on BEAM-127: - +1 Adding a simple wrapper should be fairly straight

[GitHub] incubator-beam pull request: [BEAM-83] Move Java 8 tests to their ...

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/6 --- 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

[GitHub] incubator-beam pull request: Fix AfterWatermark Early and Late jav...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/54 --- 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-119) Integrate DisplayData into DataflowPipelineRunner

Scott Wegner created BEAM-119: - Summary: Integrate DisplayData into DataflowPipelineRunner Key: BEAM-119 URL: https://issues.apache.org/jira/browse/BEAM-119 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-133) Test flakiness in the Spark runner

Davor Bonaci created BEAM-133: - Summary: Test flakiness in the Spark runner Key: BEAM-133 URL: https://issues.apache.org/jira/browse/BEAM-133 Project: Beam Issue Type: Bug Components:

[GitHub] incubator-beam pull request: Improve the reliability of `mvn verif...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/57 --- 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-123) Skip header row from csv

Davin Pidoto created BEAM-123: - Summary: Skip header row from csv Key: BEAM-123 URL: https://issues.apache.org/jira/browse/BEAM-123 Project: Beam Issue Type: New Feature Reporter:

incubator-beam git commit: [flink] fix UnboundedFlinkSource wrapper

Repository: incubator-beam Updated Branches: refs/heads/master a9c46057e -> 0f137169e [flink] fix UnboundedFlinkSource wrapper - remove unnecessary PipelineOptions cache - use the correct interface types - improve Kafka example Project:

[jira] [Created] (BEAM-125) PubSubIO.Read should be implemented by an UnboundedSource

Mark Shields created BEAM-125: - Summary: PubSubIO.Read should be implemented by an UnboundedSource Key: BEAM-125 URL: https://issues.apache.org/jira/browse/BEAM-125 Project: Beam Issue Type: Bug

[jira] [Closed] (BEAM-113) Update Spark runner README

[ https://issues.apache.org/jira/browse/BEAM-113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-113. -- Resolution: Fixed Closed PR-55 > Update Spark runner README > -- > >

[jira] [Updated] (BEAM-117) Implement the API for Static Display Metadata

[ https://issues.apache.org/jira/browse/BEAM-117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers updated BEAM-117: -- Issue Type: New Feature (was: Bug) > Implement the API for Static Display Metadata >

[7/8] incubator-beam git commit: Fix typo in javadoc

Fix typo in javadoc Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a2a2c7b9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a2a2c7b9 Diff:

[GitHub] incubator-beam pull request: [BEAM-96] Add composed combine functi...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/23 --- 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] [Commented] (BEAM-53) PubSubIO: reimplement in Java

[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201823#comment-15201823 ] Mark Shields commented on BEAM-53: -- Working on this now. First goal is to support custom timestamps,

[jira] [Closed] (BEAM-36) TimestampedValueInMultipleWindows should use a more compact set representation

[ https://issues.apache.org/jira/browse/BEAM-36?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers closed BEAM-36. Resolution: Won't Fix As per discussion on https://github.com/apache/incubator-beam/pull/43: "We looked some

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[1/3] incubator-beam-site git commit: Capability matrix page + blog post: - Content as discussed in this thread: http://mail-archives.apache.org/mod_mbox/incubator-beam-dev/201603.mbox/%3CCAB8MnHW6mE3

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site a8ebbad3e -> b04b002ca http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/931d7f51/content/blog/index.html -- diff --git

[jira] [Updated] (BEAM-53) PubSubIO: reimplement in Java

[ https://issues.apache.org/jira/browse/BEAM-53?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-53: Assignee: Mark Shields > PubSubIO: reimplement in Java > - > >

[jira] [Updated] (BEAM-134) Investigate use of AutoValue

[ https://issues.apache.org/jira/browse/BEAM-134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-134: -- Assignee: Scott Wegner (was: Davor Bonaci) > Investigate use of AutoValue >

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201317#comment-15201317 ] Maximilian Michels commented on BEAM-116: - Frankly, I don't think that is possible with Maven. Even

Re: Jenkins build became unstable: beam_MavenVerify #14

Adding Jason explicitly. This is somewhat expected. Thanks Andreas. On Thu, Mar 17, 2016 at 8:08 AM, Andreas Veithen wrote: > It looks like nowadays, when enabling "Use private Maven repository", you > also need to select a strategy. If you want to shield the build

[5/8] incubator-beam git commit: Move Java 8 examples to their own module

Move Java 8 examples to their own module This allows easy setting of the compiler source and target version to 1.8 without any fragile plugin configuration. It also allows the import into Eclipse to easily set separate compliance levels, as this is done per-Eclipse-project. This parallels the

[jira] [Commented] (BEAM-136) PipelineOptionsFactory should detect all runners

[ https://issues.apache.org/jira/browse/BEAM-136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202429#comment-15202429 ] Thomas Groh commented on BEAM-136: -- The default collection of runners is obtained by using

[jira] [Updated] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-116: -- Component/s: runner-core > Change runners artifactId to runners-parent >