[jira] [Commented] (BEAM-11938) IllegalArgumentException: Unknown Coder URN when using x-lang Kafka transforms

[ https://issues.apache.org/jira/browse/BEAM-11938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377699#comment-17377699 ] Chamikara Madhusanka Jayalath commented on BEAM-11938: -- I suspect th

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-12590) Automatically upgrade Dataflow Python pipelines that use cross-language transforms to Runner v2

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

[jira] [Work logged] (BEAM-12590) Automatically upgrade Dataflow Python pipelines that use cross-language transforms to Runner v2

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

[jira] [Work logged] (BEAM-7372) Clean up Python 2 codepaths once Beam no longer supports Python 2.

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

[jira] [Work logged] (BEAM-7372) Clean up Python 2 codepaths once Beam no longer supports Python 2.

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-12503) Process Support for ExternalWorkerService

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

[jira] [Work logged] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

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

[jira] [Work logged] (BEAM-12504) SpannerIO Read SessionNotFoundException for long-running pipline

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

[jira] [Work logged] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data

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

[jira] [Work logged] (BEAM-12504) SpannerIO Read SessionNotFoundException for long-running pipline

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

[jira] [Work logged] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

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

[jira] [Work logged] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

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

[jira] [Work logged] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

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

[jira] [Work logged] (BEAM-11275) Support GCS files for extra_requirements argument in Python Beam portable runners

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

[jira] [Work logged] (BEAM-12503) Process Support for ExternalWorkerService

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Updated] (BEAM-12590) Automatically upgrade Dataflow Python pipelines that use cross-language transforms to Runner v2

[ https://issues.apache.org/jira/browse/BEAM-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12590: --- Status: Open (was: Triage Needed) > Automatically upgrade Dataflow Python pipelines that use

[jira] [Created] (BEAM-12590) Automatically upgrade Dataflow Python pipelines that use cross-language transforms to Runner v2

Chamikara Madhusanka Jayalath created BEAM-12590: Summary: Automatically upgrade Dataflow Python pipelines that use cross-language transforms to Runner v2 Key: BEAM-12590 URL: https://issues.apache

[jira] [Work logged] (BEAM-10887) FnApiTimer should expose clear() API

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

[jira] [Assigned] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

[ https://issues.apache.org/jira/browse/BEAM-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde reassigned BEAM-12388: Assignee: Sam Rohde > Improve caching experience on InteractiveRunner with dataframes > --

[jira] [Work logged] (BEAM-12388) Improve caching experience on InteractiveRunner with dataframes

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

[jira] [Work logged] (BEAM-10887) FnApiTimer should expose clear() API

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

[jira] [Work logged] (BEAM-10887) FnApiTimer should expose clear() API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-10913) Post-commit github actions status

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

[jira] [Work logged] (BEAM-10887) FnApiTimer should expose clear() API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-10913) Post-commit github actions status

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-10913) Post-commit github actions status

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

[jira] [Updated] (BEAM-12588) Support multimapstate over fnapi

[ https://issues.apache.org/jira/browse/BEAM-12588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12588: --- Status: Open (was: Triage Needed) > Support multimapstate over fnapi > -

[jira] [Created] (BEAM-12588) Support multimapstate over fnapi

Kiley Sok created BEAM-12588: Summary: Support multimapstate over fnapi Key: BEAM-12588 URL: https://issues.apache.org/jira/browse/BEAM-12588 Project: Beam Issue Type: Bug Components: s

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-8933) BigQuery IO should support reading Arrow format over Storage API

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

[jira] [Work logged] (BEAM-12548) [Go SDK] PAssert improvements

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

[jira] [Work logged] (BEAM-12513) Complete Go SDK inclusion to Beam Programming Guide

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

[jira] [Work logged] (BEAM-10913) Post-commit github actions status

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-10913) Post-commit github actions status

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-12291) org.apache.beam.runners.flink.ReadSourcePortableTest.testExecution[streaming: false] is flaky

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

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-12435) Generalize S3FileSystem

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

[jira] [Work logged] (BEAM-8376) Add FirestoreIO connector to Java SDK

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

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-12435) Generalize S3FileSystem

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

[jira] [Work logged] (BEAM-12548) [Go SDK] PAssert improvements

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Updated] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources

