github  

Messages by Date

• 2026/02/10 Re: [PR] [Java FnApi] Improve FinalizeCallbackManager to cleanup timeout queue and use recommended ReentrantLock+Condition [beam] via GitHub
• 2026/02/10 Re: [PR] [Java FnApi] Improve FinalizeCallbackManager to cleanup timeout queue and use recommended ReentrantLock+Condition [beam] via GitHub
• 2026/02/10 Re: [I] Support for custom Python UnboundedSource [beam] via GitHub
• 2026/02/09 Re: [I] Add Kafka Streams runner [beam] via GitHub
• 2026/02/09 Re: [PR] Bump golang.org/x/net from 0.49.0 to 0.50.0 in /sdks [beam] via GitHub
• 2026/02/09 [PR] Bump golang.org/x/net from 0.49.0 to 0.50.0 in /sdks [beam] via GitHub
• 2026/02/09 Re: [PR] Add OOM handling for RunInference with model manager [beam] via GitHub
• 2026/02/09 [PR] Add OOM handling for RunInference with model manager [beam] via GitHub
• 2026/02/09 Re: [I] [Bug]: JavaFieldSchema does not support for Beam Logical Types [beam] via GitHub
• 2026/02/09 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• 2026/02/09 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• 2026/02/09 Re: [PR] Bump wheel from 0.45.1 to 0.46.2 in /sdks/python/container/py310 [beam] via GitHub
• 2026/02/09 Re: [PR] Bump wheel from 0.45.1 to 0.46.2 in /sdks/python/container/py310 [beam] via GitHub
• 2026/02/09 Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• 2026/02/09 Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
• 2026/02/09 Re: [PR] Add logic to handle end timestamp of mutable change stream bounded query [beam] via GitHub
• 2026/02/09 Re: [PR] Add logic to handle end timestamp of mutable change stream bounded query [beam] via GitHub
• 2026/02/09 Re: [PR] Add logic to handle end timestamp of mutable change stream bounded query [beam] via GitHub
• 2026/02/09 Re: [PR] fix(python): Register all declared DoOutputsTuple outputs in composite transforms [beam] via GitHub
• 2026/02/09 [PR] fix(python): Register all declared DoOutputsTuple outputs in composite transforms [beam] via GitHub
• 2026/02/09 Re: [PR] Add model manager that automatically allocate models and prevents OOMs [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 [PR] Fix PreCommit Python [beam] via GitHub
• 2026/02/09 Re: [PR] Fix PreCommit Python [beam] via GitHub
• 2026/02/09 Re: [PR] [Spanner Change Streams] Parse proto bytes change stream record in ChangeStreamRecordMapper [beam] via GitHub
• 2026/02/09 Re: [PR] Exercise Python PVR test on Flink 2.0 [beam] via GitHub
• 2026/02/09 Re: [PR] [Spanner Change Streams] Parse proto bytes change stream record in ChangeStreamRecordMapper [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Add Go example for schema-transform nested field access [beam] via GitHub
• 2026/02/09 Re: [PR] Add Go example for schema-transform nested field access [beam] via GitHub
• 2026/02/09 Re: [PR] Add back flex API option with improved pydoc [beam] via GitHub
• 2026/02/09 Re: [PR] Enable pickling main by reference option within CloudpickleConfig [beam] via GitHub
• 2026/02/09 Re: [PR] Enable pickling main by reference option within CloudpickleConfig [beam] via GitHub
• 2026/02/09 Re: [PR] Enable pickling main by reference option within CloudpickleConfig [beam] via GitHub
• 2026/02/09 [PR] Enable pickling main by reference option within CloudpickleConfig [beam] via GitHub
• 2026/02/09 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/09 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/09 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/09 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Add access to pipeline options during pipeline construction and translation. [beam] via GitHub
• 2026/02/09 Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• 2026/02/09 Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/09 Re: [PR] GCS client library migration in Java SDK - part 2 [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• 2026/02/09 Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Fix Components visibility [beam] via GitHub
• 2026/02/09 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/09 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/09 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/09 Re: [PR] Fix _OrderedUnionCoder is_deterministic check. [beam] via GitHub
• 2026/02/09 Re: [PR] Add Python example for schema transforms (field selection) [beam] via GitHub
• 2026/02/09 Re: [PR] Fix _OrderedUnionCoder is_deterministic check. [beam] via GitHub
• 2026/02/09 Re: [PR] [SQL] Alter Catalog and Table statements [beam] via GitHub
• 2026/02/09 Re: [I] [Bug]: Unhandled exception in KafkaIO SDF [beam] via GitHub
• 2026/02/09 Re: [PR] Docs: document BigQuery Storage Read API usage in Python [beam] via GitHub
• 2026/02/09 Re: [PR] Fix _OrderedUnionCoder is_deterministic check. [beam] via GitHub
• 2026/02/09 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/09 Re: [PR] Move CausedByDrain to top level, move types [beam] via GitHub
• 2026/02/09 Re: [PR] Move CausedByDrain to top level, move types [beam] via GitHub
• 2026/02/09 Re: [PR] Move CausedByDrain to top level, move types [beam] via GitHub
• 2026/02/09 Re: [PR] Docs: document BigQuery Storage Read API usage in Python [beam] via GitHub
• 2026/02/09 Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] via GitHub
• 2026/02/09 Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] via GitHub
• 2026/02/09 Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] via GitHub
• 2026/02/09 Re: [PR] Fix _OrderedUnionCoder is_deterministic check. [beam] via GitHub
• 2026/02/09 [PR] Fix _OrderedUnionCoder is_deterministic check. [beam] via GitHub
• 2026/02/09 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/09 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/09 Re: [PR] [Python][Java] Add support for record headers in WriteToKafka (Fixes #27033) [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 Re: [PR] Exposed source window to AssignContext in window_mapping_fn for side inputs [beam] via GitHub
• 2026/02/09 Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] via GitHub
• 2026/02/09 Re: [PR] feat: Introduce agent skills for various Apache Beam developments [beam] via GitHub
• 2026/02/09 Re: [PR] Upgrade Spanner to the latest version [beam] via GitHub
• 2026/02/09 Re: [PR] Move CausedByDrain to top level, move types [beam] via GitHub
• 2026/02/09 [PR] Move CausedByDrain to top level, move types [beam] via GitHub
• 2026/02/09 Re: [I] [QUESTION] Running Beam using GO on Apache Flink k8s [beam] via GitHub
• 2026/02/09 Re: [I] [Feature Request]: Cross-language / Java support for Enrichment transform [beam] via GitHub
• 2026/02/09 Re: [I] [Distroless] Enable Distroless Java SDK based container images [beam] via GitHub
• 2026/02/09 Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
• 2026/02/09 Re: [PR] Exposed source window to AssignContext in window_mapping_fn for side inputs [beam] via GitHub
• 2026/02/09 Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
• 2026/02/09 Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] via GitHub
• 2026/02/09 Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] via GitHub
• 2026/02/09 Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] via GitHub
• 2026/02/09 Re: [PR] Enforce @Validation.Required annotation on PipelineOptions [beam] via GitHub
• 2026/02/08 Re: [PR] Bump golang.org/x/oauth2 from 0.34.0 to 0.35.0 in /sdks [beam] via GitHub
• 2026/02/08 Re: [PR] Bump golang.org/x/oauth2 from 0.34.0 to 0.35.0 in /sdks [beam] via GitHub
• 2026/02/08 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/08 [PR] Bump golang.org/x/oauth2 from 0.34.0 to 0.35.0 in /sdks [beam] via GitHub
• 2026/02/08 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/08 Re: [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/08 [PR] Add RateLimiter Abstractions [beam] via GitHub
• 2026/02/08 Re: [PR] Add States for Pause [beam] via GitHub
• 2026/02/08 [PR] Add States for Pause [beam] via GitHub
• 2026/02/08 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/08 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/08 Re: [PR] Enforce @Validation.Required annotation on PipelineOptions [beam] via GitHub
• 2026/02/08 [PR] Enforce @Validation.Required annotation on PipelineOptions [beam] via GitHub
• 2026/02/08 Re: [PR] Enforce @Validation.Required annotation on PipelineOptions [beam] via GitHub
• 2026/02/08 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/08 Re: [I] [Bug]: PYTHON SDK / WriteToBigquery with STORAGE_WRITE_API fails when NULLABLE nested RECORD [beam] via GitHub
• 2026/02/08 Re: [I] [Bug]: Python SDK avro to beam schema conversion defaults to Any type for nullable atomic union fields [beam] via GitHub
• 2026/02/08 Re: [I] [Bug]: Uber jar not register coders causing `UnknownCoderWrapper` error [beam] via GitHub
• 2026/02/08 Re: [I] [Bug]: Uber jar not register coders causing `UnknownCoderWrapper` error [beam] via GitHub
• 2026/02/08 Re: [PR] Fix Javadoc Unicode rendering issue with RIGHT SINGLE QUOTATION MARK [beam] via GitHub
• 2026/02/08 Re: [PR] feat: Improve YamlUtils.dumpAsMap error handling [beam] via GitHub
• 2026/02/08 Re: [I] python typehints: reduce the number of runtime-type-check wrappers [beam] via GitHub
• 2026/02/08 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• 2026/02/08 Re: [I] Beam Programming Guide: Add Go version of Section 6.6 "Using Schema Transforms" [beam] via GitHub
• 2026/02/07 Re: [I] [Feature Request]: Expose more query options to bigqueryio for go. [beam] via GitHub
• 2026/02/07 Re: [PR] [wip] update coverage details to improve reporting [beam] via GitHub
• 2026/02/07 [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• 2026/02/07 Re: [PR] Add Go example for schema-transform nested field access [beam] via GitHub
• 2026/02/07 Re: [PR] Add Go example for schema-transform nested field access [beam] via GitHub
• 2026/02/07 [PR] Add Go example for schema-transform nested field access [beam] via GitHub
• 2026/02/07 Re: [PR] Bump go.mongodb.org/mongo-driver from 1.17.7 to 1.17.8 in /sdks [beam] via GitHub
• 2026/02/07 Re: [PR] Docs: document BigQuery Storage Read API usage in Python [beam] via GitHub
• 2026/02/07 Re: [I] Beam Programming Guide: Add Go version of Section 6.6 "Using Schema Transforms" [beam] via GitHub
• 2026/02/07 Re: [PR] Docs: document BigQuery Storage Read API usage in Python [beam] via GitHub
• 2026/02/07 [PR] Docs: document BigQuery Storage Read API usage in Python [beam] via GitHub
• 2026/02/07 Re: [I] [Task]: Update BigQuery IO Docs: BigQuery IO supports READ_API [beam] via GitHub
• 2026/02/07 Re: [PR] Fix Precommit Python Job [beam] via GitHub
• 2026/02/07 Re: [PR] Fix Precommit Python Job [beam] via GitHub
• 2026/02/07 Re: [PR] Add Apache Iceberg support and Catalog support to Beam SQL documentation [beam] via GitHub
• 2026/02/07 Re: [PR] Add Apache Iceberg support and Catalog support to Beam SQL documentation [beam] via GitHub
• 2026/02/07 Re: [PR] Debug grpc errors in tests [beam] via GitHub
• 2026/02/07 Re: [I] [Feature Request]: add documentation on maintaining transform update compatiblity when performing changes [beam] via GitHub
• 2026/02/07 Re: [PR] Cleanup: Improve formatting and remove duplicate code in textio.py [beam] via GitHub
• 2026/02/07 Re: [I] [Feature Request]: add documentation on maintaining transform update compatiblity when performing changes [beam] via GitHub
• 2026/02/07 Re: [PR] Cleanup: Improve formatting and remove duplicate code in textio.py [beam] via GitHub
• 2026/02/07 Re: [PR] Fix Precommit Python Job [beam] via GitHub
• 2026/02/07 [PR] Fix Precommit Python Job [beam] via GitHub
• 2026/02/07 Re: [PR] feat(ml): add stateless bundle-local size-aware batching and benchmark [beam] via GitHub
• 2026/02/07 Re: [I] Beam Programming Guide: Add Go version of Section 6.6 "Using Schema Transforms" [beam] via GitHub
• 2026/02/07 Re: [I] Add Kafka Streams runner [beam] via GitHub
• 2026/02/07 Re: [I] Add Kafka Streams runner [beam] via GitHub
• 2026/02/07 Re: [PR] Add Python example for schema transforms (field selection) [beam] via GitHub
• 2026/02/07 Re: [I] Beam Programming Guide: Add Go version of Section 6.6 "Using Schema Transforms" [beam] via GitHub
• 2026/02/06 Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] via GitHub
• 2026/02/06 Re: [PR] ML pipelines: RunInference - OSS Image Object detection, OSS Image Captioning, OSS Image Classification [beam] via GitHub
• 2026/02/06 Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] via GitHub
• 2026/02/06 Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] via GitHub
• 2026/02/06 Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] via GitHub
• 2026/02/06 Re: [PR] feat(ml): add stateless bundle-local size-aware batching and benchmark [beam] via GitHub
• 2026/02/06 Re: [PR] [wip] update coverage details to improve reporting [beam] via GitHub
• 2026/02/06 [PR] [wip] update coverage details to improve reporting [beam] via GitHub
• 2026/02/06 Re: [PR] Align go rc validation inputs with other workflows [beam] via GitHub
• 2026/02/06 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/06 Re: [PR] SQL DDL documentation [beam] via GitHub
• 2026/02/06 Re: [PR] SQL DDL documentation [beam] via GitHub
• 2026/02/06 [PR] SQL DDL documentation [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] Fix flakiness in model manager and multiprocessshared tests [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Use 'to_retain' tag for MultiProcessShared test [beam] via GitHub
• 2026/02/06 Re: [PR] Use 'to_retain' tag for MultiProcessShared test [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] Update RunInference to work with model manager [beam] via GitHub
• 2026/02/06 Re: [PR] [Flink 2.0] Exercise validate runner test for classic Flink runner [beam] via GitHub
• 2026/02/06 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Update queuing logic to avoid lock notify contention [beam] via GitHub
• 2026/02/06 Re: [PR] Fix flakiness in model manager and multiprocessshared tests [beam] via GitHub
• 2026/02/06 Re: [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/06 [PR] Exercise Flink PVR tests on Flink 2.0 [beam] via GitHub
• 2026/02/06 Re: [PR] Add Python example for schema transforms (field selection) [beam] via GitHub
• 2026/02/06 Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] via GitHub
• 2026/02/06 Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] via GitHub
• 2026/02/06 Re: [PR] [Flink 2.0] Exercise validate runner test for classic Flink runner [beam] via GitHub
• 2026/02/06 Re: [PR] [Flink 2.0] Exercise validate runner test for classic Flink runner [beam] via GitHub

• Earlier messages