[jira] [Assigned] (BEAM-13981) Job event log empty on Spark History Server

[ https://issues.apache.org/jira/browse/BEAM-13981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-13981: --- Assignee: Ismaël Mejía > Job event log empty on Spark History Server > -

[jira] [Work logged] (BEAM-14040) [Website] Add I/O Connectors page

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

[jira] [Assigned] (BEAM-14073) [CDAP] Batch plugin PoC

[ https://issues.apache.org/jira/browse/BEAM-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Terentyev reassigned BEAM-14073: --- Assignee: Vitaly Terentyev > [CDAP] Batch plugin PoC > --- > >

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Assigned] (BEAM-2766) HadoopInputFormatIO should support Void/null key/values

[ https://issues.apache.org/jira/browse/BEAM-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Terentyev reassigned BEAM-2766: -- Assignee: Vitaly Terentyev > HadoopInputFormatIO should support Void/null key/values >

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14076) Geography type in SnowlfakeIO

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

[jira] [Work logged] (BEAM-14076) Geography type in SnowlfakeIO

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Created] (BEAM-14092) pyparsing dependency issues

Robert Bradshaw created BEAM-14092: -- Summary: pyparsing dependency issues Key: BEAM-14092 URL: https://issues.apache.org/jira/browse/BEAM-14092 Project: Beam Issue Type: Bug Compon

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-13806) [Cross-Language] Jenkins integration test for Go SDK BigQuery IO.

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Work logged] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

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

[jira] [Commented] (BEAM-1025) User guide - "How to create Beam IO Transforms"

