Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2662

2017-02-16 Thread Apache Jenkins Server
See

[GitHub] beam pull request #2027: Add Windowing snippets for Python SDK.

2017-02-16 Thread charlesccychen
GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/2027 Add Windowing snippets for Python SDK. You can merge this pull request into a Git repository by running: $ git pull https://github.com/charlesccychen/beam add-python-snippets

[jira] [Commented] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

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

[GitHub] beam pull request #2029: Override prep

2017-02-16 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2029 Override prep 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-] Description

[jira] [Resolved] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

2017-02-16 Thread Jason Kuster (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kuster resolved BEAM-1500. Resolution: Fixed Fix Version/s: Not applicable > Jenkins Job DSL doesn't conform to Groovy

[GitHub] beam pull request #2028: [BEAM-1504] Parameterized tests for standard coders...

2017-02-16 Thread vikkyrk
GitHub user vikkyrk opened a pull request: https://github.com/apache/beam/pull/2028 [BEAM-1504] Parameterized tests for standard coders in Python SDK Be sure to do all of the following to help us incorporate your contribution quickly and easily: `python setup.py test -s

[jira] [Commented] (BEAM-1504) Python standard coders test doesn't run with setup test

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870972#comment-15870972 ] ASF GitHub Bot commented on BEAM-1504: -- GitHub user vikkyrk opened a pull request:

[2/2] beam git commit: Bring common_job_properties closer to Groovy style

2017-02-16 Thread tgroh
Bring common_job_properties closer to Groovy style Fix "RunnableOnService" typo Signed-off-by: Jason Kuster Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c22a842 Tree:

[GitHub] beam pull request #2020: [BEAM-1500] Fix typos and bring common_job_properti...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2020 --- 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: This closes #2020

2017-02-16 Thread tgroh
Repository: beam Updated Branches: refs/heads/master 9151676a5 -> 41b24090f This closes #2020 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/41b24090 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/41b24090 Diff:

[GitHub] beam pull request #2006: [BEAM-646] Get the #apply out of the DirectRunner

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2006 --- 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/3] beam git commit: Use Graph Surgery in the DirectRunner

2017-02-16 Thread tgroh
Use Graph Surgery in the DirectRunner Remove DirectRunner#apply(). This migrates the DirectRunner to work on a runner-agnostic graph. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/77a1afb2 Tree:

[3/3] beam git commit: This closes #2006

2017-02-16 Thread tgroh
This closes #2006 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2ca3bf66 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2ca3bf66 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2ca3bf66 Branch:

[1/3] beam git commit: Clean up TransformHierarchy#replace

2017-02-16 Thread tgroh
Repository: beam Updated Branches: refs/heads/master 41b24090f -> 2ca3bf669 Clean up TransformHierarchy#replace Remove Existing Outputs from Producer Map in replace. This permits replacements to produce the same PValue as the transform they are replacing, for example in CreatePCollectionView.

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[jira] [Created] (BEAM-1504) Python standard coders test doesn't run with setup test

2017-02-16 Thread Vikas Kedigehalli (JIRA)
Vikas Kedigehalli created BEAM-1504: --- Summary: Python standard coders test doesn't run with setup test Key: BEAM-1504 URL: https://issues.apache.org/jira/browse/BEAM-1504 Project: Beam

[jira] [Commented] (BEAM-1116) Support for new Timer API in Flink runner

2017-02-16 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871001#comment-15871001 ] Jingsong Lee commented on BEAM-1116: [~kenn] I found that {{onTimer()}} requires the {{BoundedWindow}}

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Dataflow #2317

2017-02-16 Thread Apache Jenkins Server
See Changes: [peihe] [BEAM-59] Beam GcsFileSystem: port fileSizes() from GcsUtil for batch [klk] Add ability to bundle any message with components in Runner API

[jira] [Commented] (BEAM-1320) Add sphinx or pydocs documentation for python-sdk

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870819#comment-15870819 ] ASF GitHub Bot commented on BEAM-1320: -- GitHub user sb2nov opened a pull request:

