[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316719#comment-15316719 ] Davor Bonaci commented on BEAM-52: -- Done? > KafkaIO - bounded/unbounded, source/sink >

[jira] [Resolved] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-52. - Resolution: Fixed > KafkaIO - bounded/unbounded, source/sink > --

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316724#comment-15316724 ] Raghu Angadi commented on BEAM-52: -- Yep. Closing now. > KafkaIO - bounded/unbounded, source

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

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

[1/2] incubator-beam git commit: Return from awaitCompletion if Already Done

Repository: incubator-beam Updated Branches: refs/heads/master c2146b9f9 -> c0b67ab12 Return from awaitCompletion if Already Done This ensures that a call to ExecutorService#awaitCompletion returns immediately if there are no visible updates and the executor has completed. If the executor is

[GitHub] incubator-beam pull request #399: Return from awaitCompletion if Already Don...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/399 --- 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] [Assigned] (BEAM-38) Avoid repeated DoFn deserialization

[ https://issues.apache.org/jira/browse/BEAM-38?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-38: --- Assignee: Thomas Groh > Avoid repeated DoFn deserialization > --- > >

[GitHub] incubator-beam pull request #419: [BEAM-38] Allow DoFns to be Reused

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/419 [BEAM-38] Allow DoFns to be Reused Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[jira] [Commented] (BEAM-38) Avoid repeated DoFn deserialization

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

Build failed in Jenkins: beam_PostCommit_MavenVerify #570

See Changes: [bchambers] Return from awaitCompletion if Already Done -- [...truncated 5035 lines...] [INFO] Installing

[GitHub] incubator-beam pull request #420: [BEAM-287] Use flat groupId structure and ...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/420 [BEAM-287] Use flat groupId structure and full qualified artifactIds Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[GitHub] incubator-beam pull request #421: Fix validation in PubsubIO

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/421 Fix validation in PubsubIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is formatted like:

[GitHub] incubator-beam pull request #416: [BEAM-319][BEAM-320] Add distributions mod...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/416 --- 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-319][BEAM-320] Add distributions module responsible of packaging source and binaries distributions.

Repository: incubator-beam Updated Branches: refs/heads/master c0b67ab12 -> 523e820b0 [BEAM-319][BEAM-320] Add distributions module responsible of packaging source and binaries distributions. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache

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

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

[jira] [Commented] (BEAM-319) Attach src distribution artifact to be take by deploy

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

[2/2] incubator-beam git commit: Fix validation in PubsubIO

Fix validation in PubsubIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/135aabd6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/135aabd6 Diff: http://git-wip-us.apache.org/repos/asf/incub

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

Repository: incubator-beam Updated Branches: refs/heads/master 523e820b0 -> fe1889316 Closes #421 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fe188931 Tree: http://git-wip-us.apache.org/repos/asf/incu

[GitHub] incubator-beam pull request #421: Fix validation in PubsubIO

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/421 --- 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] [Resolved] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

[ https://issues.apache.org/jira/browse/BEAM-323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-323. -- Resolution: Fixed > The InProcessPipelineRunner uses user objects for State and Timer lookups > --

[jira] [Updated] (BEAM-317) Implement PAssert without using Side Inputs

[ https://issues.apache.org/jira/browse/BEAM-317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-317: - Description: SideInputs are not supported equally by all runners. Implementing assertions as a main input a

[GitHub] incubator-beam pull request #422: Remove DirectRunner implementations from D...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/422 Remove DirectRunner implementations from DoFnTester Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is back to normal : beam_PostCommit_MavenVerify #572

See

[GitHub] incubator-beam pull request #423: [BEAM-287] Use flat groupId structure and ...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/423 [BEAM-287] Use flat groupId structure and full qualified artifactIds R: @jbonofre, @dhalperi JB, this is taking your #420 and builds on top of it. In particular, fixed compile

[jira] [Commented] (BEAM-287) Add new beam groupIds

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

[GitHub] incubator-beam pull request #413: Reorganization of Maven coordinates

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

[jira] [Assigned] (BEAM-298) Make TestPipeline implement the TestRule interface

[ https://issues.apache.org/jira/browse/BEAM-298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-298: Assignee: (was: Thomas Groh) > Make TestPipeline implement the TestRule interface > -

[jira] [Updated] (BEAM-85) PAssert needs sanity check that it's used correctly

[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-85: Summary: PAssert needs sanity check that it's used correctly (was: DataflowAssert (BeamAssert ;) needs sanity

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

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

[1/3] incubator-beam git commit: Remove reporting section from Spark's pom.xml file

Repository: incubator-beam Updated Branches: refs/heads/master fe1889316 -> 43c8f8360 Remove reporting section from Spark's pom.xml file This is currently triggering Maven warnings, due to a missing version qualifier. However, we don't run 'site', so this isn't being used at this point. Henc

[2/3] incubator-beam git commit: [BEAM-287] Use flat groupId structure and full qualified artifactIds

[BEAM-287] Use flat groupId structure and full qualified artifactIds Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8f244c0c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8f244c0c Diff: ht

[GitHub] incubator-beam pull request #423: [BEAM-287] Use flat groupId structure and ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/423 --- 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-287) Add new beam groupIds

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

[GitHub] incubator-beam pull request #424: [BEAM-292] Write: always produce at least ...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/424 [BEAM-292] Write: always produce at least 1 WriteT Write has a degenerate case wherein, if no elements were in the written PCollection, the finalize step will get produced with nothing

[jira] [Commented] (BEAM-292) TextIO.Write.to Empty Files

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

[jira] [Assigned] (BEAM-292) TextIO.Write.to Empty Files

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-292: Assignee: Daniel Halperin > TextIO.Write.to Empty Files > --- > >

[jira] [Commented] (BEAM-303) Add Machine Learning DSL and dedicated functions

[ https://issues.apache.org/jira/browse/BEAM-303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317841#comment-15317841 ] Kam Kasravi commented on BEAM-303: -- Hi James Did you want to coordinate on this. We could