[jira] [Work logged] (BEAM-7115) TFRecordIOIT write_time metrics are allways 0.0

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

[jira] [Commented] (BEAM-3718) ClassNotFoundException on CloudResourceManager$Builder

[ https://issues.apache.org/jira/browse/BEAM-3718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007202#comment-17007202 ] Shahar Frank commented on BEAM-3718: Almost the same happens to me with FlinkRunner: {code:java}

[jira] [Work logged] (BEAM-8676) Beam Dependency Update Request: com.google.api:gax-grpc

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

[jira] [Created] (BEAM-9052) BigQueryUtils toBeamRow to support the bytes type

Ryan Berti created BEAM-9052: Summary: BigQueryUtils toBeamRow to support the bytes type Key: BEAM-9052 URL: https://issues.apache.org/jira/browse/BEAM-9052 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Created] (BEAM-9051) BigQueryUtils toBeamRow to support GenericRecords with millisecond precision timestamps

Ryan Berti created BEAM-9051: Summary: BigQueryUtils toBeamRow to support GenericRecords with millisecond precision timestamps Key: BEAM-9051 URL: https://issues.apache.org/jira/browse/BEAM-9051 Project:

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-9027) [SQL] ZetaSQL unparsing should produce valid result

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

[jira] [Work logged] (BEAM-9027) [SQL] ZetaSQL unparsing should produce valid result

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

[jira] [Work logged] (BEAM-9027) [SQL] ZetaSQL unparsing should produce valid result

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-8844) [SQL] Create performance tests for BigQueryTable

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

[jira] [Work logged] (BEAM-8844) [SQL] Create performance tests for BigQueryTable

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

[jira] [Work logged] (BEAM-8844) [SQL] Create performance tests for BigQueryTable

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

[jira] [Work logged] (BEAM-8844) [SQL] Create performance tests for BigQueryTable

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

[jira] [Work logged] (BEAM-8844) [SQL] Create performance tests for BigQueryTable

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-8496) remove SDF translators in flink streaming transform translator

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Resolved] (BEAM-8938) Tests end up leaving stale Dataflow jobs in apache-beam-testing project and exhaust GCP resources

[ https://issues.apache.org/jira/browse/BEAM-8938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-8938. Fix Version/s: Not applicable Resolution: Not A Problem Java part is not failing anymore

[jira] [Work logged] (BEAM-8624) Implement FnService for status api in Dataflow runner

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

[jira] [Work logged] (BEAM-8938) Tests end up leaving stale Dataflow jobs in apache-beam-testing project and exhaust GCP resources

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-9041) SchemaCoder equals should not rely on from/toRowFunction equality

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

[jira] [Work logged] (BEAM-7246) Create a Spanner IO for Python

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

[jira] [Updated] (BEAM-9041) SchemaCoder equals should not rely on from/toRowFunction equality

[ https://issues.apache.org/jira/browse/BEAM-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9041: --- Summary: SchemaCoder equals should not rely on from/toRowFunction equality (was: SchemaCoder equals

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-7926) Show PCollection with Interactive Beam in a data-centric user flow

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

[jira] [Work logged] (BEAM-9050) Beam pickler doesn't pickle classes that have __module__ set to None.

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

[jira] [Created] (BEAM-9050) Beam pickler doesn't pickle classes that have __module__ set to None.

Valentyn Tymofieiev created BEAM-9050: - Summary: Beam pickler doesn't pickle classes that have __module__ set to None. Key: BEAM-9050 URL: https://issues.apache.org/jira/browse/BEAM-9050

[jira] [Work logged] (BEAM-5504) PubsubAvroTable

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

[jira] [Work logged] (BEAM-9030) Bump grpc to 1.26.0

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

[jira] [Created] (BEAM-9049) Add knobs for dataflow worker MemoryMonitor

Brian Hulette created BEAM-9049: --- Summary: Add knobs for dataflow worker MemoryMonitor Key: BEAM-9049 URL: https://issues.apache.org/jira/browse/BEAM-9049 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-9048) Matching compile-time and run-time type information in Java external transforms

Heejong Lee created BEAM-9048: - Summary: Matching compile-time and run-time type information in Java external transforms Key: BEAM-9048 URL: https://issues.apache.org/jira/browse/BEAM-9048 Project: Beam

[jira] [Assigned] (BEAM-9048) Matching compile-time and run-time type information in Java external transforms

