[jira] [Commented] (BEAM-9045) Implement an Ignite runner using Apache Ignite compute grid

[ https://issues.apache.org/jira/browse/BEAM-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127470#comment-17127470 ] Saikat Maitra commented on BEAM-9045: - [~kenn]   I was hoping to connect and talk if the tasks for

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-10101) Add a HttpIO / HttpFileSystem

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

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

[ https://issues.apache.org/jira/browse/BEAM-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Morgan reassigned BEAM-9502: Assignee: (was: Cameron Morgan) > SchemaCoder assigns random UUID, causes Dataflow's

[jira] [Updated] (BEAM-10210) Blog Post for Kotlin-based Beam Katas

[ https://issues.apache.org/jira/browse/BEAM-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rion Williams updated BEAM-10210: - Component/s: website Labels: blog kotlin (was: ) Remaining Estimate:

[jira] [Work logged] (BEAM-10210) Blog Post for Kotlin-based Beam Katas

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

[jira] [Updated] (BEAM-10210) Blog Post for Kotlin-based Beam Katas

[ https://issues.apache.org/jira/browse/BEAM-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rion Williams updated BEAM-10210: - Description: Recently BEAM-10027 introduced a Kotlin version of the existing Beam Katas for

[jira] [Created] (BEAM-10210) Blog Post for Kotlin-based Beam Katas

Rion Williams created BEAM-10210: Summary: Blog Post for Kotlin-based Beam Katas Key: BEAM-10210 URL: https://issues.apache.org/jira/browse/BEAM-10210 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-10210) Blog Post for Kotlin-based Beam Katas

[ https://issues.apache.org/jira/browse/BEAM-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10210: --- Status: Open (was: Triage Needed) > Blog Post for Kotlin-based Beam Katas >

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

[ https://issues.apache.org/jira/browse/BEAM-10027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rion Williams closed BEAM-10027. Resolution: Done > Support for Kotlin-based Beam Katas > --- > >

[jira] [Work logged] (BEAM-10209) Add without_defaults to Mean

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

[jira] [Work logged] (BEAM-10209) Add without_defaults to Mean

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

[jira] [Work logged] (BEAM-2939) Fn API SDF support

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

[jira] [Commented] (BEAM-10169) ParDo* functions should declare the correct output N in their error message

[ https://issues.apache.org/jira/browse/BEAM-10169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127136#comment-17127136 ] Aaron Tillekeratne commented on BEAM-10169: --- I like it; referencing the DoFn is  great idea. I

[jira] [Work logged] (BEAM-10093) Add ZetaSQL Nexmark variant

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

[jira] [Work logged] (BEAM-2939) Fn API SDF support

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

[jira] [Work logged] (BEAM-10197) Support type hints for frozenset

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

[jira] [Work logged] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10197) Support type hints for frozenset

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

[jira] [Work logged] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Resolved] (BEAM-10145) Kafka IO performance tests leaving behind unused disks on apache-beam-testing

[ https://issues.apache.org/jira/browse/BEAM-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski resolved BEAM-10145. - Fix Version/s: Not applicable Resolution: Fixed > Kafka IO performance tests

[jira] [Work logged] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10209) Add without_defaults to Mean

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

[jira] [Work logged] (BEAM-9363) BeamSQL windowing as TVF

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

[jira] [Commented] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-10176) Support BigQuery type aliases in WriteToBigQuery with Avro format

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

[jira] [Updated] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

[ https://issues.apache.org/jira/browse/BEAM-3342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3342: Labels: stale-assigned (was: ) > Create a Cloud Bigtable IO connector for Python >

[jira] [Work logged] (BEAM-2939) Fn API SDF support

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

[jira] [Work logged] (BEAM-10101) Add a HttpIO / HttpFileSystem

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

[jira] [Work logged] (BEAM-10209) Add without_defaults to Mean

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

[jira] [Created] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10201) Enhance JsonToRow to add Deadletter Support

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

[jira] [Work logged] (BEAM-10201) Enhance JsonToRow to add Deadletter Support

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

[jira] [Updated] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Assigned] (BEAM-10208) add cross-language KafkaIO integration test

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

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

[ https://issues.apache.org/jira/browse/BEAM-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee resolved BEAM-9869. --- Fix Version/s: 2.23.0 Resolution: Fixed > adding self-contained Kafka service jar for testing

[jira] [Resolved] (BEAM-10052) check hash and avoid duplicates when uploading artifact in Python Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee resolved BEAM-10052. Resolution: Fixed > check hash and avoid duplicates when uploading artifact in Python Dataflow >

[jira] [Resolved] (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 resolved BEAM-10125. Fix Version/s: 2.23.0 Resolution: Fixed > adding cross-language KafkaIO integration test >

[jira] [Work logged] (BEAM-9363) BeamSQL windowing as TVF

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

[jira] [Updated] (BEAM-10052) check hash and avoid duplicates when uploading artifact in Python Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-10052: --- Fix Version/s: 2.22.0 > check hash and avoid duplicates when uploading artifact in Python Dataflow

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

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

[jira] [Work logged] (BEAM-9626) pymongo should be an optional requirement

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

[jira] [Work logged] (BEAM-9626) pymongo should be an optional requirement

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

[jira] [Work logged] (BEAM-6215) FlatMap no longer shows User function name

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

[jira] [Work logged] (BEAM-10101) Add a HttpIO / HttpFileSystem

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

[jira] [Work logged] (BEAM-10201) Enhance JsonToRow to add Deadletter Support

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

[jira] [Work logged] (BEAM-10208) add cross-language KafkaIO integration test

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

[jira] [Work logged] (BEAM-10176) Support BigQuery type aliases in WriteToBigQuery with Avro format

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

[jira] [Work logged] (BEAM-10145) Kafka IO performance tests leaving behind unused disks on apache-beam-testing

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

[jira] [Work logged] (BEAM-10197) Support type hints for frozenset

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

[jira] [Work logged] (BEAM-10176) Support BigQuery type aliases in WriteToBigQuery with Avro format

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

[jira] [Work logged] (BEAM-9990) FhirIO should support conditional create / update methods

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

[jira] [Created] (BEAM-10209) Add without_defaults to Mean

Inigo San Jose Visiers created BEAM-10209: - Summary: Add without_defaults to Mean Key: BEAM-10209 URL: https://issues.apache.org/jira/browse/BEAM-10209 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-10201) Enhance JsonToRow to add Deadletter Support

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