[jira] [Created] (BEAM-2819) Key only reads from Google Datastore

Ilnar Taichinov created BEAM-2819: - Summary: Key only reads from Google Datastore Key: BEAM-2819 URL: https://issues.apache.org/jira/browse/BEAM-2819 Project: Beam Issue Type: Wish

[jira] [Closed] (BEAM-2126) Add JStorm runner to "Conbribute > Technical References > Ongoing Projects"

[ https://issues.apache.org/jira/browse/BEAM-2126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-2126. Resolution: Fixed Fix Version/s: Not applicable > Add JStorm runner to "Conbribute > Technical References >

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #3860

See

[GitHub] beam pull request #3774: Test show stall

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

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #4670

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4669

See Changes: [altay] Use the same termination logic in different places -- [...truncated 3.61 MB...] [WARNING] Cannot calculate digest of mojo class,

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4667

See

[jira] [Updated] (BEAM-2817) Bigquery queries should allow options to run in batch mode or not

[ https://issues.apache.org/jira/browse/BEAM-2817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-2817: - Labels: newbie starter (was: ) > Bigquery queries should allow options to run in batch

[jira] [Assigned] (BEAM-2817) Bigquery queries should allow options to run in batch mode or not

[ https://issues.apache.org/jira/browse/BEAM-2817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-2817: Assignee: (was: Chamikara Jayalath) > Bigquery queries should allow options to

[jira] [Commented] (BEAM-2817) Bigquery queries should allow options to run in batch mode or not

[ https://issues.apache.org/jira/browse/BEAM-2817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144591#comment-16144591 ] Chamikara Jayalath commented on BEAM-2817: -- Looks like this will be a good starter/newbie issue.

[1/2] beam git commit: Updates Dataflow worker to 20170825

Repository: beam Updated Branches: refs/heads/master 79a594f63 -> e33cc24a5 Updates Dataflow worker to 20170825 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0eb8abc8 Tree:

[GitHub] beam pull request #3771: Updates Dataflow worker to 20170825

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3771 --- 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 #3771: Updates Dataflow worker to 20170825

This closes #3771: Updates Dataflow worker to 20170825 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e33cc24a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e33cc24a Diff:

[jira] [Commented] (BEAM-2816) Create SplittableDoFnTester

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

[GitHub] beam pull request #3775: Use the same termination logic in different places ...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3775 --- 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: Use the same termination logic in different places

Repository: beam Updated Branches: refs/heads/master bbca4f741 -> 79a594f63 Use the same termination logic in different places Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/16f11326 Tree:

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

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

[jira] [Commented] (BEAM-2612) support variance builtin aggregation function

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

[jira] [Commented] (BEAM-2612) support variance builtin aggregation function

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

[GitHub] beam pull request #3568: [BEAM-2612] Variance builtin aggregation functions

GitHub user vectorijk reopened a pull request: https://github.com/apache/beam/pull/3568 [BEAM-2612] Variance builtin aggregation functions implement var_pop, var_samp builtin aggregation functions You can merge this pull request into a Git repository by running: $ git pull

[GitHub] beam pull request #3568: [BEAM-2612] Variance builtin aggregation functions

Github user vectorijk closed the pull request at: https://github.com/apache/beam/pull/3568 --- 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-2814) test_as_singleton_with_different_defaults test is flaky

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

[GitHub] beam pull request #3768: Fix beam_job_api to conform to proto naming convent...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3768 --- 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: Fix beam_job_api to conform to proto naming conventions.

Fix beam_job_api to conform to proto naming conventions. This closes #3768 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bbca4f74 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bbca4f74 Diff:

[1/2] beam git commit: Fix beam_job_api to conform to proto naming conventions.

Repository: beam Updated Branches: refs/heads/master aef89dea8 -> bbca4f741 Fix beam_job_api to conform to proto naming conventions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4764883a Tree:

[jira] [Resolved] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-2813. --- Resolution: Won't Fix Fix Version/s: Not applicable > error: option --test-pipeline-options not

[jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144545#comment-16144545 ] Ahmet Altay commented on BEAM-2813: --- I think printing potential conflicts is a good idea. That could be a

[jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144523#comment-16144523 ] Mark Liu commented on BEAM-2813: Not sure if pinning a dependency will work since both pyasn1 and

[jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144502#comment-16144502 ] Ahmet Altay commented on BEAM-2813: --- Sounds good. Can we prevent this problem in the future? (e.g. by

[jira] [Comment Edited] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144500#comment-16144500 ] Mark Liu edited comment on BEAM-2813 at 8/28/17 10:58 PM: -- I think this is a

[jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized

[ https://issues.apache.org/jira/browse/BEAM-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144500#comment-16144500 ] Mark Liu commented on BEAM-2813: I think this is a version mismatch in dependencies. This line may related

[GitHub] beam pull request #3776: Added snippet tags for documentation

GitHub user davidcavazos opened a pull request: https://github.com/apache/beam/pull/3776 Added snippet tags for documentation Hi @aaltay, Adding tags to extract code snippets for the documentation. These are following the same sections as in the Java version. You can

[beam-site] branch asf-site updated: Add content for new post, missed by automatic deployment

This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git The following commit(s) were added to refs/heads/asf-site by this push: new f8e5099 Add content for new post, missed

[jira] [Resolved] (BEAM-541) Add more documentation on DoFn Annotations

[ https://issues.apache.org/jira/browse/BEAM-541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-541. -- Resolution: Duplicate Fix Version/s: Not applicable > Add more documentation on DoFn

[jira] [Commented] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144399#comment-16144399 ] Peter Hausel commented on BEAM-2815: [~altay] yes, if there is anything we can do from our end, we

[jira] [Resolved] (BEAM-2333) Rehydrate Pipeline from Runner API proto

[ https://issues.apache.org/jira/browse/BEAM-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2333. --- Resolution: Fixed Fix Version/s: 2.1.0 I think, since the DirectRunner now does this,

[jira] [Assigned] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection

[ https://issues.apache.org/jira/browse/BEAM-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2787: - Assignee: (was: Kenneth Knowles) > IllegalArgumentException with MongoDbIO with empty

[jira] [Updated] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection

[ https://issues.apache.org/jira/browse/BEAM-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2787: -- Component/s: (was: beam-model) sdk-java-extensions >

[jira] [Commented] (BEAM-2705) DoFnTester supports for StateParameter

[ https://issues.apache.org/jira/browse/BEAM-2705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144391#comment-16144391 ] Kenneth Knowles commented on BEAM-2705: --- This is a pretty good idea - just unassigning it so someone

[jira] [Commented] (BEAM-1957) Missing DoFn annotations documentation

[ https://issues.apache.org/jira/browse/BEAM-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144390#comment-16144390 ] Kenneth Knowles commented on BEAM-1957: --- Yes, we also need to cover all the state and timers APIs. I

[jira] [Assigned] (BEAM-1957) Missing DoFn annotations documentation

[ https://issues.apache.org/jira/browse/BEAM-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1957: - Assignee: (was: Kenneth Knowles) > Missing DoFn annotations documentation >

[jira] [Commented] (BEAM-1062) Shade SDK based on a whitelist instead of a blacklist

[ https://issues.apache.org/jira/browse/BEAM-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144387#comment-16144387 ] Kenneth Knowles commented on BEAM-1062: --- The PR is still out there, but I haven't had time to look at

[jira] [Assigned] (BEAM-2674) Runner API translators should own their rehydration

[ https://issues.apache.org/jira/browse/BEAM-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2674: - Assignee: (was: Kenneth Knowles) > Runner API translators should own their

[beam-site] branch asf-site updated (6386ac2 -> 5bd80e6)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 6386ac2 Prepare repository for deployment. add 155c697 Add blog post with timely processing

[beam-site] 01/01: Prepare repository for deployment.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 5bd80e6ef06e2f0c9920b9477481307c27499361 Author: Mergebot AuthorDate: Mon Aug 28

[jira] [Commented] (BEAM-2807) NullPointerException during checkpoint on FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144384#comment-16144384 ] Kenneth Knowles commented on BEAM-2807: --- I'll be somewhat less available for the next week, and

[jira] [Assigned] (BEAM-1062) Shade SDK based on a whitelist instead of a blacklist

[ https://issues.apache.org/jira/browse/BEAM-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1062: - Assignee: (was: Kenneth Knowles) > Shade SDK based on a whitelist instead of a

[jira] [Assigned] (BEAM-2758) ParDo should indicate what "features" are used in DisplayData

[ https://issues.apache.org/jira/browse/BEAM-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2758: - Assignee: (was: Kenneth Knowles) > ParDo should indicate what "features" are used in

[jira] [Assigned] (BEAM-2807) NullPointerException during checkpoint on FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2807: - Assignee: Aljoscha Krettek (was: Kenneth Knowles) > NullPointerException during

[beam-site] 01/02: Add blog post with timely processing

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 155c6979f5ab2609ab74f9bc1ac61a8c60ddd9e7 Author: Kenneth Knowles AuthorDate: Tue Aug 15

[beam-site] 02/02: This closes #296

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 7a775c109865eed06d86b536750fa8f4896bd6b3 Merge: 6386ac2 155c697 Author: Mergebot

[beam-site] branch mergebot updated (ec83da1 -> 7a775c1)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. from ec83da1 This closes #300 add 6386ac2 Prepare repository for deployment. new 155c697 Add

[jira] [Updated] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky

[ https://issues.apache.org/jira/browse/BEAM-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-2814: -- Description: {{test_as_singleton_with_different_defaults}} is flaky and failed in the post commit test

[jira] [Commented] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144358#comment-16144358 ] Ahmet Altay commented on BEAM-2815: --- This is a known issue and tracked in the issue you mentioned

[jira] [Assigned] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-2815: - Assignee: Ahmet Altay (was: Thomas Groh) > Python DirectRunner is unusable with input files in

[jira] [Updated] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-2815: -- Component/s: sdk-py > Python DirectRunner is unusable with input files in the 100-250MB range >

[jira] [Updated] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Hausel updated BEAM-2815: --- Attachment: Screen Shot 2017-08-27 at 9.00.29 AM.png Screen Shot 2017-08-27 at 9.06.00

[jira] [Updated] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range

[ https://issues.apache.org/jira/browse/BEAM-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Hausel updated BEAM-2815: --- Description: The current python DirectRunner implementation seems to be unusable with training data

[jira] [Created] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky

Ahmet Altay created BEAM-2814: - Summary: test_as_singleton_with_different_defaults test is flaky Key: BEAM-2814 URL: https://issues.apache.org/jira/browse/BEAM-2814 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-2813) error: option --test-pipeline-options not recognized

Ahmet Altay created BEAM-2813: - Summary: error: option --test-pipeline-options not recognized Key: BEAM-2813 URL: https://issues.apache.org/jira/browse/BEAM-2813 Project: Beam Issue Type: Bug

[GitHub] beam pull request #3775: Use the same termination logic in different places ...

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/3775 Use the same termination logic in different places in DataflowRunner Use the same termination check for `wait_until_finish` and `_is_in_terminal_state`. Note that this only affects an `assert` with a

[GitHub] beam pull request #3774: Test show stall

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/3774 Test show stall You can merge this pull request into a Git repository by running: $ git pull https://github.com/mariapython/incubator-beam retry_gbk2 Alternatively you can review and

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3857

See

[jira] [Commented] (BEAM-2484) Add streaming examples for Python

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

[GitHub] beam pull request #3756: Tests for python gaming examples

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

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4665

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #3013

See Changes: [lcwik] [BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient [lcwik] Initialize the Coder in DecodeAndEmitDoFn [robertwb] Wrap unknown coders in LengthPrefixCoder.

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4663

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3856

See

[jira] [Commented] (BEAM-2806) support View.CreatePCollectionView in FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144121#comment-16144121 ] Xu Mingmin commented on BEAM-2806: -- I'm running on DSL_SQL branch, --sync-up from master at July 12 . It

[jira] [Commented] (BEAM-2457) Error: "Unable to find registrar for hdfs" - need to prevent/improve error message

[ https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144110#comment-16144110 ] Flavio Fiszman commented on BEAM-2457: -- I'm not sure about the error in 2.2.0-SNAPSHOT, but for the

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #4662

See

Jenkins build is back to normal : beam_PostCommit_Python_Verify #3012

See

[jira] [Commented] (BEAM-2792) Populate All Runner API Components from the Python SDK

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

[GitHub] beam pull request #3764: [BEAM-2792] Wrap unknown coders in LengthPrefixCode...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3764 --- 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: Wrap unknown coders in LengthPrefixCoder.

Wrap unknown coders in LengthPrefixCoder. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/08a44874 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/08a44874 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/08a44874

[GitHub] beam pull request #3769: Initialize the Coder in DecodeAndEmitDoFn

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3769 --- 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: Initialize the Coder in DecodeAndEmitDoFn

Initialize the Coder in DecodeAndEmitDoFn This closes #3769 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e6d5e088 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e6d5e088 Diff:

[1/2] beam git commit: Initialize the Coder in DecodeAndEmitDoFn

Repository: beam Updated Branches: refs/heads/master ba5c4071d -> e6d5e0887 Initialize the Coder in DecodeAndEmitDoFn Ensure that the coder is available before it is used Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api

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

[2/2] beam git commit: [BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient

[BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient This closes #3760 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ba5c4071 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ba5c4071 Diff:

[1/2] beam git commit: [BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient

Repository: beam Updated Branches: refs/heads/master f634aecbb -> ba5c4071d [BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8d36a261 Tree:

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #2933

See

[GitHub] beam pull request #3773: Small tweak to View.asList javadoc

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3773 --- 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: Small tweak to View.asList javadoc

Small tweak to View.asList javadoc This closes #3773 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f634aecb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f634aecb Diff:

[1/2] beam git commit: Small tweak to View.asList javadoc

Repository: beam Updated Branches: refs/heads/master d50c9644e -> f634aecbb Small tweak to View.asList javadoc This may help clarify https://lists.apache.org/thread.html/cd9bd1ae4b6945cd78e04b3baa7628bd43071c443a752acbb83d388d@%3Cdev.beam.apache.org%3E Project:

Build failed in Jenkins: beam_PostCommit_Python_Verify #3011

See -- [...truncated 619.06 KB...] File was already downloaded /tmp/dataflow-requirements-cache/mock-2.0.0.tar.gz Collecting setuptools (from pyhamcrest->-r

[jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter

[ https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143916#comment-16143916 ] Eugene Kirpichov commented on BEAM-2802: Hmm, I have a hard time thinking why somebody would think

[jira] [Commented] (BEAM-2806) support View.CreatePCollectionView in FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143897#comment-16143897 ] Aljoscha Krettek commented on BEAM-2806: I tried this on the Flink Runner (both batch and

[jira] [Commented] (BEAM-2457) Error: "Unable to find registrar for hdfs" - need to prevent/improve error message

[ https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143846#comment-16143846 ] Aljoscha Krettek commented on BEAM-2457: Is there any update on this? I have a jar file that I

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #4661

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3855

See

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2932

See

[jira] [Updated] (BEAM-2812) Dropped windows counters / log prints no longer working

[ https://issues.apache.org/jira/browse/BEAM-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-2812: Description: In https://github.com/apache/beam/pull/2838 aggregators were removed from Spark runner, this

[jira] [Created] (BEAM-2812) Dropped windows counters / log prints no longer working

Aviem Zur created BEAM-2812: --- Summary: Dropped windows counters / log prints no longer working Key: BEAM-2812 URL: https://issues.apache.org/jira/browse/BEAM-2812 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-2803) JdbcIO read is very slow when query return a lot of rows

[ https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143489#comment-16143489 ] Jérémie Vexiau commented on BEAM-2803: -- I think also side input is a good solution. especially for

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #4660

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3854

See

[jira] [Created] (BEAM-2811) Complete the removal of aggregators from Spark runner.

Aviem Zur created BEAM-2811: --- Summary: Complete the removal of aggregators from Spark runner. Key: BEAM-2811 URL: https://issues.apache.org/jira/browse/BEAM-2811 Project: Beam Issue Type: Task

[jira] [Commented] (BEAM-2760) Disable testMergingCustomWindows* validatesRunner tests in Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143459#comment-16143459 ] Etienne Chauchot commented on BEAM-2760: Hi [~vectorijk]. This is true. That is why custom window

  1   2   >