[jira] [Closed] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

[ https://issues.apache.org/jira/browse/BEAM-367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-367. Resolution: Fixed > GetFractionConsumed() inaccurate for non-uniform records >

[jira] [Commented] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

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

[2/2] incubator-beam git commit: Update OffsetRangeTracker progress tracking and start offset

Update OffsetRangeTracker progress tracking and start offset Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ee0a3bf2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ee0a3bf2 Diff:

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

Repository: incubator-beam Updated Branches: refs/heads/master 741ef266f -> 3ff98ea23 Closes #515 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3ff98ea2 Tree:

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

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 4840f5275 -> e3a43fb5c Closes #507 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e3a43fb5 Tree:

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

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

[GitHub] incubator-beam pull request #492: Run Pipelines in tests that expect them

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/492 --- 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: Run Pipelines in tests that expect them

Repository: incubator-beam Updated Branches: refs/heads/master e255cd6be -> 741ef266f Run Pipelines in tests that expect them Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/916bf3a8 Tree:

[01/12] incubator-beam git commit: Move some easy stuff into runners/core-java

Repository: incubator-beam Updated Branches: refs/heads/master 73862b422 -> e255cd6be http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnTester.java

[02/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java -- diff --git

[04/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ReduceFnRunner.java -- diff --git

[06/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/runners/core-java/src/test/java/org/apache/beam/sdk/util/ReduceFnTester.java -- diff --git

[09/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/runners/core-java/src/main/java/org/apache/beam/sdk/util/PushbackSideInputDoFnRunner.java -- diff --git

[12/12] incubator-beam git commit: This closes #510

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

[05/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/GroupByKeyViaGroupByKeyOnly.java -- diff --git

[11/12] incubator-beam git commit: Directly instantiate SimpleDoFnRunner in its test suite

Directly instantiate SimpleDoFnRunner in its test suite Previously, it went through a static utility class, creating quasi-circular dependency. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/efaad322 Tree:

[03/12] incubator-beam git commit: Move some easy stuff into runners/core-java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WatermarkHold.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WatermarkHold.java

[GitHub] incubator-beam pull request #510: [BEAM-362] Move some easy stuff into runne...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/510 --- 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-155) Support asserting the contents of windows and panes in PAssert

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

[GitHub] incubator-beam pull request #518: [BEAM-155] Support Windowed Assertions in ...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/518 [BEAM-155] Support Windowed Assertions in PAssert 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-368) Add getSplitPointsConsumed() to ByteKeyRangeTracker

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

[jira] [Created] (BEAM-368) Add getSplitPointsConsumed() to ByteKeyRangeTracker

Ian Zhou created BEAM-368: - Summary: Add getSplitPointsConsumed() to ByteKeyRangeTracker Key: BEAM-368 URL: https://issues.apache.org/jira/browse/BEAM-368 Project: Beam Issue Type: Improvement

[GitHub] incubator-beam pull request #517: [BEAM-368] Added getSplitPointsConsumed() ...

GitHub user ianzhou1 opened a pull request: https://github.com/apache/incubator-beam/pull/517 [BEAM-368] Added getSplitPointsConsumed() to ByteKeyRangeTracker Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[GitHub] incubator-beam pull request #516: Enable dependency-plugin at global level.

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/516 Enable dependency-plugin at global level. Create the PR to trigger tests. It is not ready for review yet, since it will likely break the build. You can merge this pull request into a Git

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15343104#comment-15343104 ] Matt Pouttu-Clarke commented on BEAM-91: https://github.com/LamdaFu/bloklinx/wiki ^^ provides the

[jira] [Commented] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

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

[jira] [Created] (BEAM-367) GetFractionConsumed() inaccurate for non-uniform records

Ian Zhou created BEAM-367: - Summary: GetFractionConsumed() inaccurate for non-uniform records Key: BEAM-367 URL: https://issues.apache.org/jira/browse/BEAM-367 Project: Beam Issue Type: Improvement

[GitHub] incubator-beam pull request #515: [BEAM-367] Modify offset range tracker to ...

GitHub user ianzhou1 opened a pull request: https://github.com/apache/incubator-beam/pull/515 [BEAM-367] Modify offset range tracker to use first response as start offset Be sure to do all of the following to help us incorporate your contribution quickly and easily: -

[GitHub] incubator-beam pull request #514: Add Travis config for Python SDK tests

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/514 Add Travis config for Python SDK tests Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

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

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

[jira] [Commented] (BEAM-359) AvroCoder should be able to handle anonymous classes as schemas

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

[GitHub] incubator-beam pull request #513: Fix BEAM-359

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/513 Fix BEAM-359 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: `[BEAM-]

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #587

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #586

See

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

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

[GitHub] incubator-beam pull request #509: Set runtime scope for Dataflow runner dep ...

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

Remove temporary GroupAlsoByWindowViaWindowSetDoFn shim Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2d563795 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2d563795 Diff:

[1/3] incubator-beam git commit: Set runtime scope for Dataflow runner dep on runners-core

Repository: incubator-beam Updated Branches: refs/heads/master 3001804e3 -> 73862b422 Set runtime scope for Dataflow runner dep on runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b52688f4

[jira] [Resolved] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

[ https://issues.apache.org/jira/browse/BEAM-234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-234. -- Resolution: Fixed > Remove the word Pipeline from the name of all PipelineRunner implementations >

[jira] [Commented] (BEAM-234) Remove the word Pipeline from the name of all PipelineRunner implementations

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

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

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

[GitHub] incubator-beam pull request #488: [BEAM-234] Rename SparkPipelineRunner to S...

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

Repository: incubator-beam Updated Branches: refs/heads/master 2b9906e8d -> 3001804e3 Rename SparkPipelineRunner to SparkRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96ffc429 Tree:

[GitHub] incubator-beam pull request #512: Use item equality in apply_to_list test

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/512 Use item equality in apply_to_list test 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 #494: Use item equality in apply_to_list test

Github user aaltay closed the pull request at: https://github.com/apache/incubator-beam/pull/494 --- 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 #511: Fix a typo in FlinkRunner.toString

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/511 Fix a typo in FlinkRunner.toString R: @tgroh @kennknowles You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam patch-1

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342259#comment-15342259 ] Matt Pouttu-Clarke commented on BEAM-91: Yes, just wanted to be sure there was interest before

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

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

[GitHub] incubator-beam pull request #510: [BEAM-362] Move some easy stuff into runne...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/510 [BEAM-362] Move some easy stuff into runners/core-java Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the

[jira] [Commented] (BEAM-366) Support Display Data on Composite Transforms

[ https://issues.apache.org/jira/browse/BEAM-366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342229#comment-15342229 ] Ben Chambers commented on BEAM-366: --- As mentioned, representing composites explicitly in the Dataflow

[jira] [Created] (BEAM-366) Support Display Data on Composite Transforms

Ben Chambers created BEAM-366: - Summary: Support Display Data on Composite Transforms Key: BEAM-366 URL: https://issues.apache.org/jira/browse/BEAM-366 Project: Beam Issue Type: Bug

[GitHub] incubator-beam pull request #509: Set runtime scope for Dataflow runner dep ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/509 Set runtime scope for Dataflow runner dep on runners-core Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342094#comment-15342094 ] Luke Cwik commented on BEAM-91: --- Matt, do you have something you can share that goes into more detail? >

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342022#comment-15342022 ] Matt Pouttu-Clarke commented on BEAM-91: The design actually solves multiple problems: i.e. BEAM-25,

[jira] [Commented] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341996#comment-15341996 ] Matt Pouttu-Clarke commented on BEAM-91: I've solved this problem successfully several times since

[jira] [Updated] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException

[ https://issues.apache.org/jira/browse/BEAM-365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Szczur updated BEAM-365: -- Description: The exception: {code}java.lang.IllegalStateException: Shard name template '' only generated

[jira] [Created] (BEAM-365) TextIO withoutSharding causes Flink to throw IllegalStateException

Pawel Szczur created BEAM-365: - Summary: TextIO withoutSharding causes Flink to throw IllegalStateException Key: BEAM-365 URL: https://issues.apache.org/jira/browse/BEAM-365 Project: Beam Issue

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Branches: refs/heads/BEAM-357_windows-build-fails [deleted] 460d21cb7

[1/2] incubator-beam git commit: fixing build on windows

Repository: incubator-beam Updated Branches: refs/heads/BEAM-357_windows-build-fails [created] 460d21cb7 fixing build on windows Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/41883300 Tree:

[2/2] incubator-beam git commit: better comments for win workaround and basic sanity checks for winutils.exe

better comments for win workaround and basic sanity checks for winutils.exe Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/460d21cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/460d21cb

[jira] [Closed] (BEAM-150) Link validation on static content generation

[ https://issues.apache.org/jira/browse/BEAM-150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Malone closed BEAM-150. - Resolution: Fixed Fixed in PR 23 to the repo: https://github.com/apache/incubator-beam-site/pull/23 Can