[jira] [Commented] (BEAM-708) Migrate BoundedReadFromUnboundedSource to use AutoValue to reduce boilerplate

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

[GitHub] beam pull request #1794: [BEAM-708] Using AutoValue in BoundedReadFromUnboun...

GitHub user vectorijk opened a pull request: https://github.com/apache/beam/pull/1794 [BEAM-708] Using AutoValue in BoundedReadFromUnboundedSource Migrate BoundedReadFromUnboundedSource to use AutoValue to reduce boilerplate You can merge this pull request into a Git repository by

[jira] [Commented] (BEAM-570) Update AvroSource to support more compression types

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

[GitHub] beam pull request #1777: [BEAM-570] Performance optimization in fileio for c...

Github user katsiapis closed the pull request at: https://github.com/apache/beam/pull/1777 --- 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 is

[jira] [Commented] (BEAM-1281) GlobalWindow needs non-empty encoding in StateNamespaces

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

[jira] [Updated] (BEAM-1281) GlobalWindow needs non-empty encoding in nested context

[ https://issues.apache.org/jira/browse/BEAM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1281: -- Description: Because the GlobalWindow is encoded to zero bytes, a StateNamespace built from the

[jira] [Updated] (BEAM-1281) GlobalWindow needs non-empty encoding in nested context

[ https://issues.apache.org/jira/browse/BEAM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1281: -- Priority: Minor (was: Critical) > GlobalWindow needs non-empty encoding in nested context >

[jira] [Updated] (BEAM-1281) GlobalWindow needs non-empty encoding in nested context

[ https://issues.apache.org/jira/browse/BEAM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1281: -- Description: One easy motivation: as a StateNamespace, the global window's stringKey ends up

[jira] [Updated] (BEAM-1281) GlobalWindow needs non-empty encoding in nested context

[ https://issues.apache.org/jira/browse/BEAM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1281: -- Summary: GlobalWindow needs non-empty encoding in nested context (was: GlobalWindow (and all

[jira] [Created] (BEAM-1281) GlobalWindow (and all values) needs non-empty encoding in nested context

Kenneth Knowles created BEAM-1281: - Summary: GlobalWindow (and all values) needs non-empty encoding in nested context Key: BEAM-1281 URL: https://issues.apache.org/jira/browse/BEAM-1281 Project: Beam

[jira] [Commented] (BEAM-1262) Need tests that use metrics in start_bundle / end_bundle functions

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

[jira] [Commented] (BEAM-1280) Remove label-first variants of PTransform constructors (use >> instead)

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

[jira] [Commented] (BEAM-1280) Remove label-first variants of PTransform constructors (use >> instead)

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

[GitHub] beam pull request #1791: [BEAM-1280] Update tests and examples to use new la...

Github user aaltay closed the pull request at: https://github.com/apache/beam/pull/1791 --- 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 is

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2376

See

[jira] [Commented] (BEAM-1113) Support for new Timer API in Dataflow runner

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

[GitHub] beam pull request #1792: [BEAM-1113] Set USES_KEYED_STATE for timers in Data...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/1792 [BEAM-1113] Set USES_KEYED_STATE for timers in Dataflow runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[jira] [Commented] (BEAM-1280) Remove label-first variants of PTransform constructors (use >> instead)

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

[jira] [Created] (BEAM-1280) Remove label-first variants of PTransform constructors (use >> instead)

Ahmet Altay created BEAM-1280: - Summary: Remove label-first variants of PTransform constructors (use >> instead) Key: BEAM-1280 URL: https://issues.apache.org/jira/browse/BEAM-1280 Project: Beam

[GitHub] beam pull request #1791: [BEAM-1280] Update tests and examples to use new la...

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/1791 [BEAM-1280] Update tests and examples to use new labels. You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/incubator-beam expand

[GitHub] beam pull request #1790: KvSwapTest: enhance validation

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/1790 KvSwapTest: enhance validation This test ensures that coders are propagated from input to output rather than re-inferred. You can merge this pull request into a Git repository by running:

[jira] [Commented] (BEAM-1225) Add a ToString transform in Java SDK

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

[1/2] beam git commit: Simplify ToString#element()

Repository: beam Updated Branches: refs/heads/master e78eb945f -> 603f4fb04 Simplify ToString#element() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d992fd1b Tree:

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2375

See

[2/2] beam git commit: This closes #1789

This closes #1789 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e78eb945 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e78eb945 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e78eb945 Branch:

[GitHub] beam pull request #1789: [BEAM-177] Fix goal ordering.

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

[1/2] beam git commit: [BEAM-177] Coveralls: fix goal ordering in precommit

Repository: beam Updated Branches: refs/heads/master d13549334 -> e78eb945f [BEAM-177] Coveralls: fix goal ordering in precommit Signed-off-by: Jason Kuster Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[GitHub] beam pull request #1784: [BEAM-1188] Fix Incorrect Value Parsing in Test Pip...

Github user markflyhigh closed the pull request at: https://github.com/apache/beam/pull/1784 --- 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 is

[2/2] beam git commit: Closes #1769

Closes #1769 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b9cb29c8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b9cb29c8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b9cb29c8 Branch:

[1/2] beam git commit: Metrics test in start/end_bundle for ParDos

Repository: beam Updated Branches: refs/heads/python-sdk b737ba907 -> b9cb29c83 Metrics test in start/end_bundle for ParDos Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/18179a1f Tree:

[1/2] beam git commit: Closes #1784

Repository: beam Updated Branches: refs/heads/python-sdk 678da7a8b -> b737ba907 Closes #1784 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b737ba90 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b737ba90 Diff:

[2/2] beam git commit: Fix Incorrect Split in Test Pipeline Test

Fix Incorrect Split in Test Pipeline Test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d8d3b4e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d8d3b4e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d8d3b4e3

[2/2] beam git commit: Closes #1777

Closes #1777 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/678da7a8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/678da7a8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/678da7a8 Branch:

[1/2] beam git commit: Moving from a string-based buffer to a cStringIO based on in order to help with performance of compressed sources.

Repository: beam Updated Branches: refs/heads/python-sdk 36a7d3491 -> 678da7a8b Moving from a string-based buffer to a cStringIO based on in order to help with performance of compressed sources. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: Add a default bucket to GcpOptions

Repository: beam Updated Branches: refs/heads/master faa2277b5 -> d13549334 Add a default bucket to GcpOptions If gcpStagingLocation is not specified, construct a stable Default Bucket. This bucket is used to stage GCP artifacts. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[GitHub] beam pull request #1041: Add a default bucket to Dataflow runner

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

[jira] [Updated] (BEAM-1225) Add a ToString transform in Java SDK

[ https://issues.apache.org/jira/browse/BEAM-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1225: -- Fix Version/s: 0.5.0 > Add a ToString transform in Java SDK >

[2/2] beam git commit: This closes #1608

This closes #1608 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/faa2277b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/faa2277b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/faa2277b Branch:

[1/2] beam git commit: GcsUtil: set timeout and retry for BatchRequest with HttpRequestInitializer.

Repository: beam Updated Branches: refs/heads/master c53249de4 -> faa2277b5 GcsUtil: set timeout and retry for BatchRequest with HttpRequestInitializer. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97a76d94 Tree:

[jira] [Commented] (BEAM-1279) Composite nodes should never be able to produce primitive output

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

[GitHub] beam pull request #1788: [BEAM-1279] Ensure Composite Nodes produce no outpu...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/1788 [BEAM-1279] Ensure Composite Nodes produce no output Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #1015: [BEAM-475] pom.xml: produce aggregate javadoc for t...

Github user dhalperi closed the pull request at: https://github.com/apache/beam/pull/1015 --- 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 is

[GitHub] beam pull request #1762: [BEAM-759] Implement wait_until_finish method for e...

Github user aaltay closed the pull request at: https://github.com/apache/beam/pull/1762 --- 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 is

[4/6] beam git commit: Update tests to use TestPipeline()

Update tests to use TestPipeline() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4ded9185 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4ded9185 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4ded9185

[1/6] beam git commit: Make TestPipeline.run() blocking by default.

Repository: beam Updated Branches: refs/heads/python-sdk f25c0e434 -> 36a7d3491 Make TestPipeline.run() blocking by default. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e49f518 Tree:

[jira] [Commented] (BEAM-1184) Add integration tests for ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827861#comment-15827861 ] Etienne Chauchot commented on BEAM-1184: I would like to do this as I have already worked on it and