github  

Messages by Date

• 2026/03/24 Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
• 2026/03/24 Re: [PR] Add outstanding parameters to processElement and onTimer signatures [beam] via GitHub
• 2026/03/24 Re: [PR] Add outstanding parameters to processElement and onTimer signatures [beam] via GitHub
• 2026/03/24 Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
• 2026/03/24 Re: [PR] Handle Flink 2 job server tag in releases and SDK snapshot [beam] via GitHub
• 2026/03/24 Re: [PR] Handle Flink 2 job server tag in releases and SDK snapshot [beam] via GitHub
• 2026/03/24 Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
• 2026/03/24 Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
• 2026/03/24 Re: [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
• 2026/03/24 Re: [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
• 2026/03/24 Re: [PR] Handle Flink 2 job server tag in releases and SDK snapshot [beam] via GitHub
• 2026/03/24 [PR] Handle Flink 2 job server tag in releases and SDK snapshot [beam] via GitHub
• 2026/03/24 Re: [PR] Add ADK model handler [beam] via GitHub
• 2026/03/24 Re: [PR] Add ADK model handler [beam] via GitHub
• 2026/03/24 Re: [PR] [wip] Iceberg add files yaml transform and test [beam] via GitHub
• 2026/03/24 [PR] [wip] Iceberg add files yaml transform and test [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] remove processContext usage across examples (java and kotlin) [beam] via GitHub
• 2026/03/24 [PR] remove processContext usage across examples (java and kotlin) [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Add ADK model handler [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Changes273 [beam] via GitHub
• 2026/03/24 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/03/24 Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• 2026/03/24 Re: [PR] Changes273 [beam] via GitHub
• 2026/03/24 [PR] Changes273 [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Exposed source window to AssignContext in window_mapping_fn for side inputs [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Bump Java dev containers [beam] via GitHub
• 2026/03/24 Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC5 [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
• 2026/03/24 Re: [PR] Add outstanding parameters to processElement and onTimer signatures [beam] via GitHub
• 2026/03/24 Re: [PR] Cherrypick #37927 [beam] via GitHub
• 2026/03/24 Re: [PR] Cherrypick #37927 [beam] via GitHub
• 2026/03/24 [PR] Cherrypick #37927 [beam] via GitHub
• 2026/03/24 Re: [PR] Cherrypick #37924 [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] Cherrypick #37924 [beam] via GitHub
• 2026/03/24 [PR] Cherrypick #37924 [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 Re: [PR] [#37930][Runners] Reap child processes in ProcessManager to prevent zombie accumulation [beam] via GitHub
• 2026/03/24 Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• 2026/03/24 Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/24 Re: [PR] Add outstanding parameters to processElement and onTimer signatures [beam] via GitHub
• 2026/03/24 Re: [PR] Updates YAML Database transforms to use managed I/O by default [beam] via GitHub
• 2026/03/24 [PR] Add outstanding parameters to processElement and onTimer signatures [beam] via GitHub
• 2026/03/24 Re: [PR] [Python][Java] Add support for record headers in WriteToKafka (Fixes #27033) [beam] via GitHub
• 2026/03/24 Re: [PR] [Python][Java] Add support for record headers in WriteToKafka (Fixes #27033) [beam] via GitHub
• 2026/03/24 Re: [I] [Feature Request]: Add support to write record headers in `WriteToKafka` in python SDK [beam] via GitHub
• 2026/03/24 Re: [PR] Bump Java dev containers [beam] via GitHub
• 2026/03/24 Re: [PR] [#37930][Runners] Reap child processes in ProcessManager to prevent zombie accumulation [beam] via GitHub
• 2026/03/24 Re: [PR] Bump Java dev containers [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/24 [PR] [#37930][Runners] Reap child processes in ProcessManager to prevent zombie accumulation [beam] via GitHub
• 2026/03/24 Re: [I] [Task]: Add DatadogIO to website after 2.72 release [beam] via GitHub
• 2026/03/24 Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
• 2026/03/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/03/24 Re: [PR] Bump Java dev containers [beam] via GitHub
• 2026/03/24 [PR] Bump Java dev containers [beam] via GitHub
• 2026/03/24 Re: [I] [Bug]: ProcessManager does not reap child processes, causing zombie accumulation on long-running Flink deployments [beam] via GitHub
• 2026/03/24 [I] [Bug]: ProcessManager does not reap child processes, causing zombie accumulation on long-running Flink deployments [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC3 [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC1 [beam] via GitHub
• 2026/03/24 Re: [I] [Feature Request]: auto-detect schema in managed I/O [beam] via GitHub
• 2026/03/24 Re: [PR] Iceberg CDC streaming source [beam] via GitHub
• 2026/03/24 Re: [PR] ib.collect support wait_for_inputs option [beam] via GitHub
• 2026/03/24 Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] via GitHub
• 2026/03/24 Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
• 2026/03/24 Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] via GitHub
• 2026/03/24 Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
• 2026/03/24 Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] via GitHub
• 2026/03/24 Re: [PR] [Iceberg] Support nested column paths in keep/drop configuration [beam] via GitHub
• 2026/03/24 Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC1 [beam] via GitHub
• 2026/03/24 Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
• 2026/03/24 Re: [PR] Pin setuptools below 82 for TensorFlow Hub pkg_resources compatibility [beam] via GitHub
• 2026/03/24 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/24 Re: [PR] Pin setuptools below 82 for TensorFlow Hub pkg_resources compatibility [beam] via GitHub
• 2026/03/24 [PR] Pin setuptools below 82 for TensorFlow Hub pkg_resources compatibility [beam] via GitHub
• 2026/03/23 Re: [PR] Add docstring for PGBKCVOperations [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] via GitHub
• 2026/03/23 Re: [PR] Pin to SHA for GCP GitHub Actions [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Go SDK: coder.RegisterCoder needs more precise docstring [beam] via GitHub
• 2026/03/23 Re: [PR] Add docstring for PGBKCVOperations [beam] via GitHub
• 2026/03/23 [PR] Add docstring for PGBKCVOperations [beam] via GitHub
• 2026/03/23 Re: [I] PGBKCVOperation is undocumented [beam] via GitHub
• 2026/03/23 Re: [PR] Pin to SHA for GCP GitHub Actions [beam] via GitHub
• 2026/03/23 Re: [PR] Updates YAML Database transforms to use managed I/O by default [beam] via GitHub
• 2026/03/23 [PR] Pin to SHA for GCP GitHub Actions [beam] via GitHub
• 2026/03/23 Re: [PR] Pin to SHA for GCP GitHub Actions [beam] via GitHub
• 2026/03/23 Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
• 2026/03/23 Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
• 2026/03/23 Re: [PR] Pin gcp actions [beam] via GitHub
• 2026/03/23 Re: [PR] Fix #37894: Update yaml doc for composite transform changes [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: update the yaml doc for composite transform changes [beam] via GitHub
• 2026/03/23 Re: [PR] Add Quick Start section to README [beam] via GitHub
• 2026/03/23 Re: [PR] Add Quick Start section to README [beam] via GitHub
• 2026/03/23 Re: [PR] Pin gcp actions [beam] via GitHub
• 2026/03/23 [PR] Pin gcp actions [beam] via GitHub
• 2026/03/23 Re: [PR] Pin gcp actions [beam] via GitHub
• 2026/03/23 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/23 Re: [PR] Iceberg Add Files [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Bump cbor2 from 5.8.0 to 5.9.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Pin version for setup-qemu-action [beam] via GitHub
• 2026/03/23 [PR] Bump cbor2 from 5.8.0 to 5.9.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• 2026/03/23 Re: [PR] Pin version for setup-qemu-action [beam] via GitHub
• 2026/03/23 [PR] Pin version for setup-qemu-action [beam] via GitHub
• 2026/03/23 Re: [PR] Updates YAML Database transforms to use managed I/O by default [beam] via GitHub
• 2026/03/23 [PR] Updates YAML Database transforms to use managed I/O by default [beam] via GitHub
• 2026/03/23 Re: [PR] [WIP] Add ADK model handler [beam] via GitHub
• 2026/03/23 Re: [PR] Pin docker actions to sha for now [beam] via GitHub
• 2026/03/23 Re: [PR] Pin docker actions to sha for now [beam] via GitHub
• 2026/03/23 [PR] Pin docker actions to sha for now [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Cherrypick #37920 [beam] via GitHub
• 2026/03/23 Re: [PR] Cherrypick #37920 [beam] via GitHub
• 2026/03/23 [PR] Cherrypick #37920 [beam] via GitHub
• 2026/03/23 Re: [PR] Add version to beam-sdks-java-io-components [beam] via GitHub
• 2026/03/23 Re: [I] The PreCommit Java GCP IO Direct job is flaky [beam] via GitHub
• 2026/03/23 Re: [PR] Add version to beam-sdks-java-io-components [beam] via GitHub
• 2026/03/23 [PR] Add version to beam-sdks-java-io-components [beam] via GitHub
• 2026/03/23 Re: [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] via GitHub
• 2026/03/23 Re: [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] via GitHub
• 2026/03/23 Re: [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] via GitHub
• 2026/03/23 Re: [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] via GitHub
• 2026/03/23 [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] via GitHub
• 2026/03/23 Re: [PR] Sync clickhouse resource manager client version with IO [beam] via GitHub
• 2026/03/23 Re: [PR] Sync clickhouse resource manager client version with IO [beam] via GitHub
• 2026/03/23 [PR] Sync clickhouse resource manager client version with IO [beam] via GitHub
• 2026/03/23 Re: [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] via GitHub
• 2026/03/23 Re: [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• 2026/03/23 Re: [PR] [Java] Optimize StreamUtils to avoid copying bytes [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 Re: [PR] Upgrade Docker setup actions to version 4 [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Ensure the effective communications during the Beam 3.0.0 development process [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 Re: [PR] Update managed-io.md for release 2.72.0-RC3 [beam] via GitHub
• 2026/03/23 Re: [PR] [WIP] Add ADK model handler [beam] via GitHub
• 2026/03/23 [PR] [WIP] Add ADK model handler [beam] via GitHub
• 2026/03/23 Re: [PR] RedisIO support PCollection of <byte[], byte[]> [beam] via GitHub
• 2026/03/23 Re: [PR] Upgrade Docker setup actions to version 4 [beam] via GitHub
• 2026/03/23 Re: [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 Re: [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] via GitHub
• 2026/03/23 [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] via GitHub
• 2026/03/23 Re: [PR] Update managed-io.md for release 2.72.0-RC3 [beam] via GitHub
• 2026/03/23 [PR] Update managed-io.md for release 2.72.0-RC3 [beam] via GitHub
• 2026/03/23 Re: [PR] Upgrade Docker setup actions to version 4 [beam] via GitHub
• 2026/03/23 [PR] Upgrade Docker setup actions to version 4 [beam] via GitHub
• 2026/03/23 Re: [PR] [Java] Optimize StreamUtils to avoid copying bytes [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 Re: [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] via GitHub
• 2026/03/23 [PR] [Java] Optimize StreamUtils to avoid copying bytes [beam] via GitHub
• 2026/03/23 Re: [PR] [Java] Optimize StreamUtils to avoid copying bytes [beam] via GitHub
• 2026/03/23 Re: [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
• 2026/03/23 Re: [I] [Feature Request]: Commit failed: value exceeding byte limit - [beam] via GitHub
• 2026/03/23 Re: [I] [Feature Request]: ElasticsearchIO Python SDK support [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Change sendState to handle state transition in a state machine [beam] via GitHub
• 2026/03/23 Re: [I] [Feature Request]: Commit failed: value exceeding byte limit - [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO]: Use @AutoService(RetryWithBackoff.class) to communicate what Exceptions signal retry with backoff [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO]: Use @AutoService(RetryWithBackoff.class) to communicate what Exceptions signal retry with backoff [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO] Add a @ThrowableImmediately annotation for UserCodeExecutionException subclasses that signal throw behavior [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO] Add a @ThrowableImmediately annotation for UserCodeExecutionException subclasses that signal throw behavior [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO]: New static RequestResponseIO instantiating methods to accept call, setup, teardown lambdas [beam] via GitHub
• 2026/03/23 Re: [I] [RRIO]: New static RequestResponseIO instantiating methods to accept call, setup, teardown lambdas [beam] via GitHub
• 2026/03/23 Re: [I] [Feature Request]: ElasticsearchIO Python SDK support [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Support Keras 3 in TFModelHandlers [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Support Keras 3 in TFModelHandlers [beam] via GitHub
• 2026/03/23 Re: [I] [Task]: Change sendState to handle state transition in a state machine [beam] via GitHub
• 2026/03/23 Re: [PR] Include logger name in FnApiLogRecordHandler log entries [beam] via GitHub

• Later messages