[jira] [Commented] (BEAM-1320) Add sphinx or pydocs documentation for python-sdk

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870820#comment-15870820 ] ASF GitHub Bot commented on BEAM-1320: -- GitHub user sb2nov opened a pull request:

[jira] [Commented] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870832#comment-15870832 ] Davor Bonaci commented on BEAM-1499: Oh, sorry, [~staslev] -- you are more than welcome to tackle this.

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2316

2017-02-16 Thread Apache Jenkins Server
See

[1/2] beam git commit: Add ability to bundle any message with components in Runner API

2017-02-16 Thread kenn
Repository: beam Updated Branches: refs/heads/master 763fb50b5 -> 9151676a5 Add ability to bundle any message with components in Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/368ad236 Tree:

[GitHub] beam pull request #2023: [BEAM-115] Add convenience for wrapping up a self c...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2023 --- 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: This closes #2023: Add ability to bundle any message with components in Runner API

2017-02-16 Thread kenn
This closes #2023: Add ability to bundle any message with components in Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9151676a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9151676a Diff:

[GitHub] beam pull request #2026: [BEAM-1218] Moving dataflow runner related code to ...

2017-02-16 Thread aaltay
GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2026 [BEAM-1218] Moving dataflow runner related code to vendor directory R: @sb2nov You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam beam

[jira] [Commented] (BEAM-115) Beam Runner API

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

[jira] [Created] (BEAM-1503) GcsFileSystem: parallelize matchGlobs()

2017-02-16 Thread Pei He (JIRA)
Pei He created BEAM-1503: Summary: GcsFileSystem: parallelize matchGlobs() Key: BEAM-1503 URL: https://issues.apache.org/jira/browse/BEAM-1503 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-1218) De-Googlify Python SDK

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870900#comment-15870900 ] ASF GitHub Bot commented on BEAM-1218: -- GitHub user aaltay opened a pull request:

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Apex #524

2017-02-16 Thread Apache Jenkins Server
See

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2315

2017-02-16 Thread Apache Jenkins Server
See

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Flink #1666

2017-02-16 Thread Apache Jenkins Server
See

[1/2] beam git commit: [BEAM-59] Beam GcsFileSystem: port fileSizes() from GcsUtil for batch get StorageObjects.

2017-02-16 Thread pei
Repository: beam Updated Branches: refs/heads/master d04a88e7e -> 763fb50b5 [BEAM-59] Beam GcsFileSystem: port fileSizes() from GcsUtil for batch get StorageObjects. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85f04085

[GitHub] beam pull request #2015: [BEAM-59] Beam GcsFileSystem: port fileSizes() from...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2015 --- 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-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871176#comment-15871176 ] ASF GitHub Bot commented on BEAM-1497: -- GitHub user ravwojdyla opened a pull request:

[GitHub] beam pull request #2030: [BEAM-115,BEAM-1328] Convert to/from WindowingStrat...

2017-02-16 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2030 [BEAM-115,BEAM-1328] Convert to/from WindowingStrategy proto in Java SDK Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[jira] [Commented] (BEAM-115) Beam Runner API

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871158#comment-15871158 ] ASF GitHub Bot commented on BEAM-115: - GitHub user kennknowles opened a pull request:

