[jira] [Closed] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker

[ https://issues.apache.org/jira/browse/BEAM-381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-381. > OffsetBasedReader should construct sources before updating the range tracker >

[jira] [Commented] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker

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

[jira] [Resolved] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker

[ https://issues.apache.org/jira/browse/BEAM-381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-381. -- Resolution: Fixed > OffsetBasedReader should construct sources before updating the range tracker

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

Repository: incubator-beam Updated Branches: refs/heads/master 921c55c94 -> 74e1f83df Closes #600 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/74e1f83d Tree:

[jira] [Updated] (BEAM-381) OffsetBasedReader should construct sources before updating the range tracker

[ https://issues.apache.org/jira/browse/BEAM-381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-381: - Fix Version/s: 0.2.0-incubating > OffsetBasedReader should construct sources before updating the

[GitHub] incubator-beam pull request #600: [BEAM-381] BoundedReader: update the range...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/600 --- 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-381] BoundedReader: update the range last of all

[BEAM-381] BoundedReader: update the range last of all Reorders the code in some splitAtFraction calls so that the rangeTracker update is the last thing (besides assignment) in the function. This avoids a potential issue if creating the primary or residual sources happens to throw an exception.

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

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

[GitHub] incubator-beam pull request #608: Uncomment tox in the postcommit script.

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/608 --- 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: Uncomment tox in the postcommit script.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk a580b31ac -> e167d2b5a Uncomment tox in the postcommit script. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1da908f7 Tree:

[GitHub] incubator-beam pull request #603: Modified addBulkOptions for simplicity

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

Modified addBulkOptions for simplicity Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b9231826 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b9231826 Diff:

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

Repository: incubator-beam Updated Branches: refs/heads/master 155409bf6 -> 290c0b772 Closes #603 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/290c0b77 Tree:

[jira] [Resolved] (BEAM-289) Examples Use TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-289. -- Resolution: Fixed Fix Version/s: 0.1.0-incubating > Examples Use TypeDescriptors >

[jira] [Updated] (BEAM-289) Examples Use TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-289: - Fix Version/s: (was: 0.1.0-incubating) 0.2.0-incubating > Examples Use

[jira] [Created] (BEAM-431) Examples dependencies on runners are a bit much and not enough

Kenneth Knowles created BEAM-431: Summary: Examples dependencies on runners are a bit much and not enough Key: BEAM-431 URL: https://issues.apache.org/jira/browse/BEAM-431 Project: Beam

[jira] [Commented] (BEAM-429) minor: remove an obsolete comment in KafakIOTest.java

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

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

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

[GitHub] incubator-beam pull request #606: [BEAM-429] remove an obsolete comment in K...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/606 --- 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: remove an obsolete comment in KafkaIOTest.java

Repository: incubator-beam Updated Branches: refs/heads/master 1963bde44 -> 155409bf6 remove an obsolete comment in KafkaIOTest.java Kafka 10.0 added compatible constructor for ConsumerRecord. It was not present when I wrote this test.

[GitHub] incubator-beam pull request #607: Mark primitive display data tests Runnable...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/607 Mark primitive display data tests RunnableOnService Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Updated] (BEAM-391) Exceptions in gcsio upload thread causes pipeline to stall

[ https://issues.apache.org/jira/browse/BEAM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-391: - Summary: Exceptions in gcsio upload thread causes pipeline to stall (was: Invalid GCS bucket name causes

[jira] [Commented] (BEAM-430) Introducing gcpTempLocation that default to tempLocation

[ https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366882#comment-15366882 ] Pei He commented on BEAM-430: - Since stagingLocation will default to gcpTempLocation, and gcpTempLocation will

[jira] [Created] (BEAM-429) minor: remove an obsolete comment in KafakIOTest.java

Raghu Angadi created BEAM-429: - Summary: minor: remove an obsolete comment in KafakIOTest.java Key: BEAM-429 URL: https://issues.apache.org/jira/browse/BEAM-429 Project: Beam Issue Type:

[GitHub] incubator-beam pull request #606: remove an obsolete comment in KafkaIOTest....

GitHub user rangadi opened a pull request: https://github.com/apache/incubator-beam/pull/606 remove an obsolete comment in KafkaIOTest.java Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] incubator-beam pull request #604: Add support for ZLIB and DEFLATE compressi...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/604 --- 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: Add support for ZLIB and DEFLATE compression

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 9bc04b750 -> a580b31ac Add support for ZLIB and DEFLATE compression Code originally contributed by Slaven Bilac. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

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

[jira] [Commented] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

[ https://issues.apache.org/jira/browse/BEAM-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366779#comment-15366779 ] Vlad Rozov commented on BEAM-320: - Apache Beam can do binary release that includes necessary binaries for

[GitHub] incubator-beam pull request #605: Rename DataflowExampleUtils and DataflowEx...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/605 Rename DataflowExampleUtils and DataflowExampleOptions You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam renaming

[jira] [Commented] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

[ https://issues.apache.org/jira/browse/BEAM-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366734#comment-15366734 ] Amit Sela commented on BEAM-320: What about execution runtime source packaging ? On one hand it would be

[GitHub] incubator-beam pull request #604: Add support for ZLIB and DEFLATE compressi...

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/604 Add support for ZLIB and DEFLATE compression Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-124) Testing -- End to End WordCount Batch and Streaming Tests

[ https://issues.apache.org/jira/browse/BEAM-124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366643#comment-15366643 ] Jason Kuster commented on BEAM-124: --- Update: Batch WordCount E2E has been in for a while. Verifiers are

[jira] [Comment Edited] (BEAM-124) Testing -- End to End WordCount Batch and Streaming Tests

[ https://issues.apache.org/jira/browse/BEAM-124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366643#comment-15366643 ] Jason Kuster edited comment on BEAM-124 at 7/7/16 7:28 PM: --- Update: Batch

[jira] [Closed] (BEAM-228) Create a merge bot for Beam

[ https://issues.apache.org/jira/browse/BEAM-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kuster closed BEAM-228. - Resolution: Won't Fix Fix Version/s: Not applicable Mergebot is being delivered to apache infra

[3/4] incubator-beam git commit: Better error message for poor use of callable apply

Better error message for poor use of callable apply Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c34f332a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c34f332a Diff:

[2/4] incubator-beam git commit: Cleanup dataflow_test.

Cleanup dataflow_test. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e0643774 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e0643774 Diff:

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

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

[1/4] incubator-beam git commit: Remove unneeded label argument in ptransform_fn

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 342d2d798 -> 9bc04b750 Remove unneeded label argument in ptransform_fn The label is already in the fully qualified name due to nesting. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: pipeline.options should never be None

pipeline.options should never be None Also fix a typehints error this exposed. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/87961e4b Tree:

[GitHub] incubator-beam pull request #597: pipeline.options should never be None

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

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 6b06e3e22 -> 342d2d798 Closes #597 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/342d2d79 Tree:

[GitHub] incubator-beam pull request #603: Modified addBulkOptions for simplicity

GitHub user ianzhou1 opened a pull request: https://github.com/apache/incubator-beam/pull/603 Modified addBulkOptions for simplicity You can merge this pull request into a Git repository by running: $ git pull https://github.com/ianzhou1/incubator-beam AddBulkOptions

[GitHub] incubator-beam pull request #593: Run lint on python/sdks folder to include ...

Github user aaltay closed the pull request at: https://github.com/apache/incubator-beam/pull/593 --- 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: Enable linter rules no-self-argument, reimported, ungrouped-imports

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 253497655 -> 6b06e3e22 Enable linter rules no-self-argument, reimported, ungrouped-imports And run lint on python/sdks folder to include setup.py. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

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

[GitHub] incubator-beam pull request #602: Fix BigtableIO display data label

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/602 --- 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: Fix BigtableIO display data label

Fix BigtableIO display data label Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9c91403c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9c91403c Diff:

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

Repository: incubator-beam Updated Branches: refs/heads/master 33b18b173 -> 1963bde44 Closes #602 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1963bde4 Tree:

[jira] [Commented] (BEAM-403) Support staging SDK packages from PyPI for remote execution

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

[GitHub] incubator-beam pull request #569: [BEAM-403] Get current SDK package from Py...

Github user silviulica closed the pull request at: https://github.com/apache/incubator-beam/pull/569 --- 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 #602: Fix BigtableIO display data label

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/602 Fix BigtableIO display data label Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] incubator-beam pull request #601: Documentation URL provided previously thro...

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

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

[jira] [Resolved] (BEAM-408) ProxyInvocationHandler uses inefficient Math.random() for random int

[ https://issues.apache.org/jira/browse/BEAM-408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-408. Resolution: Fixed Fix Version/s: 0.2.0-incubating > ProxyInvocationHandler uses inefficient

[jira] [Commented] (BEAM-408) ProxyInvocationHandler uses inefficient Math.random() for random int

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

[1/4] incubator-beam git commit: Removes extra blank space

Repository: incubator-beam Updated Branches: refs/heads/master 1cb898f58 -> 66d726aa2 Removes extra blank space Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e97cbcc Tree:

[GitHub] incubator-beam pull request #588: [BEAM-408] - Fixes ProxyInvocationHandler ...

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

[4/4] incubator-beam git commit: [BEAM-408] - Fixes ProxyInvocationHandler uses inefficient Math.random() for random int

[BEAM-408] - Fixes ProxyInvocationHandler uses inefficient Math.random() for random int This closes #588 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/66d726aa Tree:

[3/4] incubator-beam git commit: [BEAM-408] - Fixes ProxyInvocationHandler uses inefficient Math.random() for random int

[BEAM-408] - Fixes ProxyInvocationHandler uses inefficient Math.random() for random int For more information: https://issues.apache.org/jira/browse/BEAM-408 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #585: Merge master into runners-spark2 branch to...

Github user amitsela closed the pull request at: https://github.com/apache/incubator-beam/pull/585 --- 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-381) OffsetBasedReader should construct sources before updating the range tracker

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

[GitHub] incubator-beam pull request #600: [BEAM-381] BoundedReader: update the range...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/600 [BEAM-381] BoundedReader: update the range last of all Reorders the code in some splitAtFraction calls so that the rangeTracker update is the last thing (besides assignment) in the

[GitHub] incubator-beam pull request #601: Documentation URL provided previously thro...

GitHub user SrinikhilReddy opened a pull request: https://github.com/apache/incubator-beam/pull/601 Documentation URL provided previously throws Error You can merge this pull request into a Git repository by running: $ git pull https://github.com/SrinikhilReddy/incubator-beam