[jira] [Commented] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line.

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

[jira] [Updated] (BEAM-10111) Create methods in fileio to read from / write to archive files

[ https://issues.apache.org/jira/browse/BEAM-10111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10111: - Labels: stale-assigned (was: ) > Create methods in fileio to read from / write to archive files

[jira] [Commented] (BEAM-10111) Create methods in fileio to read from / write to archive files

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

[jira] [Updated] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line.

[ https://issues.apache.org/jira/browse/BEAM-10124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-10124: - Labels: stale-assigned (was: ) > ContextualTextIO - An IO that is provides metadata about the li

[jira] [Commented] (BEAM-9082) "Socket closed" Spurious GRPC errors in Flink/Spark runner log output

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

[jira] [Updated] (BEAM-9082) "Socket closed" Spurious GRPC errors in Flink/Spark runner log output

[ https://issues.apache.org/jira/browse/BEAM-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9082: Labels: portability-flink portability-spark stale-assigned (was: portability-flink portability-spar

[jira] [Commented] (BEAM-7247) DoFnSignatures analysis of @ProcessElement with @Element fails when Java SDK is used from Kotlin

[ https://issues.apache.org/jira/browse/BEAM-7247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147172#comment-17147172 ] Rion Williams commented on BEAM-7247: - [~reuvenlax] As someone that's been working q

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

[ https://issues.apache.org/jira/browse/BEAM-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damon Douglas updated BEAM-9679: Description: A kata devoted to core beam transforms patterns after  [https://github.com/apache/beam/

[jira] [Work logged] (BEAM-6110) Beam SQL join moves element timestamps to EOW sometimes, not always

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

[jira] [Work logged] (BEAM-10336) Move PubsubJsonTableProvider logic to core Beam

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

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

[ https://issues.apache.org/jira/browse/BEAM-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damon Douglas updated BEAM-9679: Description: A kata devoted to core beam transforms patterns after  [https://github.com/apache/beam/

[jira] [Work logged] (BEAM-10290) Correctness unit test for dynamic splitting.

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

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damon Douglas updated BEAM-9679: Description: A kata devoted to core beam transforms patterns after  [https://github.com/apache/beam/

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

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

[jira] [Work logged] (BEAM-10114) Add Pub/Sub Lite IO to beam builtin

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

[jira] [Work logged] (BEAM-9890) Support BIT_AND aggregation function in BeamSQL

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

[jira] [Work logged] (BEAM-9890) Support BIT_AND aggregation function in BeamSQL

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

[jira] [Work logged] (BEAM-6110) Beam SQL join moves element timestamps to EOW sometimes, not always

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

[jira] [Work logged] (BEAM-9890) Support BIT_AND aggregation function in BeamSQL

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

[jira] [Work logged] (BEAM-9890) Support BIT_AND aggregation function in BeamSQL

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

[jira] [Updated] (BEAM-9838) Watermark not advancing on splittable DoFns in Flink

[ https://issues.apache.org/jira/browse/BEAM-9838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9838: Labels: stale-P2 (was: ) > Watermark not advancing on splittable DoFns in Flink > -

[jira] [Work logged] (BEAM-9890) Support BIT_AND aggregation function in BeamSQL

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

[jira] [Commented] (BEAM-9838) Watermark not advancing on splittable DoFns in Flink

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

[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 ] Beam JIRA Bot updated BEAM-9745: Labels: currently-failing (was: currently-failing stale-assigned) > [beam_PostCommit_Java_Portabili

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17147038#comment-17147038 ] Beam JIRA Bot commented on BEAM-9745: - This issue was marked "stale-assigned" and has

[jira] [Assigned] (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 ] Beam JIRA Bot reassigned BEAM-9745: --- Assignee: (was: Kenneth Knowles) > [beam_PostCommit_Java_PortabilityApi] Various GCP IO t

[jira] [Work logged] (BEAM-9502) SchemaCoder assigns random UUID, causes Dataflow's compatibility check to fail

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

[jira] [Work logged] (BEAM-9502) SchemaCoder assigns random UUID, causes Dataflow's compatibility check to fail

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

[jira] [Work logged] (BEAM-10259) Spanner Session leak/overload in Streaming Dataflow

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