[jira] [Work logged] (BEAM-8318) Add a num_threads_per_worker pipeline option to Python SDK.

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

[jira] [Created] (BEAM-8318) Add a num_threads_per_worker pipeline option to Python SDK.

Chamikara Madhusanka Jayalath created BEAM-8318: --- Summary: Add a num_threads_per_worker pipeline option to Python SDK. Key: BEAM-8318 URL: https://issues.apache.org/jira/browse/BEAM-8318

[jira] [Work logged] (BEAM-7455) Improve Avro IO integration test coverage on Python 3.

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

[jira] [Work logged] (BEAM-8213) Run and report python tox tasks separately within Jenkins

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

[jira] [Work logged] (BEAM-8213) Run and report python tox tasks separately within Jenkins

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

[jira] [Work logged] (BEAM-876) Support schemaUpdateOption in BigQueryIO

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

[jira] [Comment Edited] (BEAM-8212) StatefulParDoFn creates GC timers for every record

[ https://issues.apache.org/jira/browse/BEAM-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937228#comment-16937228 ] Akshay Iyangar edited comment on BEAM-8212 at 9/26/19 11:19 PM:  

[jira] [Work logged] (BEAM-7933) Adding timeout to JobServer grpc calls

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

[jira] [Work logged] (BEAM-7933) Adding timeout to JobServer grpc calls

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

[jira] [Work started] (BEAM-7933) Adding timeout to JobServer grpc calls

[ https://issues.apache.org/jira/browse/BEAM-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-7933 started by Enrico Canzonieri. --- > Adding timeout to JobServer grpc calls >

[jira] [Commented] (BEAM-8303) Filesystems not properly registered using FileIO.write()

[ https://issues.apache.org/jira/browse/BEAM-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939002#comment-16939002 ] Preston Koprivica commented on BEAM-8303: - [~mxm] Sorry for the delay. I was struggling with my

[jira] [Work logged] (BEAM-8275) Beam SQL should support BigQuery in DIRECT_READ mode

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

[jira] [Work logged] (BEAM-8275) Beam SQL should support BigQuery in DIRECT_READ mode

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

[jira] [Work logged] (BEAM-8275) Beam SQL should support BigQuery in DIRECT_READ mode

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

[jira] [Work logged] (BEAM-8317) SqlTransform doesn't support aggregation over a filter node

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

[jira] [Work logged] (BEAM-8317) SqlTransform doesn't support aggregation over a filter node

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

[jira] [Commented] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

[ https://issues.apache.org/jira/browse/BEAM-8021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938995#comment-16938995 ] Preston Koprivica commented on BEAM-8021: - [~ŁukaszG]I think the PR associated to this issue may

[jira] [Work logged] (BEAM-7886) Make row coder a standard coder and implement in python

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

[jira] [Work logged] (BEAM-7886) Make row coder a standard coder and implement in python

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

[jira] [Work logged] (BEAM-7886) Make row coder a standard coder and implement in python

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

[jira] [Work logged] (BEAM-7886) Make row coder a standard coder and implement in python

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

[jira] [Commented] (BEAM-8317) SqlTransform doesn't support aggregation over a filter node

[ https://issues.apache.org/jira/browse/BEAM-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938980#comment-16938980 ] Brian Hulette commented on BEAM-8317: - Discussed this with [~apilloud]. He said that probably the

[jira] [Work logged] (BEAM-8317) SqlTransform doesn't support aggregation over a filter node

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

[jira] [Created] (BEAM-8317) SqlTransform doesn't support aggregation over a filter node

Brian Hulette created BEAM-8317: --- Summary: SqlTransform doesn't support aggregation over a filter node Key: BEAM-8317 URL: https://issues.apache.org/jira/browse/BEAM-8317 Project: Beam Issue

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Assigned] (BEAM-5543) Beam Dependency Update Request: com.gradle:build-scan-plugin

[ https://issues.apache.org/jira/browse/BEAM-5543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-5543: --- Assignee: (was: Luke Cwik) > Beam Dependency Update Request: com.gradle:build-scan-plugin >

[jira] [Assigned] (BEAM-6646) Beam Dependency Update Request: com.gradle.build-scan

[ https://issues.apache.org/jira/browse/BEAM-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-6646: --- Assignee: (was: Luke Cwik) > Beam Dependency Update Request: com.gradle.build-scan >

[jira] [Resolved] (BEAM-6647) Beam Dependency Update Request: com.gradle.build-scan:com.gradle.build-scan.gradle.plugin

[ https://issues.apache.org/jira/browse/BEAM-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-6647. - Fix Version/s: 2.16.0 Resolution: Fixed This has been updated to 2.4 > Beam Dependency Update

[jira] [Work logged] (BEAM-1296) Providing a small dataset for "Apache Beam Mobile Gaming Pipeline Examples"

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

[jira] [Work logged] (BEAM-1296) Providing a small dataset for "Apache Beam Mobile Gaming Pipeline Examples"

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

[jira] [Work logged] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

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

[jira] [Work started] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

[ https://issues.apache.org/jira/browse/BEAM-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-8313 started by Luke Cwik. --- > Rename yyy_reference to yyy_id to be consistent across protos >

[jira] [Resolved] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

[ https://issues.apache.org/jira/browse/BEAM-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-8315. - Fix Version/s: 2.17.0 Resolution: Fixed > Remove unused fields for splitting SDFs in

[jira] [Resolved] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

[ https://issues.apache.org/jira/browse/BEAM-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-8313. - Fix Version/s: 2.17.0 Resolution: Fixed > Rename yyy_reference to yyy_id to be consistent across

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Commented] (BEAM-5192) Support Elasticsearch 7.x

[ https://issues.apache.org/jira/browse/BEAM-5192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938907#comment-16938907 ] Tim Robertson commented on BEAM-5192: - [~chetaldrich] - help would be greatly appreciated. Please

[jira] [Commented] (BEAM-5192) Support Elasticsearch 7.x

[ https://issues.apache.org/jira/browse/BEAM-5192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938902#comment-16938902 ] Chet Aldrich commented on BEAM-5192: Hey folks, just curious about the current state of things here.

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

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

[jira] [Work logged] (BEAM-7738) Support PubSubIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-7738) Support PubSubIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-7738) Support PubSubIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-1296) Providing a small dataset for "Apache Beam Mobile Gaming Pipeline Examples"

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

[jira] [Work logged] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

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

[jira] [Work logged] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

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

[jira] [Work logged] (BEAM-7495) Add support for dynamic worker re-balancing when reading BigQuery data using Cloud Dataflow

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Created] (BEAM-8316) What is corresponding data type to set in UDF parameter to match RecordType

Yang Zhang created BEAM-8316: Summary: What is corresponding data type to set in UDF parameter to match RecordType Key: BEAM-8316 URL: https://issues.apache.org/jira/browse/BEAM-8316 Project: Beam

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

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

[jira] [Work logged] (BEAM-8313) Rename yyy_reference to yyy_id to be consistent across protos

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Updated] (BEAM-8314) Beam Fn Api metrics piling causes pipeline to stuck after running for a while

[ https://issues.apache.org/jira/browse/BEAM-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-8314: -- Attachment: E4UaSUhJJKF.png > Beam Fn Api metrics piling causes pipeline to stuck after running for a

[jira] [Updated] (BEAM-8314) Beam Fn Api metrics piling causes pipeline to stuck after running for a while

[ https://issues.apache.org/jira/browse/BEAM-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-8314: -- Description: Seems that in StreamingDataflowWorker we are not able to update the metrics fast enough

[jira] [Updated] (BEAM-8314) Beam Fn Api metrics piling causes pipeline to stuck after running for a while

[ https://issues.apache.org/jira/browse/BEAM-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-8314: -- Description: Seems that in StreamingDataflowWorker we are not able to update the metrics fast enough

[jira] [Work logged] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

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

[jira] [Work logged] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

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

[jira] [Created] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

Luke Cwik created BEAM-8315: --- Summary: Remove unused fields for splitting SDFs in beam_fn_api.proto Key: BEAM-8315 URL: https://issues.apache.org/jira/browse/BEAM-8315 Project: Beam Issue Type:

[jira] [Updated] (BEAM-8315) Remove unused fields for splitting SDFs in beam_fn_api.proto

[ https://issues.apache.org/jira/browse/BEAM-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-8315: Status: Open (was: Triage Needed) > Remove unused fields for splitting SDFs in beam_fn_api.proto >

[jira] [Work logged] (BEAM-7760) Interactive Beam Caching PCollections bound to user defined vars in notebook

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-8300) KinesisIO.write causes NPE as the producer is null

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

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

[jira] [Assigned] (BEAM-8212) StatefulParDoFn creates GC timers for every record

[ https://issues.apache.org/jira/browse/BEAM-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-8212: -- Assignee: (was: Aizhamal Nurmamat kyzy) > StatefulParDoFn creates GC timers for every

[jira] [Updated] (BEAM-8212) StatefulParDoFn creates GC timers for every record

[ https://issues.apache.org/jira/browse/BEAM-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8212: --- Component/s: (was: beam-community) runner-core > StatefulParDoFn creates GC

[jira] [Updated] (BEAM-8312) Flink portable pipeline jars do not need to stage artifacts remotely

[ https://issues.apache.org/jira/browse/BEAM-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8312: --- Status: Open (was: Triage Needed) > Flink portable pipeline jars do not need to stage artifacts

[jira] [Updated] (BEAM-8146) SchemaCoder/RowCoder have no equals() function

[ https://issues.apache.org/jira/browse/BEAM-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8146: --- Status: Open (was: Triage Needed) > SchemaCoder/RowCoder have no equals() function >

[jira] [Updated] (BEAM-8275) Beam SQL should support BigQuery in DIRECT_READ mode

[ https://issues.apache.org/jira/browse/BEAM-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8275: --- Status: Open (was: Triage Needed) > Beam SQL should support BigQuery in DIRECT_READ mode >

[jira] [Assigned] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-8306: -- Assignee: Derek He > improve estimation of data byte size reading from source in

[jira] [Updated] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8306: --- Status: Open (was: Triage Needed) > improve estimation of data byte size reading from source in

[jira] [Updated] (BEAM-8303) Filesystems not properly registered using FileIO.write()

[ https://issues.apache.org/jira/browse/BEAM-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8303: --- Status: Open (was: Triage Needed) > Filesystems not properly registered using FileIO.write() >