[jira] [Updated] (BEAM-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1497: -- Labels: backward-incompatible (was: ) > Refactor Hadoop/HDFS IO > --- > >

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

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

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

2017-02-16 Thread dhalperi
This closes #2022 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9df1da49 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9df1da49 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9df1da49 Branch:

[jira] [Commented] (BEAM-1399) Code coverage numbers are not accurate

2017-02-16 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871282#comment-15871282 ] Daniel Halperin commented on BEAM-1399: --- Wow, you did a whole bunch of good research here,

[jira] [Comment Edited] (BEAM-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869992#comment-15869992 ] Jean-Baptiste Onofré edited comment on BEAM-1497 at 2/16/17 2:13 PM: -

[jira] [Commented] (BEAM-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869992#comment-15869992 ] Jean-Baptiste Onofré commented on BEAM-1497: By the way, there's a PR in progress about that.

[jira] [Created] (BEAM-1498) Use Flink-native side outputs

2017-02-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created BEAM-1498: -- Summary: Use Flink-native side outputs Key: BEAM-1498 URL: https://issues.apache.org/jira/browse/BEAM-1498 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-1498) Use Flink-native side outputs

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869941#comment-15869941 ] Aljoscha Krettek commented on BEAM-1498: [~lzljs3620320] I thought you might find this interesting.

[jira] [Assigned] (BEAM-1488) add ConsoleIO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1488: -- Assignee: Jean-Baptiste Onofré > add ConsoleIO > -- > >

[jira] [Updated] (BEAM-1488) Add ConsoleIO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-1488: --- Summary: Add ConsoleIO (was: add ConsoleIO ) > Add ConsoleIO > -- > >

[jira] [Commented] (BEAM-1488) add ConsoleIO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869988#comment-15869988 ] Jean-Baptiste Onofré commented on BEAM-1488: Good idea. It's pretty close to what I started on

[jira] [Commented] (BEAM-1205) Auto set "enableAbandonedNodeEnforcement" in TestPipeline

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

[jira] [Commented] (BEAM-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869982#comment-15869982 ] Jean-Baptiste Onofré commented on BEAM-1497: I would like to work with you on this one as we

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Apex #517

2017-02-16 Thread Apache Jenkins Server
See

[jira] [Updated] (BEAM-883) Make ApiSurfaceTest fail if something whitelisted is _not_ exposed

2017-02-16 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-883: Fix Version/s: (was: Not applicable) 0.6.0 > Make ApiSurfaceTest fail if something

[GitHub] beam pull request #2012: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix...

2017-02-16 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/2012 --- 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-1393) Update Flink Runner to Flink 1.2.0

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

[1/2] beam git commit: [BEAM-1205] Auto set "enableAbandonedNodeEnforcement" in TestPipeline

2017-02-16 Thread staslevin
Repository: beam Updated Branches: refs/heads/master 5fe78440b -> f03f6ac19 [BEAM-1205] Auto set "enableAbandonedNodeEnforcement" in TestPipeline Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50daea28 Tree:

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

2017-02-16 Thread staslevin
This closes #1706 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f03f6ac1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f03f6ac1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f03f6ac1 Branch:

[GitHub] beam pull request #1706: [BEAM-1205] Auto detect and set "enableAbandonedNod...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/1706 --- 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 #1960: [BEAM-1393] [BEAM-1394] [BEAM-1445] Update Flink Ru...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/1960 --- 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

[3/4] beam git commit: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

2017-02-16 Thread aljoscha
[BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems We now use the Flink InternalTimerService for all our timer needs and we use Flink Broadcast state to store side inputs. Changing those was both necessary and easier to to in one commit while updating to Flink 1.2. Project:

[1/4] beam git commit: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

2017-02-16 Thread aljoscha
Repository: beam Updated Branches: refs/heads/master f03f6ac19 -> 137fee95b http://git-wip-us.apache.org/repos/asf/beam/blob/7d32b93e/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java

[4/4] beam git commit: This closes #1960

2017-02-16 Thread aljoscha
This closes #1960 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/137fee95 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/137fee95 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/137fee95 Branch:

[jira] [Updated] (BEAM-882) Make ApiSurfaceTest detect the java package/module under test

2017-02-16 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-882: Fix Version/s: (was: Not applicable) 0.6.0 > Make ApiSurfaceTest detect the java

[jira] [Updated] (BEAM-878) Allow usage of ApiSurfaceTest providing nothing but a whitelist

2017-02-16 Thread Stas Levin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-878: Fix Version/s: (was: Not applicable) 0.6.0 > Allow usage of ApiSurfaceTest providing

[jira] [Closed] (BEAM-1445) Use Flink broadcast state to store side-input data

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1445. -- Resolution: Fixed Fix Version/s: 0.6.0 > Use Flink broadcast state to store side-input

[jira] [Closed] (BEAM-1394) Use Flink InternalTimerService for TimerInternals

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1394. -- Resolution: Fixed Fix Version/s: 0.6.0 > Use Flink InternalTimerService for

[jira] [Closed] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1393. -- Resolution: Fixed Fix Version/s: 0.6.0 > Update Flink Runner to Flink 1.2.0 >

[jira] [Commented] (BEAM-958) desiredNumWorkers in Dataflow is too low

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

[jira] [Comment Edited] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870154#comment-15870154 ] Ismaël Mejía edited comment on BEAM-1499 at 2/16/17 3:51 PM: - Good one Stas, we

[jira] [Comment Edited] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

2017-02-16 Thread Ibrahim Sharaf ElDen (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869155#comment-15869155 ] Ibrahim Sharaf ElDen edited comment on BEAM-1440 at 2/16/17 3:04 PM: -

[GitHub] beam pull request #2009: [BEAM-958] Improve desired number of splits in Data...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2009 --- 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] [Created] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread Stas Levin (JIRA)
Stas Levin created BEAM-1499: Summary: Update testing documentation at beam-site Key: BEAM-1499 URL: https://issues.apache.org/jira/browse/BEAM-1499 Project: Beam Issue Type: Improvement

[1/2] beam git commit: [BEAM-958] Improve desired number of splits in Dataflow.

2017-02-16 Thread dhalperi
Repository: beam Updated Branches: refs/heads/master 137fee95b -> cd4e6e402 [BEAM-958] Improve desired number of splits in Dataflow. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97829546 Tree:

[jira] [Assigned] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1499: -- Assignee: Jason Kuster (was: Davor Bonaci) > Update testing documentation at beam-site >

[jira] [Commented] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870477#comment-15870477 ] ASF GitHub Bot commented on BEAM-1500: -- GitHub user jasonkuster opened a pull request:

[GitHub] beam pull request #2020: [BEAM-1500] Fix typos and bring common_job_properti...

2017-02-16 Thread jasonkuster
GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/2020 [BEAM-1500] Fix typos and bring common_job_properties closer to Groovy style guide. Signed-off-by: Jason Kuster Be sure to do all of the following to help us

[jira] [Created] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

2017-02-16 Thread Jason Kuster (JIRA)
Jason Kuster created BEAM-1500: -- Summary: Jenkins Job DSL doesn't conform to Groovy style guide. Key: BEAM-1500 URL: https://issues.apache.org/jira/browse/BEAM-1500 Project: Beam Issue Type:

[jira] [Commented] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

2017-02-16 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870484#comment-15870484 ] Kenneth Knowles commented on BEAM-1500: --- Can you link to the Groovy style guide here? It might also

[jira] [Commented] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF(YARN_CONF) environmen variable

2017-02-16 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870402#comment-15870402 ] Davor Bonaci commented on BEAM-1491: Also, [~sisk], [~pei...@gmail.com] FYI. > HDFSFileSource should

[jira] [Created] (BEAM-1501) Transient Apex runner postcommit failure in ParDoBoundTranslatorTest.testMultiOutputParDoWithSideInputs

2017-02-16 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-1501: - Summary: Transient Apex runner postcommit failure in ParDoBoundTranslatorTest.testMultiOutputParDoWithSideInputs Key: BEAM-1501 URL:

[jira] [Commented] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

2017-02-16 Thread Chamikara Jayalath (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870400#comment-15870400 ] Chamikara Jayalath commented on BEAM-1440: -- Hi Ibrahim, Great to hear that you are interested in

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Apex #522

2017-02-16 Thread Apache Jenkins Server
See

[GitHub] beam-site pull request #157: Add custom sources and sinks for Python page

2017-02-16 Thread melap
GitHub user melap opened a pull request: https://github.com/apache/beam-site/pull/157 Add custom sources and sinks for Python page R: @aaltay You can merge this pull request into a Git repository by running: $ git pull https://github.com/melap/beam-site pycustomio

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2661

2017-02-16 Thread Apache Jenkins Server
See -- Started by GitHub push by asfgit [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #1665

2017-02-16 Thread Apache Jenkins Server
See -- Started by GitHub push by asfgit [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #523

2017-02-16 Thread Apache Jenkins Server
See -- Started by GitHub push by asfgit [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

[jira] [Commented] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870667#comment-15870667 ] Ismaël Mejía commented on BEAM-1499: Yes, of course, I will be following this issue and will try to add

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

2017-02-16 Thread tgroh
This closes #2019 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/817688aa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/817688aa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/817688aa Branch:

[GitHub] beam pull request #2019: [BEAM-646] Remove Unneccessary DataflowRunner Overr...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2019 --- 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] [Created] (BEAM-1502) CombinePerKey returns a list of lists when run locally, but something else when run on Dataflow

2017-02-16 Thread Pablo Estrada (JIRA)
Pablo Estrada created BEAM-1502: --- Summary: CombinePerKey returns a list of lists when run locally, but something else when run on Dataflow Key: BEAM-1502 URL: https://issues.apache.org/jira/browse/BEAM-1502

[jira] [Resolved] (BEAM-958) desiredNumWorkers in Dataflow is too low

2017-02-16 Thread Raghu Angadi (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi resolved BEAM-958. --- Resolution: Fixed Fix Version/s: 0.6.0 > desiredNumWorkers in Dataflow is too low >

[1/4] beam git commit: Simple refactoring of core content from Dataflow -> Beam

2017-02-16 Thread altay
Repository: beam Updated Branches: refs/heads/master 817688aac -> d04a88e7e Simple refactoring of core content from Dataflow -> Beam Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f394f506 Tree:

[jira] [Commented] (BEAM-1218) De-Googlify Python SDK

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

[4/4] beam git commit: This closes #2021

2017-02-16 Thread altay
This closes #2021 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d04a88e7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d04a88e7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d04a88e7 Branch:

[2/4] beam git commit: Move runners/dataflow to runners/google_cloud_dataflow

2017-02-16 Thread altay
Move runners/dataflow to runners/google_cloud_dataflow Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e2a4d55 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5e2a4d55 Diff:

[jira] [Resolved] (BEAM-1473) Remove unused windmill proto files from python sdk

2017-02-16 Thread Sourabh Bajaj (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sourabh Bajaj resolved BEAM-1473. - Resolution: Fixed > Remove unused windmill proto files from python sdk >

[GitHub] beam pull request #2021: [BEAM-1218] Move runners/dataflow to runners/google...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2021 --- 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-1497) Refactor Hadoop/HDFS IO

2017-02-16 Thread Rafal Wojdyla (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870305#comment-15870305 ] Rafal Wojdyla commented on BEAM-1497: - [~jbonofre] great. For now i would just like to push what we

[jira] [Commented] (BEAM-1499) Update testing documentation at beam-site

2017-02-16 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870300#comment-15870300 ] Davor Bonaci commented on BEAM-1499: [~jasonkuster], I think you'd be the best person to tackle this

[GitHub] beam pull request #2019: Remove Unneccessary DataflowRunner Overrides

2017-02-16 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2019 Remove Unneccessary DataflowRunner Overrides Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[jira] [Commented] (BEAM-1500) Jenkins Job DSL doesn't conform to Groovy style guide.

2017-02-16 Thread Jason Kuster (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870499#comment-15870499 ] Jason Kuster commented on BEAM-1500: Groovy style guide: http://groovy-lang.org/style-guide.html I'll

  1   2   >