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

2016-10-11 Thread Luke Cwik (JIRA)
[ 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.

2016-10-11 Thread Luke Cwik (JIRA)
[ 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

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

2016-10-11 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565302#comment-15565302 ] Amit Sela commented on BEAM-696: I wonder though, does Flink also use bundles ? so it buffers until a

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1497

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565305#comment-15565305 ] Amit Sela commented on BEAM-696: Correct me of I'm wrong - I think we all agree that sideInput for merging

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

2016-10-11 Thread robertwb
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:

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

2016-10-11 Thread robertwb
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:

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

2016-10-11 Thread Andrew Martin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566259#comment-15566259 ] Andrew Martin commented on BEAM-741: I found this issue when using the Direct Runner for a test, which

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

2016-10-11 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566305#comment-15566305 ] Kenneth Knowles commented on BEAM-696: -- I think there's some conflation of elements coming out of

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

2016-10-11 Thread Andrew Martin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1554#comment-1554 ] Andrew Martin commented on BEAM-741: I see, so being explicit about setting the coder in Values is

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

2016-10-11 Thread Andrew Martin (JIRA)
[ 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

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

2016-10-11 Thread robertwb
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.

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

2016-10-11 Thread robertwb
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:

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

2016-10-11 Thread eljefe6a
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

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

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

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

2016-10-11 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566252#comment-15566252 ] Kenneth Knowles commented on BEAM-741: -- Can you provide a reproduction? This is fairly surprising,

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

2016-10-11 Thread robertwb
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:

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

2016-10-11 Thread Andrew Martin (JIRA)
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:

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1502

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread Apache Jenkins Server
See

Jenkins build became unstable: beam_PostCommit_MavenVerify #1501

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread kenn
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:

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

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

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

2016-10-11 Thread asfgit
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

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

2016-10-11 Thread dhalperi
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:

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

2016-10-11 Thread dhalperi
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:

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

2016-10-11 Thread dhalperi
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

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

2016-10-11 Thread asfgit
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

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

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread kenn
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:

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

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

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

2016-10-11 Thread asfgit
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

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

2016-10-11 Thread kenn
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:

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

2016-10-11 Thread kenn
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:

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

2016-10-11 Thread kenn
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:

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

2016-10-11 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566814#comment-15566814 ] Kenneth Knowles commented on BEAM-741: -- Actually, what you say makes me want to investigate further.

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

2016-10-11 Thread Thomas Groh (JIRA)
[ 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

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

2016-10-11 Thread Pei He (JIRA)
[ 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

2016-10-11 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566498#comment-15566498 ] Amit Sela commented on BEAM-696: Does Dataflow "buffer until trigger..." if there are no sideInputs assigned

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

2016-10-11 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566498#comment-15566498 ] Amit Sela edited comment on BEAM-696 at 10/11/16 8:42 PM: -- Does Dataflow "buffer

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

2016-10-11 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15566498#comment-15566498 ] Amit Sela edited comment on BEAM-696 at 10/11/16 8:41 PM: -- Does Dataflow "buffer

[1/2] incubator-beam git commit: Define DataSourceConfiguration as public in JdbcIO

2016-10-11 Thread jbonofre
Repository: incubator-beam Updated Branches: refs/heads/master daf69f87e -> 6c8821682 Define DataSourceConfiguration as public in JdbcIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/89cfee06 Tree:

Jenkins build is back to normal : beam_PostCommit_RunnableOnService_FlinkLocal #529

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread jbonofre
This closes #1075 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6c882168 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6c882168 Diff:

[GitHub] incubator-beam pull request #1075: Define DataSourceConfiguration as public ...

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

Jenkins build is back to normal : beam_PostCommit_MavenVerify #1494

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread Apache Jenkins Server
See

Jenkins build became unstable: beam_PostCommit_MavenVerify #1496

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread Apache Jenkins Server
See

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

2016-10-11 Thread JIRA
[ 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

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

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

2016-10-11 Thread jbonofre
[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:

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

2016-10-11 Thread asfgit
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

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

2016-10-11 Thread jbonofre
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:

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

2016-10-11 Thread JIRA
[ 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 >

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

2016-10-11 Thread Aljoscha Krettek (JIRA)
[ 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

2016-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565001#comment-15565001 ] Aljoscha Krettek commented on BEAM-696: --- Just to make it clear what the Flink runner does for this: