[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-14053) [CdapIO] Design and implement generic plugin class

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

[jira] [Work logged] (BEAM-14334) Avoid using forkEvery in Spark runner tests

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

[jira] [Work logged] (BEAM-14334) Avoid using forkEvery in Spark runner tests

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

[jira] [Work logged] (BEAM-14334) Avoid using forkEvery in Spark runner tests

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

[jira] [Work logged] (BEAM-12000) Support Python 3.9 in Apache Beam

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

[jira] [Work logged] (BEAM-12000) Support Python 3.9 in Apache Beam

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

[jira] [Work logged] (BEAM-11167) Beam Dependency Update Request: dill

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

[jira] [Work logged] (BEAM-11167) Beam Dependency Update Request: dill

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

[jira] [Work logged] (BEAM-14053) [CdapIO] Design and implement generic plugin class

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

[jira] [Work logged] (BEAM-12641) Support GCP auth using custom token URIs

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

[jira] [Work logged] (BEAM-12641) Support GCP auth using custom token URIs

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

[jira] [Commented] (BEAM-14467) Failed test annotated with no_xdist passes github action python test

[ https://issues.apache.org/jira/browse/BEAM-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537524#comment-17537524 ] Valentyn Tymofieiev commented on BEAM-14467: Relevant files: https://github.

[jira] [Assigned] (BEAM-14467) Failed test annotated with no_xdist passes github action python test

[ https://issues.apache.org/jira/browse/BEAM-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-14467: -- Assignee: Brian Hulette > Failed test annotated with no_xdist passes github ac

[jira] [Updated] (BEAM-14467) Failed test annotated with no_xdist passes github action python test

[ https://issues.apache.org/jira/browse/BEAM-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-14467: --- Status: Open (was: Triage Needed) > Failed test annotated with no_xdist passes githu

[jira] [Work logged] (BEAM-12918) TPC-DS: add Jenkins jobs

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

[jira] [Work logged] (BEAM-12918) TPC-DS: add Jenkins jobs

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

[jira] [Work logged] (BEAM-14255) Drop the clock abastraction and just use time.time for time measurements

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

[jira] [Work logged] (BEAM-12918) TPC-DS: add Jenkins jobs

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

[jira] [Work logged] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

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

[jira] [Work logged] (BEAM-13015) Optimize Java SDK harness

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

[jira] [Work logged] (BEAM-13982) Implement Generic RunInference Base class

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

[jira] [Updated] (BEAM-10529) Kafka XLang fails for ?empty? key/values

[ https://issues.apache.org/jira/browse/BEAM-10529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Casey updated BEAM-10529: -- Fix Version/s: 2.39.0 (was: 2.38.0) > Kafka XLang fails for ?empty? key/values >

[jira] [Work logged] (BEAM-13945) Update BQ connector to support new JSON type

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

[jira] [Work logged] (BEAM-12918) TPC-DS: add Jenkins jobs

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

[jira] [Work logged] (BEAM-14073) [CdapIO] Batch plugin PoC

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

[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-13945) Update BQ connector to support new JSON type

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

[jira] [Created] (BEAM-14473) Throw error for unbounded, global window side inputs

Jack McCluskey created BEAM-14473: - Summary: Throw error for unbounded, global window side inputs Key: BEAM-14473 URL: https://issues.apache.org/jira/browse/BEAM-14473 Project: Beam Issue Typ

[jira] [Updated] (BEAM-14473) Throw error for unbounded, global window side inputs

[ https://issues.apache.org/jira/browse/BEAM-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14473: - Status: Open (was: Triage Needed) > Throw error for unbounded, global window side inputs > -

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Updated] (BEAM-13612) When BigqueryIO's STORAGE_API_AT_LEAST_ONCE method is used and the table spec doesn't contain the project id the pipeline fails

[ https://issues.apache.org/jira/browse/BEAM-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Lilichenko updated BEAM-13612: - Labels: starter (was: stale-P2 starter) > When BigqueryIO's STORAGE_API_AT_LEAST_ONCE me

[jira] [Work logged] (BEAM-14451) Add Export to BQ to FhirIO.Export

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

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Work logged] (BEAM-14451) Add Export to BQ to FhirIO.Export

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

[jira] [Work logged] (BEAM-14451) Add Export to BQ to FhirIO.Export

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

[jira] [Updated] (BEAM-13158) "Dead letter" handling for problem rows in BigQueryIO Storage Write API

[ https://issues.apache.org/jira/browse/BEAM-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Lilichenko updated BEAM-13158: - Labels: (was: stale-P2) > "Dead letter" handling for problem rows in BigQueryIO Storage

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14471) Adding testcases and examples for xlang Python DataframeTransform

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

[jira] [Work logged] (BEAM-14473) Throw error for unbounded, global window side inputs

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

[jira] [Work logged] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

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

[jira] [Updated] (BEAM-14473) Throw error for unbounded, global window side inputs

[ https://issues.apache.org/jira/browse/BEAM-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jack McCluskey updated BEAM-14473: -- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: Open) > Throw

[jira] [Work logged] (BEAM-14255) Drop the clock abastraction and just use time.time for time measurements

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

[jira] [Work logged] (BEAM-14255) Drop the clock abastraction and just use time.time for time measurements

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

[jira] [Updated] (BEAM-14087) Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING

[ https://issues.apache.org/jira/browse/BEAM-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14087: - Labels: stale-P2 (was: ) > Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING >

[jira] [Commented] (BEAM-14087) Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING

[ https://issues.apache.org/jira/browse/BEAM-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537679#comment-17537679 ] Beam JIRA Bot commented on BEAM-14087: -- This issue is P2 but has been unassigned wit

[jira] [Updated] (BEAM-14105) Update multi-language Java quickstart

[ https://issues.apache.org/jira/browse/BEAM-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14105: - Labels: (was: stale-assigned) > Update multi-language Java quickstart > ---

[jira] [Commented] (BEAM-14105) Update multi-language Java quickstart

[ https://issues.apache.org/jira/browse/BEAM-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537681#comment-17537681 ] Beam JIRA Bot commented on BEAM-14105: -- This issue was marked "stale-assigned" and h

[jira] [Assigned] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug

[ https://issues.apache.org/jira/browse/BEAM-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-14276: Assignee: (was: Emily Ye) > beam_PostCommit_Java_DataflowV2 failures parent bug >

[jira] [Work stopped] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug

[ https://issues.apache.org/jira/browse/BEAM-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-14276 stopped by Beam JIRA Bot. > beam_PostCommit_Java_DataflowV2 failures parent bug >

[jira] [Updated] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug

[ https://issues.apache.org/jira/browse/BEAM-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14276: - Labels: currently-failing (was: currently-failing stale-assigned) > beam_PostCommit_Java_Dataflo

[jira] [Commented] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug

[ https://issues.apache.org/jira/browse/BEAM-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537682#comment-17537682 ] Beam JIRA Bot commented on BEAM-14276: -- This issue was marked "stale-assigned" and h

[jira] [Assigned] (BEAM-14105) Update multi-language Java quickstart

[ https://issues.apache.org/jira/browse/BEAM-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot reassigned BEAM-14105: Assignee: (was: David Huntsperger) > Update multi-language Java quickstart > -

[jira] [Work logged] (BEAM-14440) Add coder fuzz tests to the Go SDK

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

[jira] [Work logged] (BEAM-14440) Add coder fuzz tests to the Go SDK

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

[jira] [Updated] (BEAM-14440) Add coder fuzz tests to the Go SDK

[ https://issues.apache.org/jira/browse/BEAM-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jack McCluskey updated BEAM-14440: -- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: Open) > Add c

[jira] [Work logged] (BEAM-14035) Convert BigQuery SchemaIO to SchemaTransform

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

[jira] [Updated] (BEAM-14035) Convert BigQuery SchemaIO to SchemaTransform

[ https://issues.apache.org/jira/browse/BEAM-14035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damon Douglas updated BEAM-14035: - Fix Version/s: Not applicable Resolution: Fixed Status: Resolved (was: Open) >

[jira] [Assigned] (BEAM-14036) Convert Pubsub Schema IO to SchemaTransform

[ https://issues.apache.org/jira/browse/BEAM-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damon Douglas reassigned BEAM-14036: Assignee: Damon Douglas > Convert Pubsub Schema IO to SchemaTransform > --

[jira] [Updated] (BEAM-14449) Support cluster provisioning when using Flink on Dataproc

[ https://issues.apache.org/jira/browse/BEAM-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning updated BEAM-14449: Attachment: image-2022-05-16-11-25-32-904.png > Support cluster provisioning when using Flink on Dataproc > ---

[jira] [Updated] (BEAM-14449) Support cluster provisioning when using Flink on Dataproc

[ https://issues.apache.org/jira/browse/BEAM-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning updated BEAM-14449: Description: Provide the capability for the user to explicitly provision a cluster. Current implementation provisi

[jira] [Updated] (BEAM-14449) Support cluster provisioning when using Flink on Dataproc

[ https://issues.apache.org/jira/browse/BEAM-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning updated BEAM-14449: Description: Provide the capability for the user to explicitly provision a cluster. Current implementation provisi

[jira] [Updated] (BEAM-14449) Support cluster provisioning when using Flink on Dataproc

[ https://issues.apache.org/jira/browse/BEAM-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning updated BEAM-14449: Attachment: image-2022-05-16-11-28-12-702.png > Support cluster provisioning when using Flink on Dataproc > ---

[jira] [Work logged] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

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

[jira] [Work logged] (BEAM-14269) PulsarIOTest.testReadFromSimpleTopic is very flaky

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

[jira] [Work logged] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

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

[jira] [Work logged] (BEAM-13945) Update BQ connector to support new JSON type

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

[jira] [Created] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

Yi Hu created BEAM-14474: Summary: Clean up/Fix runtime warning messages in python unit test standard error Key: BEAM-14474 URL: https://issues.apache.org/jira/browse/BEAM-14474 Project: Beam Issue

[jira] [Work logged] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

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

[jira] [Work logged] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

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

[jira] [Updated] (BEAM-14413) Add Kafka IO exception test cases

[ https://issues.apache.org/jira/browse/BEAM-14413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Casey updated BEAM-14413: -- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: In Progress) > Add Ka

[jira] [Updated] (BEAM-14448) Add exception handling tests to Datastore

[ https://issues.apache.org/jira/browse/BEAM-14448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Casey updated BEAM-14448: -- Fix Version/s: 2.40.0 Resolution: Fixed Status: Resolved (was: In Progress) > Add ex

[jira] [Updated] (BEAM-14475) Add exception test cases to GcsFileSystem

[ https://issues.apache.org/jira/browse/BEAM-14475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-14475: - Status: Open (was: Triage Needed) > Add exception test cases to GcsFileSystem >

[jira] [Created] (BEAM-14475) Add exception test cases to GcsFileSystem

John Casey created BEAM-14475: - Summary: Add exception test cases to GcsFileSystem Key: BEAM-14475 URL: https://issues.apache.org/jira/browse/BEAM-14475 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-11587) Support pd.read_gbq and DataFrame.to_gbq

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

[jira] [Work logged] (BEAM-14475) Add exception test cases to GcsFileSystem

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

[jira] [Work logged] (BEAM-14475) Add exception test cases to GcsFileSystem

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

[jira] [Work logged] (BEAM-14475) Add exception test cases to GcsFileSystem

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

[jira] [Work logged] (BEAM-14475) Add exception test cases to GcsFileSystem

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Created] (BEAM-14476) Verbose logging causes pipelines to get stuck on Flink.

Robert Bradshaw created BEAM-14476: -- Summary: Verbose logging causes pipelines to get stuck on Flink. Key: BEAM-14476 URL: https://issues.apache.org/jira/browse/BEAM-14476 Project: Beam Issu

[jira] [Updated] (BEAM-14476) Verbose logging causes pipelines to get stuck on Flink.

[ https://issues.apache.org/jira/browse/BEAM-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw updated BEAM-14476: --- Description: Minimal reproduction:    {{def _run_pipeline(pipeline):}} {{    def process_data

[jira] [Updated] (BEAM-14476) Verbose logging causes pipelines to get stuck on Flink.

[ https://issues.apache.org/jira/browse/BEAM-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw updated BEAM-14476: --- Description: Minimal reproduction:    {{def _run_pipeline(pipeline):}} {{    def process_data

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Updated] (BEAM-14476) Verbose print causes pipelines to get stuck on FlinkRunner.

[ https://issues.apache.org/jira/browse/BEAM-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Nagaraj updated BEAM-14476: -- Summary: Verbose print causes pipelines to get stuck on FlinkRunner. (was: Verbose logging cau

[jira] [Created] (BEAM-14477) Clean up/Fix runtime warning messages when generating a proxy at pipeline construction time

Yi Hu created BEAM-14477: Summary: Clean up/Fix runtime warning messages when generating a proxy at pipeline construction time Key: BEAM-14477 URL: https://issues.apache.org/jira/browse/BEAM-14477 Project: B

[jira] [Work logged] (BEAM-14474) Clean up/Fix runtime warning messages in python unit test standard error

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

[jira] [Work logged] (BEAM-11587) Support pd.read_gbq and DataFrame.to_gbq

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

[jira] [Work logged] (BEAM-11587) Support pd.read_gbq and DataFrame.to_gbq

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

  1   2   >