[jira] [Resolved] (BEAM-161) Create FAQ

[ https://issues.apache.org/jira/browse/BEAM-161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-161. --- Resolution: Later Fix Version/s: 0.1.0-incubating Not applicable Not actively

[jira] [Updated] (BEAM-161) Create FAQ

[ https://issues.apache.org/jira/browse/BEAM-161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-161: -- Fix Version/s: (was: 0.1.0-incubating) > Create FAQ > -- > > Key: BEAM-161 >

[jira] [Commented] (BEAM-1727) Add setForNowAlign(period, offset) to Timer

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

[GitHub] beam pull request #2273: [BEAM-1727] Add setForNowAlign(period, offset) to T...

GitHub user JingsongLi opened a pull request: https://github.com/apache/beam/pull/2273 [BEAM-1727] Add setForNowAlign(period, offset) to Timer Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[2/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/0765aa05 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/0765aa05 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/0765aa05

[GitHub] beam-site pull request #191: Change peihe company affiliation to Alibaba.

Github user asfgit closed the pull request at: https://github.com/apache/beam-site/pull/191 --- 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/3] beam-site git commit: This closes #191

This closes #191 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/6b377549 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/6b377549 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/6b377549

[1/3] beam-site git commit: Change peihe company affiliation to Alibaba.

Repository: beam-site Updated Branches: refs/heads/asf-site 41018ed60 -> 6b3775494 Change peihe company affiliation to Alibaba. Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/13a88d23 Tree:

[jira] [Commented] (BEAM-1439) Beam Example(s) exploring public document datasets

[ https://issues.apache.org/jira/browse/BEAM-1439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932063#comment-15932063 ] SungJunyoung commented on BEAM-1439: The current Beam example counts the number of occurrences of a

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2589

See

[GitHub] beam-site pull request #191: Change peihe company affiliation to Alibaba.

GitHub user peihe opened a pull request: https://github.com/apache/beam-site/pull/191 Change peihe company affiliation to Alibaba. You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/beam-site asf-site Alternatively you can

[jira] [Comment Edited] (BEAM-1542) Need Source/Sink for Spanner

[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932041#comment-15932041 ] Guy Molinari edited comment on BEAM-1542 at 3/20/17 12:28 AM: -- Gentlemen,

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2951

See -- [...truncated 1.12 MB...] 2017-03-20T00:23:30.838 [INFO] 2017-03-20\T\00:23:30.838 [INFO] Finished at: 2017-03-20T00:23:30+00:00 2017-03-20T00:23:30.980 [INFO]

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Spark #1283

See

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932041#comment-15932041 ] Guy Molinari commented on BEAM-1542: Gentlemen, I have fixed the compilation error (weird generic

[jira] [Created] (BEAM-1754) Will Dataflow ever support Node.js with an SDK similar to Java or Python?

Diego Zuluaga created BEAM-1754: --- Summary: Will Dataflow ever support Node.js with an SDK similar to Java or Python? Key: BEAM-1754 URL: https://issues.apache.org/jira/browse/BEAM-1754 Project: Beam

[jira] [Updated] (BEAM-1568) Ineffective null check in IsmFormat#structuralValue

[ https://issues.apache.org/jira/browse/BEAM-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1568: - Description: {code} public Object structuralValue(IsmRecord record) throws Exception {

[jira] [Resolved] (BEAM-1574) MongoDbIOTest fails due to inability to download mongodb tar ball

[ https://issues.apache.org/jira/browse/BEAM-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BEAM-1574. -- Resolution: Cannot Reproduce Fix Version/s: Not applicable > MongoDbIOTest fails due to inability to

[jira] [Created] (BEAM-1753) ImportError (cannot import name descriptor) in new venv after 'python setup.py install'

María GH created BEAM-1753: -- Summary: ImportError (cannot import name descriptor) in new venv after 'python setup.py install' Key: BEAM-1753 URL: https://issues.apache.org/jira/browse/BEAM-1753 Project:

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2949

See Changes: [amitsela33] [BEAM-1752, BEAM-1582] execute tests that recover from checkpoint in -- [...truncated 2.15 MB...] 2017-03-19T18:40:51.561

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1550

See

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #1282

See -- [...truncated 1.69 KB...] maven33-agent.jar already up to date maven33-interceptor.jar already up to date maven3-interceptor-commons.jar already up to

[jira] [Commented] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931859#comment-15931859 ] Amit Sela commented on BEAM-1582: - Moved tests that use checkpoint recovery to post-commit. Keeping open

[jira] [Commented] (BEAM-1752) Tag Spark runner tests that recover from checkpoint.

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

[jira] [Resolved] (BEAM-1752) Tag Spark runner tests that recover from checkpoint.

[ https://issues.apache.org/jira/browse/BEAM-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1752. - Resolution: Fixed Fix Version/s: First stable release > Tag Spark runner tests that recover from

[GitHub] beam pull request #2272: [BEAM-1752, BEAM-1582] Move checkpoint recovery tes...

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

This closes #2272 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/faa9645d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/faa9645d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/faa9645d Branch:

[1/2] beam git commit: [BEAM-1752, BEAM-1582] execute tests that recover from checkpoint in post-commit. Add UsesCheckpointRecovery tag to mark Spark runner tests that recover from checkpoint.

Repository: beam Updated Branches: refs/heads/master 3f0fe91aa -> faa9645d2 [BEAM-1752, BEAM-1582] execute tests that recover from checkpoint in post-commit. Add UsesCheckpointRecovery tag to mark Spark runner tests that recover from checkpoint. Mark ResumeFromCheckpointStreamingTest with

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Spark #1280

See

[jira] [Assigned] (BEAM-1075) Shuffle the input read-values to get maximum parallelism.

[ https://issues.apache.org/jira/browse/BEAM-1075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1075: --- Assignee: Aviem Zur (was: Amit Sela) > Shuffle the input read-values to get maximum parallelism. >

[jira] [Assigned] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded.

[ https://issues.apache.org/jira/browse/BEAM-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1074: --- Assignee: Aviem Zur (was: Amit Sela) > Set default-partitioner in SourceRDD.Unbounded. >

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Flink #1982

See

[jira] [Created] (BEAM-1752) Tag Spark runner tests that recover from checkpoint.

Amit Sela created BEAM-1752: --- Summary: Tag Spark runner tests that recover from checkpoint. Key: BEAM-1752 URL: https://issues.apache.org/jira/browse/BEAM-1752 Project: Beam Issue Type: Test

[jira] [Updated] (BEAM-1751) Singleton ByteKeyRange with BigtableIO and Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] peay updated BEAM-1751: --- Description: I am getting this exception on a smallish table of a couple hundreds of rows from Bigtable, when running

[jira] [Created] (BEAM-1751) Singleton ByteKeyRange with BigtableIO and Dataflow runner

peay created BEAM-1751: -- Summary: Singleton ByteKeyRange with BigtableIO and Dataflow runner Key: BEAM-1751 URL: https://issues.apache.org/jira/browse/BEAM-1751 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #1981

See Changes: [aviemzur] [BEAM-1726] Fix Flatten with input copies in Flink Streaming Runner -- GitHub pull request #2263 of commit

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2948

See -- [...truncated 1.12 MB...] 2017-03-19T12:20:07.889 [INFO] 2017-03-19\T\12:20:07.889 [INFO] Finished at: 2017-03-19T12:20:07+00:00 2017-03-19T12:20:08.015 [INFO]

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #1279

See -- [...truncated 1.69 KB...] maven33-agent.jar already up to date maven33-interceptor.jar already up to date maven3-interceptor-commons.jar already up to

[jira] [Commented] (BEAM-1676) SdkCoreApiSurfaceTest Failed When Directory Contains Space

[ https://issues.apache.org/jira/browse/BEAM-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931625#comment-15931625 ] Stas Levin commented on BEAM-1676: -- Good catch [~markflyhigh], looks like it has to do with [this issue in

Build failed in Jenkins: beam_PostCommit_Python_Verify #1548

See -- [...truncated 392.98 KB...] Collecting pbr>=0.11 (from mock->-r postcommit_requirements.txt (line 2)) File was already downloaded

[jira] [Updated] (BEAM-1685) Measure and report code coverage in Python-SDK's unit tests

[ https://issues.apache.org/jira/browse/BEAM-1685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1685: - Fix Version/s: (was: 0.6.0) > Measure and report code coverage in Python-SDK's unit tests >

[jira] [Updated] (BEAM-1685) Measure and report code coverage in Python-SDK's unit tests

[ https://issues.apache.org/jira/browse/BEAM-1685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1685: - Fix Version/s: 0.6.0 > Measure and report code coverage in Python-SDK's unit tests >

[jira] [Assigned] (BEAM-972) Add basic level of unit testing to gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned BEAM-972: --- Assignee: Huafeng Wang (was: Manu Zhang) > Add basic level of unit testing to gearpump runner >

[jira] [Assigned] (BEAM-968) Update capability matrix to include gearpump-runner

[ https://issues.apache.org/jira/browse/BEAM-968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned BEAM-968: --- Assignee: Huafeng Wang (was: Manu Zhang) > Update capability matrix to include gearpump-runner >

[jira] [Resolved] (BEAM-971) Add support for merging windows in gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang resolved BEAM-971. - Resolution: Fixed Fix Version/s: Not applicable > Add support for merging windows in gearpump runner

[jira] [Resolved] (BEAM-970) Add side-input/side-output support to gearpump-runner

[ https://issues.apache.org/jira/browse/BEAM-970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang resolved BEAM-970. - Resolution: Fixed Fix Version/s: Not applicable > Add side-input/side-output support to

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #1979

See