[jira] [Work logged] (BEAM-9699) Add ability to use ZetaSQL in Python SqlTransform

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

[jira] [Updated] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

[ https://issues.apache.org/jira/browse/BEAM-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hannah Jiang updated BEAM-9685: --- Description: We decided to remove Go SDK images from release process from 2.21.0, because Go SDK is n

[jira] [Work logged] (BEAM-9322) Python SDK ignores manually set PCollection tags

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

[jira] [Updated] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

[ https://issues.apache.org/jira/browse/BEAM-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hannah Jiang updated BEAM-9685: --- Description: We decided to remove Go SDK images from release process from 2.21.0, because Go SDK is n

[jira] [Updated] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

[ https://issues.apache.org/jira/browse/BEAM-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hannah Jiang updated BEAM-9685: --- Description: We decided to remove Go SDK images from release process from 2.21.0, because Go SDK is n

[jira] [Work logged] (BEAM-10038) Add script to mass-comment Jenkins triggers on PR

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

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

[ https://issues.apache.org/jira/browse/BEAM-8889?focusedWorklogId=435716&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435716 ] 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=435715&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435715 ] ASF GitHub Bot logged work on BEAM-8889: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

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

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

[jira] [Resolved] (BEAM-9261) Add LICENSE and NOTICE to Docker images

[ https://issues.apache.org/jira/browse/BEAM-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-9261. --- Fix Version/s: 2.21.0 Resolution: Fixed > Add LICENSE and NOTICE to Docker images > ---

[jira] [Work logged] (BEAM-9978) Add offset range restrictions to the Go SDK.

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

[jira] [Commented] (BEAM-7304) Twister2 Beam runner

[ https://issues.apache.org/jira/browse/BEAM-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112621#comment-17112621 ] Pulasthi Wickramasinghe commented on BEAM-7304: --- Thanks, Brian, I found a so

[jira] [Work logged] (BEAM-8019) Support cross-language transforms for DataflowRunner

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

[jira] [Work logged] (BEAM-8019) Support cross-language transforms for DataflowRunner

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

[jira] [Work logged] (BEAM-8019) Support cross-language transforms for DataflowRunner

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

[jira] [Issue Comment Deleted] (BEAM-9994) Cannot create a virtualenv using Python 3.8 on Jenkins machines

[ https://issues.apache.org/jira/browse/BEAM-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Zou updated BEAM-9994: Comment: was deleted (was: Yes, We will have to reimage the Jenkins to ensure the consistent environment ac

[jira] [Commented] (BEAM-9994) Cannot create a virtualenv using Python 3.8 on Jenkins machines

[ https://issues.apache.org/jira/browse/BEAM-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112613#comment-17112613 ] Yifan Zou commented on BEAM-9994: - Yes, We will have to reimage the Jenkins to ensure the

[jira] [Work logged] (BEAM-10027) Support for Kotlin-based Beam Katas

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

[jira] [Work logged] (BEAM-9421) AI Platform pipeline patterns

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

[jira] [Work logged] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

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

[jira] [Work logged] (BEAM-10048) Remove "manual steps" from release guide.

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

[jira] [Created] (BEAM-10048) Remove "manual steps" from release guide.

Kyle Weaver created BEAM-10048: -- Summary: Remove "manual steps" from release guide. Key: BEAM-10048 URL: https://issues.apache.org/jira/browse/BEAM-10048 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-10048) Remove "manual steps" from release guide.

[ https://issues.apache.org/jira/browse/BEAM-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10048: --- Status: Open (was: Triage Needed) > Remove "manual steps" from release guide. >

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Commented] (BEAM-9698) BeamUncollectRel UncollectDoFn NullPointerException

[ https://issues.apache.org/jira/browse/BEAM-9698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112582#comment-17112582 ] Andrew Pilloud commented on BEAM-9698: -- This looks to be an issue with UNNEST in calc

[jira] [Work logged] (BEAM-9899) Add integration tests for cross-language SnowflakeIO Read and Write

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

[jira] [Work logged] (BEAM-9692) Clean Python DataflowRunner to use portable pipelines

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

[jira] [Work logged] (BEAM-9899) Add integration tests for cross-language SnowflakeIO Read and Write

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9899) Add integration tests for cross-language SnowflakeIO Read and Write

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

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

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9899) Add integration tests for cross-language SnowflakeIO Read and Write

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

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

[ https://issues.apache.org/jira/browse/BEAM-8889?focusedWorklogId=435662&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435662 ] 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=435663&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435663 ] 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=435660&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435660 ] 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=435661&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-435661 ] ASF GitHub Bot logged work on BEAM-8889: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9679) Core Transforms | Go SDK Code Katas

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

[jira] [Work logged] (BEAM-9679) Core Transforms | Go SDK Code Katas

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9699) Add ability to use ZetaSQL in Python SqlTransform

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

[jira] [Commented] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

[ https://issues.apache.org/jira/browse/BEAM-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112565#comment-17112565 ] Brian Hulette commented on BEAM-9822: - Filed BEAM-10047 for PR #11570 > SpannerIO: Re

[jira] [Updated] (BEAM-10047) SpannerIO: Combine sorting and batching

[ https://issues.apache.org/jira/browse/BEAM-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Hulette updated BEAM-10047: - Status: Open (was: Triage Needed) > SpannerIO: Combine sorting and batching > --

[jira] [Created] (BEAM-10047) SpannerIO: Combine sorting and batching

Brian Hulette created BEAM-10047: Summary: SpannerIO: Combine sorting and batching Key: BEAM-10047 URL: https://issues.apache.org/jira/browse/BEAM-10047 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-9707) Hardcode runner harness container image for unified worker

[ https://issues.apache.org/jira/browse/BEAM-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112559#comment-17112559 ] Ankur Goenka commented on BEAM-9707: We can delay it to 2.23 > Hardcode runner harnes

[jira] [Updated] (BEAM-9707) Hardcode runner harness container image for unified worker

[ https://issues.apache.org/jira/browse/BEAM-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-9707: --- Fix Version/s: (was: 2.22.0) 2.23.0 > Hardcode runner harness container image f

[jira] [Updated] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Hulette updated BEAM-9745: Fix Version/s: (was: 2.22.0) > [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failin

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Commented] (BEAM-7304) Twister2 Beam runner

[ https://issues.apache.org/jira/browse/BEAM-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112554#comment-17112554 ] Brian Hulette commented on BEAM-7304: - I think you can do something like this with fin

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-10007) PortableRunner doesn't handle ValueProvider instances when converting pipeline options

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9978) Add offset range restrictions to the Go SDK.

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-9978) Add offset range restrictions to the Go SDK.

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-10028) [Java SDK] Support state backed iterables within the SDK harness

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

[jira] [Work logged] (BEAM-10028) [Java SDK] Support state backed iterables within the SDK harness

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Work logged] (BEAM-10007) PortableRunner doesn't handle ValueProvider instances when converting pipeline options

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

[jira] [Work logged] (BEAM-9699) Add ability to use ZetaSQL in Python SqlTransform

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

[jira] [Work logged] (BEAM-9699) Add ability to use ZetaSQL in Python SqlTransform

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

[jira] [Work logged] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK

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

[jira] [Commented] (BEAM-7304) Twister2 Beam runner

[ https://issues.apache.org/jira/browse/BEAM-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112540#comment-17112540 ] Pulasthi Wickramasinghe commented on BEAM-7304: --- [~iemejia] I am looking int

[jira] [Work logged] (BEAM-10037) BeamSqlExample.java fails to build when running ./gradlew command

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

[jira] [Work logged] (BEAM-9603) Support Dynamic Timer in Java SDK over FnApi

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

[jira] [Work logged] (BEAM-9603) Support Dynamic Timer in Java SDK over FnApi

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

[jira] [Work logged] (BEAM-9603) Support Dynamic Timer in Java SDK over FnApi

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

[jira] [Work logged] (BEAM-9748) Refactor Reparallelize as an alternative Reshuffle implementation

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

[jira] [Work logged] (BEAM-9856) HL7v2IO.ListHL7v2Messages should be refactored to support more parallelization

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

[jira] [Work logged] (BEAM-10028) [Java SDK] Support state backed iterables within the SDK harness

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

[jira] [Work logged] (BEAM-10007) PortableRunner doesn't handle ValueProvider instances when converting pipeline options

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

[jira] [Work logged] (BEAM-7390) Colab examples for aggregation transforms (Python)

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

[jira] [Work logged] (BEAM-7390) Colab examples for aggregation transforms (Python)

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

[jira] [Work logged] (BEAM-10007) PortableRunner doesn't handle ValueProvider instances when converting pipeline options

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

[jira] [Work logged] (BEAM-9822) SpannerIO: Reduce memory usage - especially when streaming

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

<    1   2   3   4   >