[jira] [Updated] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException

[ https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guenther Grill updated BEAM-2943: - Summary: Beam Flink deployment results in ClassNotFoundException (was: Beam Flink execution not wo

[jira] [Updated] (BEAM-2943) Beam Flink execution not working

[ https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guenther Grill updated BEAM-2943: - Description: Hi, I followed the guide https://beam.apache.org/documentation/runners/flink/ to run

[jira] [Updated] (BEAM-2943) Beam Flink execution not working

[ https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guenther Grill updated BEAM-2943: - Description: Hi, I followed the guide https://beam.apache.org/documentation/runners/flink/ to run

[jira] [Created] (BEAM-2943) Beam Flink execution not working

Guenther Grill created BEAM-2943: Summary: Beam Flink execution not working Key: BEAM-2943 URL: https://issues.apache.org/jira/browse/BEAM-2943 Project: Beam Issue Type: Bug Compone

[GitHub] beam pull request #3839: Add javadoc to ConsoleIO

GitHub user joeyfezster opened a pull request: https://github.com/apache/beam/pull/3839 Add javadoc to ConsoleIO Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/proje

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3952

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4776

See -- [...truncated 254.99 KB...] 2017-09-12T06:01:48.833 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/apache/maven/doxia/doxia-decoration-model/1.4/dox

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #4775

See

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #3049

See

[jira] [Commented] (BEAM-2861) test_delete_bq_table_succeeds fails with GOOGLE_APPLICATION_CREDENTIALS

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

[GitHub] beam pull request #3825: [BEAM-2861] Fix tests which fail with google creden...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3825 ---

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

This closes #3825 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fcd11feb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fcd11feb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fcd11feb Branch: refs/heads/maste

[1/2] beam git commit: [BEAM-2861] Fix tests which fail with google credential

Repository: beam Updated Branches: refs/heads/master 3a83a661b -> fcd11feb9 [BEAM-2861] Fix tests which fail with google credential Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a95dc855 Tree: http://git-wip-us.apache.org/

Jenkins build is back to normal : beam_PostCommit_Python_Verify #3115

See

[jira] [Created] (BEAM-2942) DOCUMENTATION in header becomes too long, and needs redesign

Pei He created BEAM-2942: Summary: DOCUMENTATION in header becomes too long, and needs redesign Key: BEAM-2942 URL: https://issues.apache.org/jira/browse/BEAM-2942 Project: Beam Issue Type: Bug

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #3951

See

[jira] [Assigned] (BEAM-2893) Tez runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2893: - Assignee: (was: Kenneth Knowles) > Tez runs portable pipelines >

[jira] [Assigned] (BEAM-2826) Need to generate a single XML file when write is performed on small amount of data

[ https://issues.apache.org/jira/browse/BEAM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2826: - Assignee: Eugene Kirpichov (was: Kenneth Knowles) > Need to generate a single XML file wh

[jira] [Assigned] (BEAM-2903) Java SDK support for portable progress reporting

[ https://issues.apache.org/jira/browse/BEAM-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2903: - Assignee: (was: Kenneth Knowles) > Java SDK support for portable progress reporting >

[jira] [Commented] (BEAM-2516) User reports 4 minutes to process 1 million line CSV in DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162420#comment-16162420 ] Kenneth Knowles commented on BEAM-2516: --- The actual round-trip is behind a flag, but

[jira] [Assigned] (BEAM-2914) Fn API merging window support

[ https://issues.apache.org/jira/browse/BEAM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2914: - Assignee: (was: Kenneth Knowles) > Fn API merging window support > ---

[jira] [Assigned] (BEAM-2911) Tez supports portable progress reporting

[ https://issues.apache.org/jira/browse/BEAM-2911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2911: - Assignee: (was: Kenneth Knowles) > Tez supports portable progress reporting >

[jira] [Assigned] (BEAM-2922) Tez support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2922: - Assignee: (was: Kenneth Knowles) > Tez support for portable user state > -

[jira] [Assigned] (BEAM-2925) Fn API user timer support

[ https://issues.apache.org/jira/browse/BEAM-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2925: - Assignee: (was: Kenneth Knowles) > Fn API user timer support > ---

[jira] [Assigned] (BEAM-2937) Fn API combiner support w/ lifting to PGBK

[ https://issues.apache.org/jira/browse/BEAM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2937: - Assignee: (was: Kenneth Knowles) > Fn API combiner support w/ lifting to PGBK > --

[jira] [Assigned] (BEAM-2926) Java SDK support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2926: - Assignee: (was: Kenneth Knowles) > Java SDK support for portable side input > ---

[jira] [Assigned] (BEAM-2886) Portable pipeline submission proxy

[ https://issues.apache.org/jira/browse/BEAM-2886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2886: - Assignee: Thomas Groh (was: Kenneth Knowles) > Portable pipeline submission proxy > -

[jira] [Assigned] (BEAM-2934) Tez support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2934: - Assignee: (was: Kenneth Knowles) > Tez support for portable side input > -

[jira] [Assigned] (BEAM-2868) Allow FileSystems.copy() to copy between different scheme

[ https://issues.apache.org/jira/browse/BEAM-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2868: - Assignee: Luke Cwik (was: Kenneth Knowles) > Allow FileSystems.copy() to copy between dif

[jira] [Commented] (BEAM-2868) Allow FileSystems.copy() to copy between different scheme

[ https://issues.apache.org/jira/browse/BEAM-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162415#comment-16162415 ] Kenneth Knowles commented on BEAM-2868: --- [~lcwik] I think you have the most recent ex

[jira] [Commented] (BEAM-2826) Need to generate a single XML file when write is performed on small amount of data

[ https://issues.apache.org/jira/browse/BEAM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162409#comment-16162409 ] Kenneth Knowles commented on BEAM-2826: --- [~jkff] has this situation changed so it is

[jira] [Assigned] (BEAM-2938) Fn API combiner support w/ lifting to GABW

[ https://issues.apache.org/jira/browse/BEAM-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2938: - Assignee: (was: Kenneth Knowles) > Fn API combiner support w/ lifting to GABW > --

[jira] [Assigned] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2939: - Assignee: (was: Kenneth Knowles) > Fn API streaming SDF support >

[jira] [Updated] (BEAM-2498) Dataflow runner should shade Runner/Fn API protos

[ https://issues.apache.org/jira/browse/BEAM-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2498: -- Fix Version/s: (was: 2.2.0) 2.3.0 > Dataflow runner should shade Runner/Fn

[jira] [Commented] (BEAM-2498) Dataflow runner should shade Runner/Fn API protos

[ https://issues.apache.org/jira/browse/BEAM-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162379#comment-16162379 ] Kenneth Knowles commented on BEAM-2498: --- Since we are cutting now, let's punt this.

[jira] [Commented] (BEAM-2761) Write to empty BigQuery partition fails with "No schema specified on job or table." despite having provided schema

[ https://issues.apache.org/jira/browse/BEAM-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162363#comment-16162363 ] Reuven Lax commented on BEAM-2761: -- Also a note - Create.empty(TableRowJsonCoder.of()) is

[jira] [Commented] (BEAM-2761) Write to empty BigQuery partition fails with "No schema specified on job or table." despite having provided schema

[ https://issues.apache.org/jira/browse/BEAM-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162362#comment-16162362 ] Reuven Lax commented on BEAM-2761: -- I've been trying to write a unit test that reproduces

[jira] [Assigned] (BEAM-2516) User reports 4 minutes to process 1 million line CSV in DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax reassigned BEAM-2516: Assignee: Kenneth Knowles > User reports 4 minutes to process 1 million line CSV in DirectRunner > -

[jira] [Assigned] (BEAM-2498) Dataflow runner should shade Runner/Fn API protos

[ https://issues.apache.org/jira/browse/BEAM-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax reassigned BEAM-2498: Assignee: Kenneth Knowles > Dataflow runner should shade Runner/Fn API protos >

[jira] [Commented] (BEAM-2498) Dataflow runner should shade Runner/Fn API protos

[ https://issues.apache.org/jira/browse/BEAM-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162332#comment-16162332 ] Reuven Lax commented on BEAM-2498: -- [~kenn] This is currently on to 2.2.0 list. Does this

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3950

See

[jira] [Assigned] (BEAM-2941) Portability milestone: windowed wordcount runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-2941: --- Assignee: (was: Kenneth Knowles) > Portability milestone: windowed wordcount runs everywhe

[jira] [Updated] (BEAM-2941) Portability milestone: windowed wordcount runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2941: Description: This issue tracks the broad milestone for adoption of the portability framework by runne

[jira] [Created] (BEAM-2941) Portability milestone: windowed wordcount runs everywhere

Henning Rohde created BEAM-2941: --- Summary: Portability milestone: windowed wordcount runs everywhere Key: BEAM-2941 URL: https://issues.apache.org/jira/browse/BEAM-2941 Project: Beam Issue Type

[jira] [Assigned] (BEAM-2940) Portability milestone: mobile gaming runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-2940: --- Assignee: (was: Kenneth Knowles) > Portability milestone: mobile gaming runs everywhere >

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4773

See Changes: [relax] Add ability to set job labels to BEAM Java SDK -- [...truncated 3.80 MB...] 2017-09-12T00:52:15.472 [INFO]

[jira] [Assigned] (BEAM-2905) ULR supports portable progress reporting

[ https://issues.apache.org/jira/browse/BEAM-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2905: - Assignee: (was: Kenneth Knowles) > ULR supports portable progress reporting >

[jira] [Updated] (BEAM-2917) ULR support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-2917: -- Component/s: runner-direct > ULR support for portable user state > --- >

[jira] [Updated] (BEAM-2928) ULR support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-2928: -- Component/s: runner-direct > ULR support for portable side input > --- >

[jira] [Updated] (BEAM-2905) ULR supports portable progress reporting

[ https://issues.apache.org/jira/browse/BEAM-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-2905: -- Component/s: runner-direct > ULR supports portable progress reporting > -

[jira] [Assigned] (BEAM-2928) ULR support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2928: - Assignee: (was: Thomas Groh) > ULR support for portable side input > -

[jira] [Assigned] (BEAM-2928) ULR support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2928: - Assignee: Thomas Groh (was: Kenneth Knowles) > ULR support for portable side input >

[jira] [Assigned] (BEAM-2917) ULR support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2917: - Assignee: Thomas Groh > ULR support for portable user state > ---

[jira] [Assigned] (BEAM-2917) ULR support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2917: - Assignee: (was: Thomas Groh) > ULR support for portable user state > -

Build failed in Jenkins: beam_PostCommit_Python_Verify #3114

See Changes: [relax] Add ability to set job labels to BEAM Java SDK -- [...truncated 643.18 KB...] Successfully downloaded pyhamcrest mock setuptools six func

[jira] [Updated] (BEAM-2940) Portability milestone: mobile gaming runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2940: Description: This issue tracks a broad milestone for adoption of the portability framework by runners

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4774

See -- [...truncated 1.57 MB...] 2017-09-12T00:39:09.826 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/apache/maven/archetype/archetype-descriptor/2.4/arc

[jira] [Updated] (BEAM-2896) Portability milestone: wordcount runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2896: Description: This issue tracks the first broad milestone for adoption of the portability framework by

[jira] [Created] (BEAM-2940) Portability milestone: mobile gaming runs everywhere

Henning Rohde created BEAM-2940: --- Summary: Portability milestone: mobile gaming runs everywhere Key: BEAM-2940 URL: https://issues.apache.org/jira/browse/BEAM-2940 Project: Beam Issue Type: Imp

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #3048

See

[jira] [Created] (BEAM-2939) Fn API streaming SDF support

Henning Rohde created BEAM-2939: --- Summary: Fn API streaming SDF support Key: BEAM-2939 URL: https://issues.apache.org/jira/browse/BEAM-2939 Project: Beam Issue Type: Improvement Compo

[jira] [Created] (BEAM-2938) Fn API combiner support w/ lifting to GABW

Henning Rohde created BEAM-2938: --- Summary: Fn API combiner support w/ lifting to GABW Key: BEAM-2938 URL: https://issues.apache.org/jira/browse/BEAM-2938 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-2937) Fn API combiner support w/ lifting to PGBK

Henning Rohde created BEAM-2937: --- Summary: Fn API combiner support w/ lifting to PGBK Key: BEAM-2937 URL: https://issues.apache.org/jira/browse/BEAM-2937 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-2936) JStorm support for portable side input

Henning Rohde created BEAM-2936: --- Summary: JStorm support for portable side input Key: BEAM-2936 URL: https://issues.apache.org/jira/browse/BEAM-2936 Project: Beam Issue Type: Sub-task

[jira] [Updated] (BEAM-2934) Tez support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2934: Summary: Tez support for portable side input (was: Tex support for portable side input) > Tez suppo

[jira] [Created] (BEAM-2934) Tex support for portable side input

Henning Rohde created BEAM-2934: --- Summary: Tex support for portable side input Key: BEAM-2934 URL: https://issues.apache.org/jira/browse/BEAM-2934 Project: Beam Issue Type: Sub-task C

[jira] [Created] (BEAM-2935) MapReduce support for portable side input

Henning Rohde created BEAM-2935: --- Summary: MapReduce support for portable side input Key: BEAM-2935 URL: https://issues.apache.org/jira/browse/BEAM-2935 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2933) Gearpump support for portable side input

Henning Rohde created BEAM-2933: --- Summary: Gearpump support for portable side input Key: BEAM-2933 URL: https://issues.apache.org/jira/browse/BEAM-2933 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2931) Apex support for portable side input

Henning Rohde created BEAM-2931: --- Summary: Apex support for portable side input Key: BEAM-2931 URL: https://issues.apache.org/jira/browse/BEAM-2931 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2930) Flink support for portable side input

Henning Rohde created BEAM-2930: --- Summary: Flink support for portable side input Key: BEAM-2930 URL: https://issues.apache.org/jira/browse/BEAM-2930 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2929) Dataflow support for portable side input

Henning Rohde created BEAM-2929: --- Summary: Dataflow support for portable side input Key: BEAM-2929 URL: https://issues.apache.org/jira/browse/BEAM-2929 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2932) Spark support for portable side input

Henning Rohde created BEAM-2932: --- Summary: Spark support for portable side input Key: BEAM-2932 URL: https://issues.apache.org/jira/browse/BEAM-2932 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2927) Python SDK support for portable side input

Henning Rohde created BEAM-2927: --- Summary: Python SDK support for portable side input Key: BEAM-2927 URL: https://issues.apache.org/jira/browse/BEAM-2927 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-2928) ULR support for portable side input

Henning Rohde created BEAM-2928: --- Summary: ULR support for portable side input Key: BEAM-2928 URL: https://issues.apache.org/jira/browse/BEAM-2928 Project: Beam Issue Type: Sub-task C

[jira] [Created] (BEAM-2926) Java SDK support for portable side input

Henning Rohde created BEAM-2926: --- Summary: Java SDK support for portable side input Key: BEAM-2926 URL: https://issues.apache.org/jira/browse/BEAM-2926 Project: Beam Issue Type: Sub-task

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4772

See

[jira] [Updated] (BEAM-2925) Fn API user timer support

[ https://issues.apache.org/jira/browse/BEAM-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2925: Issue Type: Improvement (was: Bug) > Fn API user timer support > - > >

[jira] [Created] (BEAM-2925) Fn API user timer support

Henning Rohde created BEAM-2925: --- Summary: Fn API user timer support Key: BEAM-2925 URL: https://issues.apache.org/jira/browse/BEAM-2925 Project: Beam Issue Type: Bug Components: beam

[jira] [Assigned] (BEAM-2917) ULR support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-2917: --- Assignee: (was: Kenneth Knowles) > ULR support for portable user state > -

[jira] [Assigned] (BEAM-2915) Java SDK support for portable user state

[ https://issues.apache.org/jira/browse/BEAM-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-2915: --- Assignee: (was: Kenneth Knowles) > Java SDK support for portable user state >

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4771

See

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #3949

See

[jira] [Commented] (BEAM-2829) Add ability to set job labels in DataflowPipelineOptions

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

[1/2] beam git commit: Add ability to set job labels to BEAM Java SDK

Repository: beam Updated Branches: refs/heads/master e8bf045f6 -> 3a83a661b Add ability to set job labels to BEAM Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b2f423d Tree: http://git-wip-us.apache.org/repos/asf

[GitHub] beam pull request #3797: [BEAM-2829] Add ability to set job labels for Dataf...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3797 ---

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

This closes #3797 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3a83a661 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3a83a661 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3a83a661 Branch: refs/heads/maste

[jira] [Closed] (BEAM-190) Dead-letter drop for bad BigQuery records

[ https://issues.apache.org/jira/browse/BEAM-190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax closed BEAM-190. --- Resolution: Fixed Fix Version/s: 2.1.0 > Dead-letter drop for bad BigQuery records >

[jira] [Closed] (BEAM-2305) Dinstinct transform produces unexpected output when triggered

[ https://issues.apache.org/jira/browse/BEAM-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax closed BEAM-2305. Resolution: Fixed Fix Version/s: 2.0.0 > Dinstinct transform produces unexpected output when triggered

[jira] [Updated] (BEAM-2761) Write to empty BigQuery partition fails with "No schema specified on job or table." despite having provided schema

[ https://issues.apache.org/jira/browse/BEAM-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax updated BEAM-2761: - Fix Version/s: 2.2.0 > Write to empty BigQuery partition fails with "No schema specified on job or > table

[jira] [Closed] (BEAM-1151) BigQueryIO.Write has no way of handling failures

[ https://issues.apache.org/jira/browse/BEAM-1151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax closed BEAM-1151. Resolution: Fixed Fix Version/s: 2.1.0 > BigQueryIO.Write has no way of handling failures > --

[jira] [Commented] (BEAM-2840) BigQueryIO write is slow/fail with a bounded source

[ https://issues.apache.org/jira/browse/BEAM-2840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162171#comment-16162171 ] Reuven Lax commented on BEAM-2840: -- How many dated tables? Can you post code that reproduc

[2/3] beam git commit: Cleans up PTransform validation across Beam

Cleans up PTransform validation across Beam - Moves validation from validate() to expand() when possible - Replaces checkNotNull() with checkArgument() when possible - Shortens overly verbose validation messages in a few IOs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http:

[GitHub] beam pull request #3730: Cleans up PTransform validation across Beam

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3730 ---

[3/3] beam git commit: This closes #3730: Cleans up PTransform validation across Beam

This closes #3730: Cleans up PTransform validation across Beam Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e8bf045f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e8bf045f Diff: http://git-wip-us.apache.org/repos/asf

[1/3] beam git commit: Cleans up PTransform validation across Beam

Repository: beam Updated Branches: refs/heads/master 98b0fd2b4 -> e8bf045f6 http://git-wip-us.apache.org/repos/asf/beam/blob/1a38de17/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java --

[jira] [Commented] (BEAM-2866) StateTable should key off state id, not StateTag, since coders may have bad equality

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

[2/2] beam git commit: This closes #3818: [BEAM-2866] Key StateTable off ID

This closes #3818: [BEAM-2866] Key StateTable off ID Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/98b0fd2b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/98b0fd2b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff

[GitHub] beam pull request #3818: [BEAM-2866] Key StateTable off ID

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3818 ---

[1/2] beam git commit: Key StateTable off id, not full StateTag

Repository: beam Updated Branches: refs/heads/master 774b26819 -> 98b0fd2b4 Key StateTable off id, not full StateTag Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb6f5bc6 Tree: http://git-wip-us.apache.org/repos/asf/beam/

[jira] [Commented] (BEAM-2804) support TIMESTAMP in Sort

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

  1   2   3   4   >