[ https://issues.apache.org/jira/browse/BEAM-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee reassigned BEAM-9048: - Assignee: Heejong Lee > Matching compile-time and run-time type information in Java external >

[jira] [Updated] (BEAM-9048) Matching compile-time and run-time type information in Java external transforms

[ https://issues.apache.org/jira/browse/BEAM-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-9048: -- Status: Open (was: Triage Needed) > Matching compile-time and run-time type information in Java

[jira] [Work logged] (BEAM-8676) Beam Dependency Update Request: com.google.api:gax-grpc

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

[jira] [Work logged] (BEAM-9030) Bump grpc to 1.26.0

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

[jira] [Work logged] (BEAM-5504) PubsubAvroTable

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

[jira] [Work logged] (BEAM-8676) Beam Dependency Update Request: com.google.api:gax-grpc

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-3288) Guard against unsafe triggers at construction time

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

[jira] [Updated] (BEAM-9047) Java TestPipeline doesn't support remote job endpoint

[ https://issues.apache.org/jira/browse/BEAM-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-9047: -- Status: Open (was: Triage Needed) > Java TestPipeline doesn't support remote job endpoint >

[jira] [Created] (BEAM-9047) Java TestPipeline doesn't support remote job endpoint

Heejong Lee created BEAM-9047: - Summary: Java TestPipeline doesn't support remote job endpoint Key: BEAM-9047 URL: https://issues.apache.org/jira/browse/BEAM-9047 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Resolved] (BEAM-9034) Update environment_id for ExternalTransform in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee resolved BEAM-9034. --- Fix Version/s: 2.19.0 Resolution: Fixed > Update environment_id for ExternalTransform in

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-7961) Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite

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

[jira] [Work logged] (BEAM-4287) SplittableDoFn: splitAtFraction() API for Java

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

[jira] [Work logged] (BEAM-7427) JmsCheckpointMark Avro Serialisation issue with UnboundedSource

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

[jira] [Work logged] (BEAM-4287) SplittableDoFn: splitAtFraction() API for Java

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

[jira] [Work logged] (BEAM-4287) SplittableDoFn: splitAtFraction() API for Java

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-5600) Splitting for SplittableDoFn should be exposed within runner shared libraries

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

[jira] [Work logged] (BEAM-5600) Splitting for SplittableDoFn should be exposed within runner shared libraries

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-5600) Splitting for SplittableDoFn should be exposed within runner shared libraries

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

[jira] [Work logged] (BEAM-9034) Update environment_id for ExternalTransform in Python SDK

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

[jira] [Work logged] (BEAM-9034) Update environment_id for ExternalTransform in Python SDK

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

[jira] [Work logged] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model

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

[jira] [Work logged] (BEAM-8891) Create and submit Spark portable jar in Python

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

[jira] [Work logged] (BEAM-8891) Create and submit Spark portable jar in Python

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

[jira] [Work logged] (BEAM-5600) Splitting for SplittableDoFn should be exposed within runner shared libraries

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

[jira] [Work logged] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model

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

[jira] [Updated] (BEAM-9046) Kafka connector for Python throws ClassCastException when reading KafkaRecord

[ https://issues.apache.org/jira/browse/BEAM-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Berkay Öztürk updated BEAM-9046: Description:  I'm trying to read the data streaming from Apache Kafka using the Python SDK for

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Created] (BEAM-9046) Kafka connector for Python throws ClassCastException when reading KafkaRecord

Berkay Öztürk created BEAM-9046: --- Summary: Kafka connector for Python throws ClassCastException when reading KafkaRecord Key: BEAM-9046 URL: https://issues.apache.org/jira/browse/BEAM-9046 Project:

[jira] [Commented] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization

[ https://issues.apache.org/jira/browse/BEAM-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007067#comment-17007067 ] Cyrille Chépélov commented on BEAM-8577: Got hit by this while attempting to run a SCIO pipeline

[jira] [Work logged] (BEAM-5504) PubsubAvroTable

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-5504) PubsubAvroTable

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

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

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-7926) Show PCollection with Interactive Beam in a data-centric user flow

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-8960) Add an option for user to be able to opt out of using insert id for BigQuery streaming insert.

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-5605) Support Portable SplittableDoFn for batch

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

[jira] [Work logged] (BEAM-8996) Auto-generate pipeline options documentation for FlinkRunner

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

[jira] [Work logged] (BEAM-7926) Show PCollection with Interactive Beam in a data-centric user flow

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

[jira] [Work logged] (BEAM-7926) Show PCollection with Interactive Beam in a data-centric user flow

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

[jira] [Resolved] (BEAM-8935) Fail fast if sdk harness startup failed

[ https://issues.apache.org/jira/browse/BEAM-8935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-8935. - Resolution: Fixed > Fail fast if sdk harness startup failed > --- > >

[jira] [Work logged] (BEAM-8935) Fail fast if sdk harness startup failed

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

[jira] [Work logged] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness

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

  1   2   >