[GitHub] incubator-beam pull request #738: Create DoFnInvoker instances in the packag...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/738 Create DoFnInvoker instances in the package of the invoked DoFn Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_SparkLocal #24

See

[jira] [Commented] (BEAM-491) Reuse context and disable UI in the Spark runner tests

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

[GitHub] incubator-beam pull request #736: [BEAM-491]-Reuse context and disable UI in...

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

[1/2] incubator-beam git commit: Reuse context and disable UI.

Repository: incubator-beam Updated Branches: refs/heads/master 68850b4b8 -> e8695a1b6 Reuse context and disable UI. Rename dataflow to beam. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e62bfdb1

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

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

[GitHub] incubator-beam pull request #737: Add Side-Input Support in Flink Streaming ...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/737 Add Side-Input Support in Flink Streaming Runner This does several things in somewhat isolated steps: - Unify the operator wrappers. Before there where 4 different DoFn/Window

[jira] [Commented] (BEAM-491) Reuse context and disable UI in the Spark runner tests

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

[GitHub] incubator-beam pull request #736: [BEAM-491]-Reuse context and disable UI in...

GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/736 [BEAM-491]-Reuse context and disable UI in the Spark runner tests Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Created] (BEAM-491) Reuse context and disable UI in the Spark runner tests

Amit Sela created BEAM-491: -- Summary: Reuse context and disable UI in the Spark runner tests Key: BEAM-491 URL: https://issues.apache.org/jira/browse/BEAM-491 Project: Beam Issue Type: Bug

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #831

See

[GitHub] incubator-beam pull request #735: Implement Aggregators directly in the Dire...

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/735 Implement Aggregators directly in the DirectRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make sure the PR

Jenkins build is back to stable : beam_PostCommit_MavenVerify #982

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #982

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #830

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #981

See

[jira] [Commented] (BEAM-386) Dataflow runner to support Read.Bounded in streaming mode.

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

[GitHub] incubator-beam pull request #704: [BEAM-386] Remove StreamingCreate in Dataf...

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

[2/2] incubator-beam git commit: [BEAM-386] Remove StreamingCreate in DataflowRunner

[BEAM-386] Remove StreamingCreate in DataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fc99c53f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fc99c53f Diff:

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

Repository: incubator-beam Updated Branches: refs/heads/master 3c6e147d9 -> 68850b4b8 Closes #704 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/68850b4b Tree:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_SparkLocal #23

See

[3/3] incubator-beam git commit: Closes #731

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

[GitHub] incubator-beam pull request #731: Remove spark test dependency on DirectRunn...

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

[2/3] incubator-beam git commit: Remove spark test dependency on DirectRunner

Remove spark test dependency on DirectRunner Rather than assert that SparkRunner matches DirectRunner, assert that SparkRunner is correct. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51011581 Tree:

[1/3] incubator-beam git commit: Spark tests: force spark runner

Repository: incubator-beam Updated Branches: refs/heads/master 8597a3cf4 -> 3c6e147d9 Spark tests: force spark runner They were somehow using the DirectRunner before. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Resolved] (BEAM-489) remove headerLocation from maven-checkstyle-plugin configuration

