[jira] [Work logged] (BEAM-5884) Allow nested types have null value.

[ https://issues.apache.org/jira/browse/BEAM-5884?focusedWorklogId=172181&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172181 ] ASF GitHub Bot logged work on BEAM-5884: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6159) Dataflow portable runner harness should use ExecutableStage to process bundle

[ https://issues.apache.org/jira/browse/BEAM-6159?focusedWorklogId=172168&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172168 ] ASF GitHub Bot logged work on BEAM-6159: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5817) Nexmark test of joining stream to files

[ https://issues.apache.org/jira/browse/BEAM-5817?focusedWorklogId=172164&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172164 ] ASF GitHub Bot logged work on BEAM-5817: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5884) Allow nested types have null value.

[ https://issues.apache.org/jira/browse/BEAM-5884?focusedWorklogId=172163&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172163 ] ASF GitHub Bot logged work on BEAM-5884: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-6169) Dataflow runner: rateLimit exceeded from BigQuery API in start_bundle

[ https://issues.apache.org/jira/browse/BEAM-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-6169: - Assignee: Chamikara Jayalath (was: Kenneth Knowles) > Dataflow runner: rateLimit exceede

[jira] [Updated] (BEAM-6169) Dataflow runner: rateLimit exceeded from BigQuery API in start_bundle

[ https://issues.apache.org/jira/browse/BEAM-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6169: -- Component/s: (was: gcp-quota) sdk-py-core > Dataflow runner: rateLimit exce

[jira] [Work logged] (BEAM-5817) Nexmark test of joining stream to files

[ https://issues.apache.org/jira/browse/BEAM-5817?focusedWorklogId=172148&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172148 ] ASF GitHub Bot logged work on BEAM-5817: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5514) BigQueryIO doesn't handle quotaExceeded errors properly

[ https://issues.apache.org/jira/browse/BEAM-5514?focusedWorklogId=172149&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172149 ] ASF GitHub Bot logged work on BEAM-5514: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5884) Allow nested types have null value.

[ https://issues.apache.org/jira/browse/BEAM-5884?focusedWorklogId=172144&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172144 ] ASF GitHub Bot logged work on BEAM-5884: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5884) Allow nested types have null value.

[ https://issues.apache.org/jira/browse/BEAM-5884?focusedWorklogId=172145&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172145 ] ASF GitHub Bot logged work on BEAM-5884: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6159) Dataflow portable runner harness should use ExecutableStage to process bundle

[ https://issues.apache.org/jira/browse/BEAM-6159?focusedWorklogId=172127&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172127 ] ASF GitHub Bot logged work on BEAM-6159: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2717) Infer coders in SDK prior to handing off pipeline to Runner

[ https://issues.apache.org/jira/browse/BEAM-2717?focusedWorklogId=172122&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172122 ] ASF GitHub Bot logged work on BEAM-2717: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6171) beam_PostCommit_Java_GradleBuild timing out (4 hours)

[ https://issues.apache.org/jira/browse/BEAM-6171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709474#comment-16709474 ] Udi Meiri commented on BEAM-6171: - Any updates? > beam_PostCommit_Java_GradleBuild timing

[jira] [Resolved] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

[ https://issues.apache.org/jira/browse/BEAM-6180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang resolved BEAM-6180. Resolution: Fixed Fix Version/s: 3.0.0 > Replace duplicated runner IdGenerator code with IdGe

[jira] [Work logged] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

[ https://issues.apache.org/jira/browse/BEAM-6180?focusedWorklogId=172117&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172117 ] ASF GitHub Bot logged work on BEAM-6180: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

[ https://issues.apache.org/jira/browse/BEAM-6180?focusedWorklogId=172116&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172116 ] ASF GitHub Bot logged work on BEAM-6180: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

[ https://issues.apache.org/jira/browse/BEAM-6180?focusedWorklogId=172115&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172115 ] ASF GitHub Bot logged work on BEAM-6180: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2400) Null pointer exception when creating a template

[ https://issues.apache.org/jira/browse/BEAM-2400?focusedWorklogId=172114&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172114 ] ASF GitHub Bot logged work on BEAM-2400: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6181) Utilize MetricInfo for reporting user metrics in Portable Dataflow Java Runner.

[ https://issues.apache.org/jira/browse/BEAM-6181?focusedWorklogId=172113&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172113 ] ASF GitHub Bot logged work on BEAM-6181: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6181) Utilize MetricInfo for reporting user metrics in Portable Dataflow Java Runner.

[ https://issues.apache.org/jira/browse/BEAM-6181?focusedWorklogId=172111&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172111 ] ASF GitHub Bot logged work on BEAM-6181: Author: ASF GitHub Bot

[jira] [Comment Edited] (BEAM-51) Implement a CSV file reader

[ https://issues.apache.org/jira/browse/BEAM-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709427#comment-16709427 ] Tanguy MONFORT edited comment on BEAM-51 at 12/5/18 12:14 AM: --

[jira] [Work logged] (BEAM-6139) Support for GEOGRAPHY data type in BQ sources

[ https://issues.apache.org/jira/browse/BEAM-6139?focusedWorklogId=172107&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172107 ] ASF GitHub Bot logged work on BEAM-6139: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-51) Implement a CSV file reader

[ https://issues.apache.org/jira/browse/BEAM-51?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709427#comment-16709427 ] Tanguy MONFORT commented on BEAM-51: Hello, I think, the CSV file reader should also be

[jira] [Work logged] (BEAM-6139) Support for GEOGRAPHY data type in BQ sources

[ https://issues.apache.org/jira/browse/BEAM-6139?focusedWorklogId=172101&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172101 ] ASF GitHub Bot logged work on BEAM-6139: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6139) Support for GEOGRAPHY data type in BQ sources

[ https://issues.apache.org/jira/browse/BEAM-6139?focusedWorklogId=172100&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172100 ] ASF GitHub Bot logged work on BEAM-6139: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6181) Utilize MetricInfo for reporting user metrics in Portable Dataflow Java Runner.

[ https://issues.apache.org/jira/browse/BEAM-6181?focusedWorklogId=172099&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172099 ] ASF GitHub Bot logged work on BEAM-6181: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6181) Utilize MetricInfo for reporting user metrics in Portable Dataflow Java Runner.

Mikhail Gryzykhin created BEAM-6181: --- Summary: Utilize MetricInfo for reporting user metrics in Portable Dataflow Java Runner. Key: BEAM-6181 URL: https://issues.apache.org/jira/browse/BEAM-6181 Pro

[jira] [Work logged] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

[ https://issues.apache.org/jira/browse/BEAM-6180?focusedWorklogId=172097&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172097 ] ASF GitHub Bot logged work on BEAM-6180: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-3797) Add reference entry for Filter

[ https://issues.apache.org/jira/browse/BEAM-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Fernandez reassigned BEAM-3797: -- Assignee: Melissa Pashniak (was: Rafael Fernandez) > Add reference entry for Filter >

[jira] [Assigned] (BEAM-6169) Dataflow runner: rateLimit exceeded from BigQuery API in start_bundle

[ https://issues.apache.org/jira/browse/BEAM-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Fernandez reassigned BEAM-6169: -- Assignee: Kenneth Knowles (was: Rafael Fernandez) > Dataflow runner: rateLimit exceede

[jira] [Created] (BEAM-6180) Replace duplicated runner IdGenerator code with IdGenerator from shared lib

Boyuan Zhang created BEAM-6180: -- Summary: Replace duplicated runner IdGenerator code with IdGenerator from shared lib Key: BEAM-6180 URL: https://issues.apache.org/jira/browse/BEAM-6180 Project: Beam

[jira] [Assigned] (BEAM-3763) Add per-transform documentation to the website

[ https://issues.apache.org/jira/browse/BEAM-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Fernandez reassigned BEAM-3763: -- Assignee: Melissa Pashniak (was: Rafael Fernandez) > Add per-transform documentation t

[jira] [Resolved] (BEAM-6160) Simplify service and server creation in dataflow runner harness

[ https://issues.apache.org/jira/browse/BEAM-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang resolved BEAM-6160. Resolution: Fixed Fix Version/s: 3.0.0 > Simplify service and server creation in dataflow run

[jira] [Commented] (BEAM-5105) Move load job poll to finishBundle() method to better parallelize execution

[ https://issues.apache.org/jira/browse/BEAM-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709370#comment-16709370 ] Chamikara Jayalath commented on BEAM-5105: -- This was fixed and available in Beam

[jira] [Assigned] (BEAM-5105) Move load job poll to finishBundle() method to better parallelize execution

[ https://issues.apache.org/jira/browse/BEAM-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5105: Assignee: Reuven Lax > Move load job poll to finishBundle() method to better parall

[jira] [Resolved] (BEAM-5105) Move load job poll to finishBundle() method to better parallelize execution

[ https://issues.apache.org/jira/browse/BEAM-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-5105. -- Resolution: Fixed > Move load job poll to finishBundle() method to better parallelize ex

[jira] [Updated] (BEAM-5105) Move load job poll to finishBundle() method to better parallelize execution

[ https://issues.apache.org/jira/browse/BEAM-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-5105: - Fix Version/s: 2.8.0 > Move load job poll to finishBundle() method to better parallelize e

[jira] [Work logged] (BEAM-6139) Support for GEOGRAPHY data type in BQ sources

[ https://issues.apache.org/jira/browse/BEAM-6139?focusedWorklogId=172086&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172086 ] ASF GitHub Bot logged work on BEAM-6139: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709271#comment-16709271 ] Ankur Goenka commented on BEAM-6179: cc: [~robertwb] > Batch size estimation failing

[jira] [Created] (BEAM-6179) Batch size estimation failing

Ankur Goenka created BEAM-6179: -- Summary: Batch size estimation failing Key: BEAM-6179 URL: https://issues.apache.org/jira/browse/BEAM-6179 Project: Beam Issue Type: Bug Components: ru

[jira] [Commented] (BEAM-2370) BigQuery Insert with Partition Decorator throwing error

e to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://www.googleapis.com/bigquery/v2/projects/bq-sql-load-test/datasets/telco_analytics/tables/clickstream_raw$20181204/insertAllException

[jira] [Work logged] (BEAM-5321) Finish Python 3 porting for transforms module

[ https://issues.apache.org/jira/browse/BEAM-5321?focusedWorklogId=172029&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172029 ] ASF GitHub Bot logged work on BEAM-5321: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-4850) Remove dependency on google-apitools package in Python SDK.

[ https://issues.apache.org/jira/browse/BEAM-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709191#comment-16709191 ] Mark Liu commented on BEAM-4850: https://github.com/apache/beam/pull/7051 is reverted sinc

[jira] [Commented] (BEAM-5663) Add tox suites for various Python 3 versions

[ https://issues.apache.org/jira/browse/BEAM-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709190#comment-16709190 ] Mark Liu commented on BEAM-5663: agree. I'll update the INFRA ticket. > Add tox suites fo

[jira] [Work logged] (BEAM-5321) Finish Python 3 porting for transforms module

[ https://issues.apache.org/jira/browse/BEAM-5321?focusedWorklogId=172028&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172028 ] ASF GitHub Bot logged work on BEAM-5321: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5167) Use concurrency information from SDK Harness in Flink Portable Runner

[ https://issues.apache.org/jira/browse/BEAM-5167?focusedWorklogId=172027&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172027 ] ASF GitHub Bot logged work on BEAM-5167: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5663) Add tox suites for various Python 3 versions

[ https://issues.apache.org/jira/browse/BEAM-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709168#comment-16709168 ] Valentyn Tymofieiev commented on BEAM-5663: --- Per [https://devguide.python.org/,]

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-?focusedWorklogId=172023&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172023 ] ASF GitHub Bot logged work on BEAM-: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=172022&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172022 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5462) get rid of .options deprecation warnings in tests

[ https://issues.apache.org/jira/browse/BEAM-5462?focusedWorklogId=172021&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172021 ] ASF GitHub Bot logged work on BEAM-5462: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5462) get rid of .options deprecation warnings in tests

[ https://issues.apache.org/jira/browse/BEAM-5462?focusedWorklogId=172020&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172020 ] ASF GitHub Bot logged work on BEAM-5462: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6154) Gcsio batch delete broken in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709102#comment-16709102 ] Mark Liu commented on BEAM-6154: Reported this issue in apitools: https://github.com/googl

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=172002&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172002 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2400) Null pointer exception when creating a template

[ https://issues.apache.org/jira/browse/BEAM-2400?focusedWorklogId=172003&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172003 ] ASF GitHub Bot logged work on BEAM-2400: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-2400) Null pointer exception when creating a template

[ https://issues.apache.org/jira/browse/BEAM-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709084#comment-16709084 ] Ahmet Altay commented on BEAM-2400: --- DataflowTemplateJob does not support waitUntilFinis

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=172000&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-172000 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171996&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171996 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-6122) Update committer guidelines

[ https://issues.apache.org/jira/browse/BEAM-6122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed BEAM-6122. -- Resolution: Done Fix Version/s: Not applicable > Update committer guidelines > --

[jira] [Work logged] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

[ https://issues.apache.org/jira/browse/BEAM-6067?focusedWorklogId=171993&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171993 ] ASF GitHub Bot logged work on BEAM-6067: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171979&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171979 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709050#comment-16709050 ] Adrish Das commented on BEAM-2943: -- The error is caused by wrong path or filename in "fil

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

[ https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709050#comment-16709050 ] Adrish Das edited comment on BEAM-2943 at 12/4/18 5:58 PM: --- The

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171972&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171972 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6178) Create BOM for Beam

[ https://issues.apache.org/jira/browse/BEAM-6178?focusedWorklogId=171967&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171967 ] ASF GitHub Bot logged work on BEAM-6178: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6178) Create BOM for Beam

Garrett Jones created BEAM-6178: --- Summary: Create BOM for Beam Key: BEAM-6178 URL: https://issues.apache.org/jira/browse/BEAM-6178 Project: Beam Issue Type: Improvement Components: bu

[jira] [Work logged] (BEAM-6122) Update committer guidelines

[ https://issues.apache.org/jira/browse/BEAM-6122?focusedWorklogId=171952&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171952 ] ASF GitHub Bot logged work on BEAM-6122: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708998#comment-16708998 ] Jeroen Steggink commented on BEAM-5419: --- In the meantime Flink 1.7 was released last

[jira] [Work logged] (BEAM-6077) Make UnboundedSource state rescale friendly

[ https://issues.apache.org/jira/browse/BEAM-6077?focusedWorklogId=171953&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171953 ] ASF GitHub Bot logged work on BEAM-6077: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6077) Make UnboundedSource state rescale friendly

[ https://issues.apache.org/jira/browse/BEAM-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6077. -- Resolution: Fixed Fix Version/s: 2.10.0 > Make UnboundedSource state rescale frie

[jira] [Created] (BEAM-6177) AfterProcessingTime not firing

Arnaud T created BEAM-6177: -- Summary: AfterProcessingTime not firing Key: BEAM-6177 URL: https://issues.apache.org/jira/browse/BEAM-6177 Project: Beam Issue Type: Bug Components: sdk-py-co

[jira] [Work logged] (BEAM-6176) Flink Runner's master url does not support IPv6 addresses

[ https://issues.apache.org/jira/browse/BEAM-6176?focusedWorklogId=171941&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171941 ] ASF GitHub Bot logged work on BEAM-6176: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6176) Flink Runner's master url does not support IPv6 addresses

[ https://issues.apache.org/jira/browse/BEAM-6176?focusedWorklogId=171939&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171939 ] ASF GitHub Bot logged work on BEAM-6176: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6077) Make UnboundedSource state rescale friendly

[ https://issues.apache.org/jira/browse/BEAM-6077?focusedWorklogId=171936&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171936 ] ASF GitHub Bot logged work on BEAM-6077: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6176) Flink Runner's master url does not support IPv6 addresses

[ https://issues.apache.org/jira/browse/BEAM-6176?focusedWorklogId=171921&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171921 ] ASF GitHub Bot logged work on BEAM-6176: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6176) Flink Runner's master url does not support IPv6 addresses

Maximilian Michels created BEAM-6176: Summary: Flink Runner's master url does not support IPv6 addresses Key: BEAM-6176 URL: https://issues.apache.org/jira/browse/BEAM-6176 Project: Beam

[jira] [Closed] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-1628. Resolution: Fixed Fix Version/s: 2.10.0 > Flink runner: logic around --flinkMaster is

[jira] [Work logged] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?focusedWorklogId=171911&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171911 ] ASF GitHub Bot logged work on BEAM-1628: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171909&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171909 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6175) Extract reader and publisher from MetricsMonitor in Python Load Test utils

Kasia Kucharczyk created BEAM-6175: -- Summary: Extract reader and publisher from MetricsMonitor in Python Load Test utils Key: BEAM-6175 URL: https://issues.apache.org/jira/browse/BEAM-6175 Project: B

[jira] [Commented] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708749#comment-16708749 ] Jozef Vilcek commented on BEAM-5865: I had a bit of clarification chat with [~mxm] ove

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171908&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171908 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171907&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171907 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6165) Send metrics to Flink in portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6165?focusedWorklogId=171905&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171905 ] ASF GitHub Bot logged work on BEAM-6165: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?focusedWorklogId=171899&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171899 ] ASF GitHub Bot logged work on BEAM-1628: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5978) portableWordCount gradle task not working

[ https://issues.apache.org/jira/browse/BEAM-5978?focusedWorklogId=171900&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171900 ] ASF GitHub Bot logged work on BEAM-5978: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?focusedWorklogId=171898&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171898 ] ASF GitHub Bot logged work on BEAM-1628: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6111) org.apache.beam.runners.flink.PortableTimersExecutionTest is very flakey 40/50 runs failed

[ https://issues.apache.org/jira/browse/BEAM-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6111: - Fix Version/s: 2.9.0 > org.apache.beam.runners.flink.PortableTimersExecutionTest is very f

[jira] [Work logged] (BEAM-5778) Add integrations of Metrics API to Big Query for SyntheticSources load tests in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-5778?focusedWorklogId=171888&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171888 ] ASF GitHub Bot logged work on BEAM-5778: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6079) Add ability for CassandraIO to delete data

[ https://issues.apache.org/jira/browse/BEAM-6079?focusedWorklogId=171887&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171887 ] ASF GitHub Bot logged work on BEAM-6079: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6174) Remove unnecesarry Kryo dependecny from euphoria

[ https://issues.apache.org/jira/browse/BEAM-6174?focusedWorklogId=171881&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171881 ] ASF GitHub Bot logged work on BEAM-6174: Author: ASF GitHub Bot

[jira] [Work started] (BEAM-6174) Remove unnecesarry Kryo dependecny from euphoria

[ https://issues.apache.org/jira/browse/BEAM-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6174 started by Vaclav Plajt. -- > Remove unnecesarry Kryo dependecny from euphoria >

[jira] [Work logged] (BEAM-6174) Remove unnecesarry Kryo dependecny from euphoria

[ https://issues.apache.org/jira/browse/BEAM-6174?focusedWorklogId=171874&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171874 ] ASF GitHub Bot logged work on BEAM-6174: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6174) Remove unnecesarry Kryo dependecny from euphoria

[ https://issues.apache.org/jira/browse/BEAM-6174?focusedWorklogId=171871&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171871 ] ASF GitHub Bot logged work on BEAM-6174: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6174) Remove unnecesarry Kryo dependecny from euphoria

Vaclav Plajt created BEAM-6174: -- Summary: Remove unnecesarry Kryo dependecny from euphoria Key: BEAM-6174 URL: https://issues.apache.org/jira/browse/BEAM-6174 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?focusedWorklogId=171855&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171855 ] ASF GitHub Bot logged work on BEAM-1628: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6169) Dataflow runner: rateLimit exceeded from BigQuery API in start_bundle

[ https://issues.apache.org/jira/browse/BEAM-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Pilewicz updated BEAM-6169: -- Description: When many machines, or too big machines are used, BigQuery returns rateLimit excee

[jira] [Work logged] (BEAM-6167) Create a Class to read content of a file keeping track of the file path (python)

[ https://issues.apache.org/jira/browse/BEAM-6167?focusedWorklogId=171854&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171854 ] ASF GitHub Bot logged work on BEAM-6167: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5884) Allow nested types have null value.

[ https://issues.apache.org/jira/browse/BEAM-5884?focusedWorklogId=171852&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-171852 ] ASF GitHub Bot logged work on BEAM-5884: Author: ASF GitHub Bot