[jira] [Updated] (BEAM-740) Improve document on running Beam program on Flink Cluster

[ https://issues.apache.org/jira/browse/BEAM-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-740: -- Assignee: Manu Zhang > Improve document on running Beam program on Flink Cluster > ---

[GitHub] incubator-beam pull request #1082: [BEAM-740] improve runners-flink README.m...

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

[1/2] incubator-beam git commit: [BEAM-740] improve runners-flink README.md

Repository: incubator-beam Updated Branches: refs/heads/master 6c8821682 -> 1de6439f1 [BEAM-740] improve runners-flink README.md Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8017a025 Tree: http://git-w

[jira] [Updated] (BEAM-740) Improve document on running Beam program on Flink Cluster

[ https://issues.apache.org/jira/browse/BEAM-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-740: -- Fix Version/s: 0.3.0-incubating > Improve document on running Beam program on Flink Cluste

[2/2] incubator-beam git commit: [BEAM-740] This closes #1082

[BEAM-740] This closes #1082 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1de6439f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1de6439f Diff: http://git-wip-us.apache.org/repos/asf/inc

[jira] [Resolved] (BEAM-740) Improve document on running Beam program on Flink Cluster

[ https://issues.apache.org/jira/browse/BEAM-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-740. --- Resolution: Fixed > Improve document on running Beam program on Flink Cluster >

[jira] [Commented] (BEAM-740) Improve document on running Beam program on Flink Cluster

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

Jenkins build became unstable: beam_PostCommit_MavenVerify #1496

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1496

See

[jira] [Updated] (BEAM-720) Running WindowedWordCount Integration Test in Flink

[ https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-720: -- Component/s: runner-flink > Running WindowedWordCount Integration Test in Flink >

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15565001#comment-15565001 ] Aljoscha Krettek commented on BEAM-696: --- Just to make it clear what the Flink runner d

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15565302#comment-15565302 ] Amit Sela commented on BEAM-696: I wonder though, does Flink also use bundles ? so it buffer

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1497

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1497

See

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15565305#comment-15565305 ] Amit Sela commented on BEAM-696: Correct me of I'm wrong - I think we all agree that sideInp

[jira] [Updated] (BEAM-736) BigQueryTornadoesIT broken, blocking nightly release.

[ https://issues.apache.org/jira/browse/BEAM-736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-736: --- Priority: Minor (was: Major) > BigQueryTornadoesIT broken, blocking nightly release. >

[jira] [Resolved] (BEAM-736) BigQueryTornadoesIT broken, blocking nightly release.

[ https://issues.apache.org/jira/browse/BEAM-736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-736. Resolution: Fixed Fix Version/s: 0.3.0-incubating > BigQueryTornadoesIT broken, blocking nightly releas

[GitHub] incubator-beam-site pull request #43: Blog post about Strata+Hadoop World Tu...

GitHub user eljefe6a opened a pull request: https://github.com/apache/incubator-beam-site/pull/43 Blog post about Strata+Hadoop World Tutorial Added blog post about Strata+Hadoop World tutorial. Added Jesse Anderson as an author. Added the images for the blog post. You can merge th

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

Closes #1077 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/240f8f67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/240f8f67 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

[1/2] incubator-beam git commit: Add profile_memory flag

Repository: incubator-beam Updated Branches: refs/heads/python-sdk ba624e98f -> 240f8f673 Add profile_memory flag Runners with memory profiling support, would use this flag to profile the workflow for heap usage. Renamed the profile flag to profile_cpu flag to make the distinction clear. Pr

[3/4] incubator-beam git commit: Add support for bz2 compression

Add support for bz2 compression Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a9a00bae Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a9a00bae Diff: http://git-wip-us.apache.org/repos/asf/

[4/4] incubator-beam git commit: Post-merge fixup.

Post-merge fixup. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb57b974 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb57b974 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam

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

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 240f8f673 -> eb57b974c Closes #1007 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/46110e4a Tree: http://git-wip-us.apache.org/repos/asf

[2/4] incubator-beam git commit: implement codreview feedback

implement codreview feedback Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e223929c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e223929c Diff: http://git-wip-us.apache.org/repos/asf/inc

[jira] [Created] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

Andrew Martin created BEAM-741: -- Summary: Values transform does not use the correct output coder when values is an Iterable Key: BEAM-741 URL: https://issues.apache.org/jira/browse/BEAM-741 Project: Beam

[jira] [Comment Edited] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546263#comment-15546263 ] Kenneth Knowles edited comment on BEAM-696 at 10/11/16 6:52 PM: --

[jira] [Commented] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566252#comment-15566252 ] Kenneth Knowles commented on BEAM-741: -- Can you provide a reproduction? This is fairly

[jira] [Commented] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566259#comment-15566259 ] Andrew Martin commented on BEAM-741: I found this issue when using the Direct Runner for

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566305#comment-15566305 ] Kenneth Knowles commented on BEAM-696: -- I think there's some conflation of elements com

[jira] [Assigned] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He reassigned BEAM-59: -- Assignee: Pei He > IOChannelFactory rethinking/redesign > > >

[jira] [Commented] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566498#comment-15566498 ] Amit Sela commented on BEAM-696: Does Dataflow "buffer until trigger..." if there are no sid

[jira] [Comment Edited] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566498#comment-15566498 ] Amit Sela edited comment on BEAM-696 at 10/11/16 8:41 PM: -- Does Dat

[jira] [Comment Edited] (BEAM-696) Side-Inputs non-deterministic with merging main-input windows

[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566498#comment-15566498 ] Amit Sela edited comment on BEAM-696 at 10/11/16 8:42 PM: -- Does Dat

[jira] [Closed] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Martin closed BEAM-741. -- Resolution: Not A Problem Fix Version/s: Not applicable > Values transform does not use the correct

[jira] [Commented] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1554#comment-1554 ] Andrew Martin commented on BEAM-741: I see, so being explicit about setting the coder in

[4/4] incubator-beam git commit: This closes #1080

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

[1/4] incubator-beam git commit: Remove unused ListOutputManager

Repository: incubator-beam Updated Branches: refs/heads/master 1de6439f1 -> 9fab4ba51 Remove unused ListOutputManager Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e195237d Tree: http://git-wip-us.apach

[3/4] incubator-beam git commit: Fix access levels on SimpleDoFnRunner

Fix access levels on SimpleDoFnRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bac00e1a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bac00e1a Diff: http://git-wip-us.apache.org/repo

[2/4] incubator-beam git commit: Inline DoFnRunnerBase to its sole subclass

Inline DoFnRunnerBase to its sole subclass Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/48a7a558 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/48a7a558 Diff: http://git-wip-us.apache.org

[GitHub] incubator-beam pull request #1080: [BEAM-498] Inline DoFnRunnerBase and fix ...

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

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[jira] [Commented] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15566814#comment-15566814 ] Kenneth Knowles commented on BEAM-741: -- Actually, what you say makes me want to investi

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

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

[GitHub] incubator-beam pull request #1069: [BEAM-732] Only remove Elements that were...

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

[1/2] incubator-beam git commit: Only remove Elements that were pending from Pending Elements

Repository: incubator-beam Updated Branches: refs/heads/master 9fab4ba51 -> 7c2124ba4 Only remove Elements that were pending from Pending Elements Update the comparator so elements will only be removed from the collection of pending elements if they were formerly added. This ensures that eleme

[jira] [Commented] (BEAM-732) Placing Timers into the global window causes tests to Flake

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

[jira] [Resolved] (BEAM-732) Placing Timers into the global window causes tests to Flake

[ https://issues.apache.org/jira/browse/BEAM-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-732. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > Placing Timers into the global window causes te

[1/3] incubator-beam git commit: checkstyle: improve Javadoc checking

Repository: incubator-beam Updated Branches: refs/heads/master 7c2124ba4 -> 135790bc9 http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9e30a989/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java -

[2/3] incubator-beam git commit: checkstyle: improve Javadoc checking

checkstyle: improve Javadoc checking * Enable JavadocParagraph, which gives a consistent style in how we format paragraphs. This caught a LOT of missing tags and other issues. * This also caught a lot of HTML issues that led to mis-rendering Javadoc. Project: http://git-wip-us.apache.org/rep

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

Closes #1060 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/135790bc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/135790bc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

[GitHub] incubator-beam pull request #1060: checkstyle: improve Javadoc checking

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

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1501

See

Jenkins build became unstable: beam_PostCommit_MavenVerify #1501

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1502

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1502

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1503

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1503

See

[jira] [Created] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

Kenneth Knowles created BEAM-742: Summary: Move trigger state machines to runners-core, convert triggers to AST Key: BEAM-742 URL: https://issues.apache.org/jira/browse/BEAM-742 Project: Beam

[GitHub] incubator-beam pull request #1083: [BEAM-742] Replicate triggers to runners-...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1083 [BEAM-742] Replicate triggers to runners-core (migration step towards conversion to AST) Be sure to do all of the following to help us incorporate your contribution quickly and easi

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[GitHub] incubator-beam pull request #1083: [BEAM-742] Replicate triggers to runners-...

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

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[GitHub] incubator-beam pull request #1083: [BEAM-742] Replicate triggers to runners-...

GitHub user kennknowles reopened a pull request: https://github.com/apache/incubator-beam/pull/1083 [BEAM-742] Replicate triggers to runners-core (migration step towards conversion to AST) Be sure to do all of the following to help us incorporate your contribution quickly and ea