[ https://issues.apache.org/jira/browse/BEAM-489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-489. -- Resolution: Fixed Fix Version/s: Not applicable > remove headerLocation from

[jira] [Commented] (BEAM-474) Tests which evaluate DisplayData but don't run a pipeline should be marked @NeedsRunner not @RunnableOnService

[ https://issues.apache.org/jira/browse/BEAM-474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394061#comment-15394061 ] Luke Cwik commented on BEAM-474: The issue is that none of the display data tests execute the pipeline and

[GitHub] incubator-beam pull request #734: [BEAM-489] remove headerLocation from mave...

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

[1/2] incubator-beam git commit: [BEAM-489] remove headerLocation from maven-checkstyle-plugin

Repository: incubator-beam Updated Branches: refs/heads/master d02d2de09 -> 8597a3cf4 [BEAM-489] remove headerLocation from maven-checkstyle-plugin Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

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

[jira] [Commented] (BEAM-474) Tests which evaluate DisplayData but don't run a pipeline should be marked @NeedsRunner not @RunnableOnService

[ https://issues.apache.org/jira/browse/BEAM-474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394011#comment-15394011 ] Scott Wegner commented on BEAM-474: --- My understanding when we wrote the tests was different. I thought the

[jira] [Created] (BEAM-490) Swap to using CoGBK as grouping primitive instead of GBK

Luke Cwik created BEAM-490: -- Summary: Swap to using CoGBK as grouping primitive instead of GBK Key: BEAM-490 URL: https://issues.apache.org/jira/browse/BEAM-490 Project: Beam Issue Type:

[jira] [Updated] (BEAM-474) Tests which evaluate DisplayData but don't run a pipeline should be marked @NeedsRunner not @RunnableOnService

[ https://issues.apache.org/jira/browse/BEAM-474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-474: --- Priority: Minor (was: Major) > Tests which evaluate DisplayData but don't run a pipeline should be marked >

[jira] [Commented] (BEAM-461) Create custom Kinesis source

[ https://issues.apache.org/jira/browse/BEAM-461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393731#comment-15393731 ] Przemyslaw Pastuszka commented on BEAM-461: --- All the comments in the review have been addressed.

[jira] [Commented] (BEAM-489) remove headerLocation from maven-checkstyle-plugin configuration

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

[GitHub] incubator-beam pull request #734: [BEAM-489] remove headerLocation from mave...

GitHub user manuzhang opened a pull request: https://github.com/apache/incubator-beam/pull/734 [BEAM-489] remove headerLocation from maven-checkstyle-plugin Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Created] (BEAM-489) remove headerLocation from maven-checkstyle-plugin configuration

Manu Zhang created BEAM-489: --- Summary: remove headerLocation from maven-checkstyle-plugin configuration Key: BEAM-489 URL: https://issues.apache.org/jira/browse/BEAM-489 Project: Beam Issue

[1/2] incubator-beam git commit: [flink] improve example section in README

Repository: incubator-beam Updated Branches: refs/heads/master 267136fb6 -> d02d2de09 [flink] improve example section in README - updates the README - repairs broken exec configuration Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #724: [flink] improve example section in README

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

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

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

[jira] [Updated] (BEAM-454) Validate Pubsub Topic exists when reading

[ https://issues.apache.org/jira/browse/BEAM-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-454: - Assignee: (was: Daniel Halperin) > Validate Pubsub Topic exists when reading >

[jira] [Updated] (BEAM-474) Tests which evaluate DisplayData but don't run a pipeline should be marked @NeedsRunner not @RunnableOnService

[ https://issues.apache.org/jira/browse/BEAM-474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-474: - Assignee: (was: Daniel Halperin) > Tests which evaluate DisplayData but don't run a pipeline

[jira] [Updated] (BEAM-458) Support for Flink Metrics

[ https://issues.apache.org/jira/browse/BEAM-458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-458: - Assignee: (was: Frances Perry) > Support for Flink Metrics > -- > >

[jira] [Commented] (BEAM-487) Add disclaimer to GitHub README.md

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

[GitHub] incubator-beam pull request #733: [BEAM-487] README.md: add DISCLAIMER, incu...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/733 [BEAM-487] README.md: add DISCLAIMER, incubating, minor fixes From the linked JIRA: > For the github audience, reaching https://github.com/apache/incubator-beam, there is no

[jira] [Commented] (BEAM-488) Remove KEYS file

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

[GitHub] incubator-beam pull request #732: [BEAM-488] Remove KEYS file

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/732 [BEAM-488] Remove KEYS file Per discussion, linked in JIRA: > Bundling PGP keys inside a package is worse than worthless – an > attacker can just bundle spoofed keys with a

[jira] [Created] (BEAM-488) Remove KEYS file

Daniel Halperin created BEAM-488: Summary: Remove KEYS file Key: BEAM-488 URL: https://issues.apache.org/jira/browse/BEAM-488 Project: Beam Issue Type: Task Components:

[jira] [Created] (BEAM-487) Add disclaimer to GitHub README.md

Daniel Halperin created BEAM-487: Summary: Add disclaimer to GitHub README.md Key: BEAM-487 URL: https://issues.apache.org/jira/browse/BEAM-487 Project: Beam Issue Type: Task