[ https://issues.apache.org/jira/browse/BEAM-1025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504665#comment-17504665 ] David Huntsperger commented on BEAM-1025: - This project is pretty stale, and we ha

[jira] [Commented] (BEAM-2634) Add better documentation on testing unbounded I/O scenarios

[ https://issues.apache.org/jira/browse/BEAM-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504663#comment-17504663 ] David Huntsperger commented on BEAM-2634: - This is now low priority. We should con

[jira] [Commented] (BEAM-2635) Add better documentation on testing Python I/O transforms

[ https://issues.apache.org/jira/browse/BEAM-2635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504664#comment-17504664 ] David Huntsperger commented on BEAM-2635: - This is pretty stale and not a high pri

[jira] [Updated] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

[ https://issues.apache.org/jira/browse/BEAM-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-14091: --- Status: Open (was: Triage Needed) > Fixing Interactive Beam show/collect for remote runners

[jira] [Created] (BEAM-14091) Fixing Interactive Beam show/collect for remote runners

Victor Chen created BEAM-14091: -- Summary: Fixing Interactive Beam show/collect for remote runners Key: BEAM-14091 URL: https://issues.apache.org/jira/browse/BEAM-14091 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-14038) Add the ability to easily start up Python expansion services.

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

[jira] [Updated] (BEAM-13953) Document BigQueryIO Storage Write API methods

[ https://issues.apache.org/jira/browse/BEAM-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Huntsperger updated BEAM-13953: - Priority: P1 (was: P2) > Document BigQueryIO Storage Write API methods > ---

[jira] [Commented] (BEAM-13953) Document BigQueryIO Storage Write API methods

[ https://issues.apache.org/jira/browse/BEAM-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504658#comment-17504658 ] David Huntsperger commented on BEAM-13953: -- We'll make this a P1 and add it to t

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

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

[jira] [Work logged] (BEAM-12572) All beam examples should get continuously exercised on at least 2 runners

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

[jira] [Updated] (BEAM-14090) Run code in examples in Beam's Pydoc

[ https://issues.apache.org/jira/browse/BEAM-14090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-14090: - Labels: gsoc gsoc2022 mentor (was: ) > Run code in examples in Beam's Pydoc > --

[jira] [Created] (BEAM-14090) Run code in examples in Beam's Pydoc

Pablo Estrada created BEAM-14090: Summary: Run code in examples in Beam's Pydoc Key: BEAM-14090 URL: https://issues.apache.org/jira/browse/BEAM-14090 Project: Beam Issue Type: Bug C

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Created] (BEAM-14089) CLONE - A generic Beam IO Sink for Java

Pablo Estrada created BEAM-14089: Summary: CLONE - A generic Beam IO Sink for Java Key: BEAM-14089 URL: https://issues.apache.org/jira/browse/BEAM-14089 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-3767) A Complex Event Processing (CEP) library/extension for Apache Beam

[ https://issues.apache.org/jira/browse/BEAM-3767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-3767: Labels: gsoc gsoc2022 mentor (was: ) > A Complex Event Processing (CEP) library/extension for Apach

[jira] [Commented] (BEAM-3767) A Complex Event Processing (CEP) library/extension for Apache Beam

[ https://issues.apache.org/jira/browse/BEAM-3767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504646#comment-17504646 ] Pablo Estrada commented on BEAM-3767: - I'd love to get a proposal from a GSoC student

[jira] [Updated] (BEAM-8258) Implement Nexmark (benchmark suite) in Python and integrate it with Spark and Flink runners

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Commented] (BEAM-14017) beam_PreCommit_CommunityMetrics_Cron is failing.

[ https://issues.apache.org/jira/browse/BEAM-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504639#comment-17504639 ] Ahmet Altay commented on BEAM-14017: NB: Community metrics are still up and running.

[jira] [Work logged] (BEAM-11971) Direct Runner State is null while active timers exist

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Updated] (BEAM-14072) XVR_PythonUsingJava_Dataflow and XVR_PythonUsingJavaSQL_Dataflow failing due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-14072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-14072: - Priority: P2 (was: P1) > XVR_PythonUsingJava_Dataflow and XVR_Py

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Updated] (BEAM-14088) Add ability to type PTransforms with input and output by making it a generic

[ https://issues.apache.org/jira/browse/BEAM-14088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Ye updated BEAM-14088: --- Description: beam.PTransform should be a generic type to enable us to type it with input and output. For exa

[jira] [Updated] (BEAM-14088) Add ability to type PTransforms with input and output by making it a generic

[ https://issues.apache.org/jira/browse/BEAM-14088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Ye updated BEAM-14088: --- Description: beam.PTransform should be a generic type. For example: {code:java} MyTransform(beam.PTransform[P

[jira] [Created] (BEAM-14088) Add ability to type PTransforms with input and output by making it a generic

Andy Ye created BEAM-14088: -- Summary: Add ability to type PTransforms with input and output by making it a generic Key: BEAM-14088 URL: https://issues.apache.org/jira/browse/BEAM-14088 Project: Beam

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

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

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

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

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

[jira] [Commented] (BEAM-13953) Document BigQueryIO Storage Write API methods

[ https://issues.apache.org/jira/browse/BEAM-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504589#comment-17504589 ] Sachin Agarwal commented on BEAM-13953: --- reassigned to David -  [https://cloud.goo

[jira] [Assigned] (BEAM-13953) Document BigQueryIO Storage Write API methods

[ https://issues.apache.org/jira/browse/BEAM-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Agarwal reassigned BEAM-13953: - Assignee: David Huntsperger (was: Kerry Donny-Clark) > Document BigQueryIO Storage Writ

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

Paul Hsu created BEAM-14087: --- Summary: Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING Key: BEAM-14087 URL: https://issues.apache.org/jira/browse/BEAM-14087 Project: Beam Issue Type: Improve

[jira] [Work logged] (BEAM-12097) OVER clause converted from ZetaSQL to Logical SQL plan

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

[jira] [Commented] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

[ https://issues.apache.org/jira/browse/BEAM-12753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504583#comment-17504583 ] Danny McCormick commented on BEAM-12753: I've been digging in to this one and not

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

[jira] [Work logged] (BEAM-14047) Update x-lang release validation to use staged jars

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

[jira] [Work logged] (BEAM-14047) Update x-lang release validation to use staged jars

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

[jira] [Work logged] (BEAM-11971) Direct Runner State is null while active timers exist

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

[jira] [Work logged] (BEAM-13925) Automate Reviewer Assignment

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

[jira] [Work logged] (BEAM-11997) Implement RedisIO on top of Splittable DoFn

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

[jira] [Comment Edited] (BEAM-14074) BigQueryIO: NullPointerException in BigQueryServicesImpl

[ https://issues.apache.org/jira/browse/BEAM-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504572#comment-17504572 ] Chamikara Madhusanka Jayalath edited comment on BEAM-14074 at 3/10/22, 8:39 PM: ---

[jira] [Commented] (BEAM-14074) BigQueryIO: NullPointerException in BigQueryServicesImpl

[ https://issues.apache.org/jira/browse/BEAM-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504572#comment-17504572 ] Chamikara Madhusanka Jayalath commented on BEAM-14074: -- Ok, only dif

[jira] [Assigned] (BEAM-14074) BigQueryIO: NullPointerException in BigQueryServicesImpl

[ https://issues.apache.org/jira/browse/BEAM-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-14074: Assignee: Pablo Estrada > BigQueryIO: NullPointerException

[jira] [Commented] (BEAM-14074) BigQueryIO: NullPointerException in BigQueryServicesImpl

[ https://issues.apache.org/jira/browse/BEAM-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504544#comment-17504544 ] Dennis Waldron commented on BEAM-14074: --- Unfortunately, I don't have a reproducible

[jira] [Work logged] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Work logged] (BEAM-11971) Direct Runner State is null while active timers exist

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

[jira] [Work logged] (BEAM-12753) Flink Runner fails with memory issue when creating first TestStream instance

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

[jira] [Work logged] (BEAM-13806) [Cross-Language] Jenkins integration test for Go SDK BigQuery IO.

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

[jira] [Commented] (BEAM-14064) ElasticSearchIO#Write buffering and outputting across windows

[ https://issues.apache.org/jira/browse/BEAM-14064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504531#comment-17504531 ] Evan Galpin commented on BEAM-14064: There's still open discussion[1] around the best

[jira] [Created] (BEAM-14086) BigQueryIO - Clustered Table - STORAGEWRITEAPI

Bruce Arctor created BEAM-14086: --- Summary: BigQueryIO - Clustered Table - STORAGEWRITEAPI Key: BEAM-14086 URL: https://issues.apache.org/jira/browse/BEAM-14086 Project: Beam Issue Type: Improve

[jira] [Work logged] (BEAM-13806) [Cross-Language] Jenkins integration test for Go SDK BigQuery IO.

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

[jira] [Updated] (BEAM-14085) DoFn ProcessContext needs a MultiSideInput interface

[ https://issues.apache.org/jira/browse/BEAM-14085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud updated BEAM-14085: -- Status: Open (was: Triage Needed) > DoFn ProcessContext needs a MultiSideInput interface > ---

[jira] [Assigned] (BEAM-14085) DoFn ProcessContext needs a MultiSideInput interface

[ https://issues.apache.org/jira/browse/BEAM-14085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-14085: - Assignee: Andrew Pilloud > DoFn ProcessContext needs a MultiSideInput interface > --

[jira] [Updated] (BEAM-10652) Allow Clustering without TimePartitioning in BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-10652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruce Arctor updated BEAM-10652: Fix Version/s: 2.38.0 Resolution: Fixed Status: Resolved (was: In Progress) > Al

[jira] [Created] (BEAM-14085) DoFn ProcessContext needs a MultiSideInput interface

Andrew Pilloud created BEAM-14085: - Summary: DoFn ProcessContext needs a MultiSideInput interface Key: BEAM-14085 URL: https://issues.apache.org/jira/browse/BEAM-14085 Project: Beam Issue Typ

[jira] [Commented] (BEAM-14064) ElasticSearchIO#Write buffering and outputting across windows

[ https://issues.apache.org/jira/browse/BEAM-14064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504527#comment-17504527 ] Evan Galpin commented on BEAM-14064: [~kenn] I've updated the ticket adding the fix v

  1   2   3   >