github  

Messages by Date

• 2026/10/27 Re: [PR] [Solace] Fix flaky SolaceIO integration tests [beam] via GitHub
• 2026/10/27 Re: [PR] AddFiles: Wire a destination-table key through the registration chain [beam] via GitHub
• 2026/10/27 Re: [PR] Managed Iceberg AddFiles [beam] via GitHub
• 2026/10/27 Re: [PR] AddFiles: Wire a destination-table key through the registration chain [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Row equality/hashing, RowUtils validation and ByteBuffer handling, and LogicalTypeCoder DATETIME conversion [beam] via GitHub
• 2026/10/27 Re: [PR] AddFiles: Wire a destination-table key through the registration chain [beam] via GitHub
• 2026/10/27 [PR] [Python] Handle translated Azure missing-blob errors in exists [beam] via GitHub
• 2026/10/27 [PR] Fix HF Inference API test model [beam] via GitHub
• 2026/10/27 Re: [PR] [Java] Preserve BigQuery failed rows across retries [beam] via GitHub
• 2026/10/27 Re: [PR] [Java] Preserve BigQuery failed rows across retries [beam] via GitHub
• 2026/10/27 Re: [PR] [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors [beam] via GitHub
• 2026/10/27 Re: [PR] Fixes some bugs in WindmillMapViaMultimap. [beam] via GitHub
• 2026/10/27 Re: [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
• 2026/10/27 Re: [PR] Fixes some bugs in WindmillMapViaMultimap. [beam] via GitHub
• 2026/10/27 Re: [PR] [#18690] Port SolrIOTest off deprecated DoFnTester [beam] via GitHub
• 2026/10/27 Re: [PR] [#18690] Port SolrIOTest off deprecated DoFnTester [beam] via GitHub
• 2026/10/27 Re: [I] [Bug]: DeferredSeries.duplicated() raises WontImplementError due to incorrect column indexing [beam] via GitHub
• 2026/10/27 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] via GitHub
• 2026/10/27 Re: [PR] [KafkaIO] Remove obsolete ConsumerSpEL and ProducerSpEL reflection shims [beam] via GitHub
• 2026/10/27 Re: [PR] [Java] BigQueryIO: set table labels from dynamic destinations [beam] via GitHub
• 2026/10/27 Re: [PR] update beam dev sdk container tag to 20261026 [beam] via GitHub
• 2026/10/27 Re: [PR] Beam SQL: name query composites after what was fused into them [beam] via GitHub
• 2026/10/27 [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 Re: [PR] [Flink] Reshuffle batch inputs round-robin from deterministic start channels [beam] via GitHub
• 2026/10/27 Re: [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 [PR] [Java] BigQueryIO: set table labels from dynamic destinations [beam] via GitHub
• 2026/10/27 Re: [PR] [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors [beam] via GitHub
• 2026/10/27 Re: [I] [Bug]: UNNEST ARRAY with a nested ROW (described below) [beam] via GitHub
• 2026/10/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.9 to 1.33.10 in /sdks [beam] via GitHub
• 2026/10/27 Re: [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
• 2026/10/27 Re: [I] [Failing Test]: testE2EBigtableWriteWith[...]Failures flaky [beam] via GitHub
• 2026/10/27 Re: [PR] [Flink] Re-split and balance bounded source splits in batch [beam] via GitHub
• 2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
• 2026/10/27 Re: [PR] Log systemname 2 cache [beam] via GitHub
• 2026/10/27 Re: [I] [Failing Test]: testE2EBigtableWriteWith[...]Failures flaky [beam] via GitHub
• 2026/10/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.114.3 to 1.114.5 in /sdks [beam] via GitHub
• 2026/10/27 Re: [I] [Bug]: StrUtf8Coder in Python can't deserialize what's encoded with Java StringUtf8Coder [beam] via GitHub
• 2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
• 2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
• 2026/10/27 Re: [I] [Failing Test]: testE2EBigtableWriteWith[...]Failures flaky [beam] via GitHub
• 2026/10/27 Re: [PR] [Java fn-execution] Drain bundle output before waiting for the ProcessBundleResponse [beam] via GitHub
• 2026/10/27 Re: [I] [Bug]: Portable Java runners deadlock when one bundle's output exceeds ~1 GB (regression in 2.77 from #38407) [beam] via GitHub
• 2026/10/27 Re: [PR] [Java fn-execution] Drain bundle output before waiting for the ProcessBundleResponse [beam] via GitHub
• 2026/10/27 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/27 Re: [PR] [CI] Use Python 3.11 in the vLLM benchmark image [beam] via GitHub
• 2026/10/27 Re: [PR] Bump cloud.google.com/go/pubsub/v2 from 2.7.0 to 2.8.0 in /sdks [beam] via GitHub
• 2026/10/27 Re: [PR] Fixes some bugs in WindmillMapViaMultimap. [beam] via GitHub
• 2026/10/27 [PR] [KafkaIO] Remove obsolete ConsumerSpEL and ProducerSpEL reflection shims [beam] via GitHub
• 2026/10/27 Re: [PR] [Java] ParquetIO: resolve file records against the read schema [beam] via GitHub
• 2026/10/27 Re: [I] [Bug]: UNNEST ARRAY with a nested ROW (described below) [beam] via GitHub
• 2026/10/27 Re: [PR] Add retries and timeout to Grafana request in flaky test detection [beam] via GitHub
• 2026/10/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.14 to 1.23.16 in /sdks [beam] via GitHub
• 2026/10/27 Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks [beam] via GitHub
• 2026/10/27 Re: [PR] [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 Re: [PR] [FileWrites] Allow maxNumWritersPerBundle to exceed DEFAULT_MAX_NUM_WRITERS_PER_BUNDLE (20) [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 Re: [PR] [KafkaIO] Remove obsolete ConsumerSpEL and ProducerSpEL reflection shims [beam] via GitHub
• 2026/10/27 Re: [PR] [KafkaIO] Use UnsignedLong for backlog calculation [beam] via GitHub
• 2026/10/27 Re: [PR] Fix Beam SQL UNNEST of array elements with a nested row through JDBC [beam] via GitHub
• 2026/10/27 [PR] [FileWrites] Allow maxNumWritersPerBundle to exceed DEFAULT_MAX_NUM_WRITERS_PER_BUNDLE (20) [beam] via GitHub
• 2026/10/27 [PR] [KafkaIO] Use UnsignedLong for backlog calculation [beam] via GitHub
• 2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
• 2026/10/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.114.3 to 1.114.5 in /sdks [beam] via GitHub
• 2026/10/27 Re: [I] The PreCommit Java Solace IO Direct job is flaky [beam] via GitHub
• 2026/10/27 Re: [PR] [Python] Restore legacy TensorFlow dependency tests [beam] via GitHub
• 2026/10/27 Re: [PR] [InfluxDB] Wait for HTTP readiness before integration tests [beam] via GitHub
• 2026/10/27 Re: [PR] Fix PreCommit Java Solace IO Direct workflow [beam] via GitHub
• 2026/10/27 Re: [PR] Fix PreCommit Java Solace IO Direct workflow [beam] via GitHub
• 2026/10/27 [PR] [CI] Use Python 3.11 in the vLLM benchmark image [beam] via GitHub
• 2026/10/26 [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
• 2026/10/26 Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• 2026/10/26 [PR] Bump cloud.google.com/go/pubsub/v2 from 2.7.0 to 2.8.0 in /sdks [beam] via GitHub
• 2026/10/26 [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.114.3 to 1.114.5 in /sdks [beam] via GitHub
• 2026/10/26 [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.14 to 1.23.16 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [PR] Bump github.com/nats-io/nats.go from 1.54.0 to 1.55.0 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.14 to 1.23.16 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.9 to 1.33.10 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] Bump github.com/nats-io/nats.go from 1.54.0 to 1.55.0 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] Bump cloud.google.com/go/pubsub/v2 from 2.7.0 to 2.8.0 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• 2026/10/26 Re: [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
• 2026/10/26 [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.9 to 1.33.10 in /sdks [beam] via GitHub
• 2026/10/26 [PR] Bump github.com/nats-io/nats.go from 1.54.0 to 1.55.0 in /sdks [beam] via GitHub
• 2026/10/26 Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• 2026/10/26 Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• 2026/10/26 Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: Wire a destination-table key through the registration chain [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: Wire a destination-table key through the registration chain [beam] via GitHub
• 2026/10/26 Re: [PR] update beam dev sdk container tag to 20261026 [beam] via GitHub
• 2026/10/26 Re: [PR] udpate beam dev sdk container tag to 20261026 [beam] via GitHub
• 2026/10/26 Re: [PR] Managed Iceberg AddFiles [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 Re: [PR] Adds drain support to Spanner CDC source. [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
• 2026/10/26 [PR] udpate beam dev sdk container tag to 20261026 [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
• 2026/10/26 Re: [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 Re: [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 Re: [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
• 2026/10/26 Re: [PR] Managed Iceberg AddFiles [beam] via GitHub
• 2026/10/26 [I] [Task]: Publicize new Iceberg CDC features [beam] via GitHub
• 2026/10/26 [I] [Task]: Achieve v3 compliance for IcebergIO [beam] via GitHub
• 2026/10/26 Re: [PR] Managed Iceberg AddFiles [beam] via GitHub
• 2026/10/26 [I] [Task]: Support CDC use cases in Beam SQL [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 [PR] Managed Iceberg AddFiles [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve data channel failure causes [beam] via GitHub
• 2026/10/26 Re: [PR] Beam SQL Primary Keys [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 Re: [PR] Beam SQL Primary Keys [beam] via GitHub
• 2026/10/26 Re: [PR] Beam SQL Primary Keys [beam] via GitHub
• 2026/10/26 Re: [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 Re: [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 [PR] Beam SQL Primary Keys [beam] via GitHub
• 2026/10/26 Re: [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] [Java] Set job location when cleaning up BigQueryIO export reads [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [I] [Bug][Prism]: Expired aggregation input survives while later-window work holds output [beam] via GitHub
• 2026/10/26 Re: [PR] [Prism] Drop expired aggregation input using upstream watermark [beam] via GitHub
• 2026/10/26 Re: [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] update numpy to be conditional on python version [beam] via GitHub
• 2026/10/26 Re: [PR] Adds drain support to Spanner CDC source. [beam] via GitHub
• 2026/10/26 Re: [PR] Adds drain support to Spanner CDC source. [beam] via GitHub
• 2026/10/26 [PR] Fix silent data truncation when mutating partially-cached StateIterables [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs in StateFetchingIterators. [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs in StateFetchingIterators. [beam] via GitHub
• 2026/10/26 [PR] Update Python container CA dependencies and distroless base images to debian13 [beam] via GitHub
• 2026/10/26 Re: [PR] update numpy to be conditional on python version [beam] via GitHub
• 2026/10/26 Re: [PR] update numpy to be conditional on python version [beam] via GitHub
• 2026/10/26 Re: [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] update numpy to be conditional on python version [beam] via GitHub
• 2026/10/26 [PR] update numpy to be conditional on python version [beam] via GitHub
• 2026/10/26 [PR] Set firm upper bound on Python 3.11 numpy [beam] via GitHub
• 2026/10/26 Re: [PR] AddFiles: PathPattern and RouteFiles [beam] via GitHub
• 2026/10/26 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] via GitHub
• 2026/10/26 Re: [PR] [IcebergIO] Support sorted writes and RANGE distribution mode [beam] via GitHub
• 2026/10/26 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Only give an unknown option a value that directly follows it [beam] via GitHub
• 2026/10/26 Re: [PR] [Prism] Drop expired aggregation input using upstream watermark [beam] via GitHub
• 2026/10/26 Re: [PR] Fix Clean Up GCP Resources workflow [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Do not fail type checks on Protocol type hints [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes a bug in WindmillSet.addIfAbsent. [beam] via GitHub
• 2026/10/26 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Do not fail type checks on Protocol type hints [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Do not fail type checks on Protocol type hints [beam] via GitHub
• 2026/10/26 Re: [PR] [Solace] Fix flaky SolaceIO integration tests [beam] via GitHub
• 2026/10/26 [PR] Fix Clean Up GCP Resources workflow [beam] via GitHub
• 2026/10/26 Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• 2026/10/26 Re: [PR] [IcebergIO] Support sorted writes and RANGE distribution mode [beam] via GitHub
• 2026/10/26 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
• 2026/10/26 Re: [PR] [yaml] fix documentation and tests for flags [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
• 2026/10/26 [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] via GitHub
• 2026/10/26 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
• 2026/10/26 Re: [PR] Rename TestRecord [beam] via GitHub
• 2026/10/26 [PR] [Experimental] Update ONNX extras [beam] via GitHub
• 2026/10/26 Re: [PR] Update Python container CA dependencies and distroless base images to debian13 [beam] via GitHub
• 2026/10/26 Re: [PR] [Prism] Drop expired aggregation input using upstream watermark [beam] via GitHub
• 2026/10/26 Re: [PR] [#18690] Port SolrIOTest off deprecated DoFnTester [beam] via GitHub
• 2026/10/26 Re: [PR] [#18690] Port SolrIOTest off deprecated DoFnTester [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 Re: [PR] [Go SDK] Fix generic registration of anonymous struct types [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
• 2026/10/26 Re: [PR] Update Python container CA dependencies and distroless base images to debian13 [beam] via GitHub
• 2026/10/26 Re: [PR] Fix correctness issue in JsonToRow, RowJsonDeserializer and RowJsonSerializer [beam] via GitHub
• 2026/10/26 [PR] [Prism] Drop expired aggregation input using upstream watermark [beam] via GitHub
• 2026/10/26 Re: [PR] Fixes some bugs in WindmillMapViaMultimap. [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve data channel failure causes [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 [PR] [#18690] Port SolrIOTest off deprecated DoFnTester [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
• 2026/10/26 Re: [I] Port SolrIOTest off DoFnTester [beam] via GitHub
• 2026/10/26 Re: [PR] Update tensorflow dependencies [beam] via GitHub
• 2026/10/26 Re: [PR] Fix PreCommit Java Solace IO Direct workflow [beam] via GitHub
• 2026/10/26 Re: [PR] Resolve staged sklearn model path on the worker in RunInference xlang tests [beam] via GitHub
• 2026/10/26 [PR] Fix PreCommit Java Solace IO Direct workflow [beam] via GitHub
• 2026/10/26 Re: [I] Port SolrIOTest off DoFnTester [beam] via GitHub
• 2026/10/26 Re: [PR] [Java] Honor non-default universe domains in GcsUtilV2 [beam] via GitHub
• 2026/10/26 [I] [Bug][Prism]: Expired aggregation input survives while later-window work holds output [beam] via GitHub

• Earlier messages
• Later messages