[ https://issues.apache.org/jira/browse/BEAM-12586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12586: --- Component/s: sdk-py-core > Python Direct Runner doesn't support both streaming & non streamin

[jira] [Commented] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources

[ https://issues.apache.org/jira/browse/BEAM-12586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377539#comment-17377539 ] Kenneth Knowles commented on BEAM-12586: Pinging [~pabloem] and [~robertwb] eithe

[jira] [Updated] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources

[ https://issues.apache.org/jira/browse/BEAM-12586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12586: --- Status: Open (was: Triage Needed) > Python Direct Runner doesn't support both streaming & no

[jira] [Work logged] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-12548) [Go SDK] PAssert improvements

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

[jira] [Work logged] (BEAM-12513) Complete Go SDK inclusion to Beam Programming Guide

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

[jira] [Work logged] (BEAM-12435) Generalize S3FileSystem

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

[jira] [Updated] (BEAM-1857) Add Neo4jIO

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

[jira] [Updated] (BEAM-12013) Replace BoundedSource with OffsetBasedSource in BigQuery connector

[ https://issues.apache.org/jira/browse/BEAM-12013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12013: - Labels: (was: stale-P2) > Replace BoundedSource with OffsetBasedSource in BigQuery connector >

[jira] [Commented] (BEAM-1857) Add Neo4jIO

[ https://issues.apache.org/jira/browse/BEAM-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377518#comment-17377518 ] Beam JIRA Bot commented on BEAM-1857: - This issue is assigned but has not received an

[jira] [Updated] (BEAM-11084) [Go SDK] Validate Windowing

[ https://issues.apache.org/jira/browse/BEAM-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-11084: - Labels: stale-assigned (was: ) > [Go SDK] Validate Windowing > --- > >

[jira] [Updated] (BEAM-12058) Add withMatchConfiguration + watchForNewFiles to ParquetIO

[ https://issues.apache.org/jira/browse/BEAM-12058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12058: - Priority: P3 (was: P2) > Add withMatchConfiguration + watchForNewFiles to ParquetIO > --

[jira] [Updated] (BEAM-12299) ParquetTableProvider doesn't support globs or path to file in LOCATION

[ https://issues.apache.org/jira/browse/BEAM-12299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12299: - Labels: stale-P2 (was: ) > ParquetTableProvider doesn't support globs or path to file in LOCATIO

[jira] [Commented] (BEAM-12164) SpannerIO Change Stream Connector

[ https://issues.apache.org/jira/browse/BEAM-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377517#comment-17377517 ] Beam JIRA Bot commented on BEAM-12164: -- This issue is assigned but has not received

[jira] [Updated] (BEAM-12013) Replace BoundedSource with OffsetBasedSource in BigQuery connector

[ https://issues.apache.org/jira/browse/BEAM-12013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12013: - Priority: P3 (was: P2) > Replace BoundedSource with OffsetBasedSource in BigQuery connector > --

[jira] [Commented] (BEAM-12458) Using SubscriberOptions.setPartitions results in pipeline construction error

[ https://issues.apache.org/jira/browse/BEAM-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377513#comment-17377513 ] Beam JIRA Bot commented on BEAM-12458: -- This issue is assigned but has not received

[jira] [Updated] (BEAM-12458) Using SubscriberOptions.setPartitions results in pipeline construction error

[ https://issues.apache.org/jira/browse/BEAM-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12458: - Labels: stale-assigned (was: ) > Using SubscriberOptions.setPartitions results in pipeline const

[jira] [Updated] (BEAM-11920) Simplify the pipeline by grouping on TableDestination

[ https://issues.apache.org/jira/browse/BEAM-11920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-11920: - Labels: stale-P2 (was: ) > Simplify the pipeline by grouping on TableDestination > -

[jira] [Updated] (BEAM-12164) SpannerIO Change Stream Connector

[ https://issues.apache.org/jira/browse/BEAM-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12164: - Labels: stale-assigned (was: ) > SpannerIO Change Stream Connector > ---

[jira] [Commented] (BEAM-12058) Add withMatchConfiguration + watchForNewFiles to ParquetIO

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

[jira] [Commented] (BEAM-12013) Replace BoundedSource with OffsetBasedSource in BigQuery connector

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

[jira] [Commented] (BEAM-11084) [Go SDK] Validate Windowing

[ https://issues.apache.org/jira/browse/BEAM-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377519#comment-17377519 ] Beam JIRA Bot commented on BEAM-11084: -- This issue is assigned but has not received

[jira] [Commented] (BEAM-11920) Simplify the pipeline by grouping on TableDestination

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

[jira] [Updated] (BEAM-12315) Support PARTITIONED BY on Beam's SQL DDL

[ https://issues.apache.org/jira/browse/BEAM-12315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12315: - Labels: stale-P2 (was: ) > Support PARTITIONED BY on Beam's SQL DDL > --

[jira] [Updated] (BEAM-12058) Add withMatchConfiguration + watchForNewFiles to ParquetIO

[ https://issues.apache.org/jira/browse/BEAM-12058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-12058: - Labels: (was: stale-P2) > Add withMatchConfiguration + watchForNewFiles to ParquetIO >

[jira] [Commented] (BEAM-12315) Support PARTITIONED BY on Beam's SQL DDL

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

[jira] [Commented] (BEAM-12299) ParquetTableProvider doesn't support globs or path to file in LOCATION

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

[jira] [Work logged] (BEAM-12513) Complete Go SDK inclusion to Beam Programming Guide

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

[jira] [Work logged] (BEAM-12008) KafkaIO does not handle null keys

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

  1   2   >