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

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

[jira] [Work logged] (BEAM-7774) Stop usign Perfkit Benchmarker tool in Python performance tests

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

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

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

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

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

[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=17118690#comment-17118690 ] Daniel Gomes commented on BEAM-9082: Seeing message 1. using Google Dataflow and every

[jira] [Work logged] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service

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

[jira] [Work logged] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality

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

[jira] [Updated] (BEAM-10133) AWS - add possibility for multiple region client

[ https://issues.apache.org/jira/browse/BEAM-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Perchlicki updated BEAM-10133: Summary: AWS - add possibility for multiple region client (was: Add possibility fo

[jira] [Created] (BEAM-10133) Add possibility for multiple region client

Krzysztof Perchlicki created BEAM-10133: --- Summary: Add possibility for multiple region client Key: BEAM-10133 URL: https://issues.apache.org/jira/browse/BEAM-10133 Project: Beam Issue T

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

[ https://issues.apache.org/jira/browse/BEAM-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118619#comment-17118619 ] Daniel Collins commented on BEAM-10114: --- This will use the Pub/Sub Lite wire protoc

[jira] [Created] (BEAM-10132) Remove reference to apachebeam/*

Kyle Weaver created BEAM-10132: -- Summary: Remove reference to apachebeam/* Key: BEAM-10132 URL: https://issues.apache.org/jira/browse/BEAM-10132 Project: Beam Issue Type: Bug Component

[jira] [Updated] (BEAM-10132) Remove reference to apachebeam/*

[ https://issues.apache.org/jira/browse/BEAM-10132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10132: --- Status: Open (was: Triage Needed) > Remove reference to apachebeam/* > -

[jira] [Resolved] (BEAM-10098) Javadoc export deactivated for RabbitMqIO and KuduIO

[ https://issues.apache.org/jira/browse/BEAM-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-10098. - Fix Version/s: Not applicable Resolution: Fixed > Javadoc export deactivated for R

[jira] [Updated] (BEAM-10098) Javadoc export deactivated for RabbitMqIO and KuduIO

[ https://issues.apache.org/jira/browse/BEAM-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-10098: Fix Version/s: (was: Not applicable) 2.23.0 > Javadoc export deactiv

[jira] [Updated] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

[ https://issues.apache.org/jira/browse/BEAM-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10127: --- Status: Open (was: Triage Needed) > Patterns: Create a pattern showing how to do HLL

[jira] [Updated] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key

[ https://issues.apache.org/jira/browse/BEAM-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10131: --- Status: Open (was: Triage Needed) > Patterns: Show pattern for key redistribution wh

[jira] [Updated] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

[ https://issues.apache.org/jira/browse/BEAM-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10128: --- Status: Open (was: Triage Needed) > Pattern: Write FixedWindow and output TF.Sequenc

[jira] [Updated] (BEAM-10129) Pattern: Buffered Service Call Pattern

[ https://issues.apache.org/jira/browse/BEAM-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10129: --- Status: Open (was: Triage Needed) > Pattern: Buffered Service Call Pattern > ---

[jira] [Updated] (BEAM-10130) Pattern : Limiting the calls to an external service within a DoFn

[ https://issues.apache.org/jira/browse/BEAM-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10130: --- Status: Open (was: Triage Needed) > Pattern : Limiting the calls to an external serv

[jira] [Updated] (BEAM-10126) Pattern : Filters using Beam Schemas

[ https://issues.apache.org/jira/browse/BEAM-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10126: --- Status: Open (was: Triage Needed) > Pattern : Filters using Beam Schemas > -

[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 ] Reza ardeshir rokni updated BEAM-10124: --- Status: Open (was: Triage Needed) > ContextualTextIO - An IO that is provides metada

[jira] [Created] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key

Reza ardeshir rokni created BEAM-10131: -- Summary: Patterns: Show pattern for key redistribution when there is no natural key Key: BEAM-10131 URL: https://issues.apache.org/jira/browse/BEAM-10131

[jira] [Updated] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

[ https://issues.apache.org/jira/browse/BEAM-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10127: --- Labels: pipeline-patterns (was: ) > Patterns: Create a pattern showing how to do HLL

[jira] [Updated] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

[ https://issues.apache.org/jira/browse/BEAM-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10128: --- Labels: pipeline-patterns (was: ) > Pattern: Write FixedWindow and output TF.Sequenc

[jira] [Created] (BEAM-10130) Pattern : Limiting the calls to an external service within a DoFn

Reza ardeshir rokni created BEAM-10130: -- Summary: Pattern : Limiting the calls to an external service within a DoFn Key: BEAM-10130 URL: https://issues.apache.org/jira/browse/BEAM-10130 Project:

[jira] [Created] (BEAM-10129) Pattern: Buffered Service Call Pattern

Reza ardeshir rokni created BEAM-10129: -- Summary: Pattern: Buffered Service Call Pattern Key: BEAM-10129 URL: https://issues.apache.org/jira/browse/BEAM-10129 Project: Beam Issue Type: N

[jira] [Created] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

Reza ardeshir rokni created BEAM-10128: -- Summary: Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO Key: BEAM-10128 URL: https://issues.apache.org/jira/browse/BEAM-10128 Pr

[jira] [Created] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

Reza ardeshir rokni created BEAM-10127: -- Summary: Patterns: Create a pattern showing how to do HLL++ in streams Key: BEAM-10127 URL: https://issues.apache.org/jira/browse/BEAM-10127 Project: Beam

[jira] [Updated] (BEAM-10126) Pattern : Filters using Beam Schemas

[ https://issues.apache.org/jira/browse/BEAM-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10126: --- Description: Pattern : Filters using Beam Schemas   Add a pattern to show filtering

[jira] [Created] (BEAM-10126) Pattern : Filters using Beam Schemas

Reza ardeshir rokni created BEAM-10126: -- Summary: Pattern : Filters using Beam Schemas Key: BEAM-10126 URL: https://issues.apache.org/jira/browse/BEAM-10126 Project: Beam Issue Type: New

[jira] [Updated] (BEAM-10100) FileIO writeDynamic with AvroIO.sink not writing all data

[ https://issues.apache.org/jira/browse/BEAM-10100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dave Martin updated BEAM-10100: --- Affects Version/s: 2.16.0 > FileIO writeDynamic with AvroIO.sink not writing all data > -

[jira] [Updated] (BEAM-9634) [Java] PTransform that integrates Cloud Natural Language functionality

[ https://issues.apache.org/jira/browse/BEAM-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Walenia updated BEAM-9634: - Fix Version/s: (was: 2.23.0) 2.22.0 > [Java] PTransform that integrates Clo

[jira] [Updated] (BEAM-9634) [Java] PTransform that integrates Cloud Natural Language functionality

[ https://issues.apache.org/jira/browse/BEAM-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Walenia updated BEAM-9634: - Fix Version/s: (was: Not applicable) 2.23.0 > [Java] PTransform that integr

[jira] [Resolved] (BEAM-9634) [Java] PTransform that integrates Cloud Natural Language functionality

[ https://issues.apache.org/jira/browse/BEAM-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Walenia resolved BEAM-9634. -- Fix Version/s: Not applicable Resolution: Fixed > [Java] PTransform that integrates Cloud

[jira] [Work logged] (BEAM-10097) Migrate PCollection views to use both iterable and multimap materializations/access patterns

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

[jira] [Updated] (BEAM-9501) [Java] PTransform that integrates Cloud AI Prediction functionality

[ https://issues.apache.org/jira/browse/BEAM-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-9501: --- Status: Open (was: Triage Needed) > [Java] PTransform that integrates Cloud AI Prediction fun

[jira] [Resolved] (BEAM-9810) Add a Tox (precommit) suite for Python 3.8

[ https://issues.apache.org/jira/browse/BEAM-9810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski resolved BEAM-9810. Fix Version/s: 2.23.0 Resolution: Fixed > Add a Tox (precommit) suite for Python 3.8

[jira] [Resolved] (BEAM-9936) Create SDK harness containers with Python 3.8

[ https://issues.apache.org/jira/browse/BEAM-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski resolved BEAM-9936. Fix Version/s: Not applicable Resolution: Fixed > Create SDK harness containers with

[jira] [Work logged] (BEAM-9869) adding self-contained Kafka service jar for testing

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

[jira] [Work logged] (BEAM-9869) adding self-contained Kafka service jar for testing

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

[jira] [Work logged] (BEAM-10125) adding cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10125) adding cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10125) adding cross-language KafkaIO integration test

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

[jira] [Created] (BEAM-10125) adding cross-language KafkaIO integration test

Heejong Lee created BEAM-10125: -- Summary: adding cross-language KafkaIO integration test Key: BEAM-10125 URL: https://issues.apache.org/jira/browse/BEAM-10125 Project: Beam Issue Type: Improveme

[jira] [Assigned] (BEAM-10125) adding cross-language KafkaIO integration test

[ https://issues.apache.org/jira/browse/BEAM-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee reassigned BEAM-10125: -- Assignee: Heejong Lee > adding cross-language KafkaIO integration test > -

[jira] [Updated] (BEAM-10125) adding cross-language KafkaIO integration test

[ https://issues.apache.org/jira/browse/BEAM-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-10125: --- Status: Open (was: Triage Needed) > adding cross-language KafkaIO integration test > ---

[jira] [Work logged] (BEAM-9869) adding self-contained Kafka service jar for testing

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

[jira] [Work logged] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service

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

[jira] [Work logged] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service

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

<    1   2   3