github

Messages by Date

2026/10/28 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/28 Re: [PR] [InfluxDB] Wait for HTTP readiness before integration tests [beam] via GitHub
2026/10/28 [PR] Remove twister2 runner support [beam] via GitHub
2026/10/28 Re: [PR] Bump dnspython from 2.8.0 to 2.9.0 in /sdks/python/container/py314 [beam] via GitHub
2026/10/28 Re: [PR] Bump dnspython from 2.8.0 to 2.9.0 in /sdks/python/container/py314 [beam] via GitHub
2026/10/28 Re: [PR] Bump pymongo from 4.17.0 to 4.18.3 in /sdks/python/container/py314 [beam] via GitHub
2026/10/28 Re: [PR] Bump nltk from 3.10.3 to 3.10.4 in /sdks/python/container/py313 [beam] via GitHub
2026/10/28 Re: [PR] Remove twister2 runner support [beam] via GitHub
2026/10/28 [PR] Bump dnspython from 2.8.0 to 2.9.0 in /sdks/python/container/py314 [beam] via GitHub
2026/10/28 [PR] Bump pymongo from 4.17.0 to 4.18.3 in /sdks/python/container/py314 [beam] via GitHub
2026/10/28 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
2026/10/28 [PR] Port BigQueryIOWriteTest off DoFnTester [beam] via GitHub
2026/10/28 Re: [I] [Feature Request]: Expose page traffic and PR review metrics for the Beam community [beam] via GitHub
2026/10/28 Re: [I] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/28 Re: [I] [Task]: Deprecate Twister2 runner [beam] via GitHub
2026/10/28 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
2026/10/28 Re: [PR] Port DatastoreV1Test off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
2026/10/28 Re: [PR] Fix HF Inference API test model [beam] via GitHub
2026/10/28 Re: [PR] [YAML] Add SplunkIO write SchemaTransform and WriteToSplunk [beam] via GitHub
2026/10/28 Re: [I] Port BigQueryIOWriteTest off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] [YAML] Add SplunkIO write SchemaTransform and WriteToSplunk [beam] via GitHub
2026/10/28 Re: [PR] [Iceberg] Merge on read fixes [beam] via GitHub
2026/10/28 [PR] [Spanner Change Stream] Claim CreatedAt timestamp before scheduling partitions in DetectNewPartitionsAction [beam] via GitHub
2026/10/28 Re: [PR] Remove twister2 runner support [beam] via GitHub
2026/10/28 Re: [PR] [CI] Run the 1 TB BigQuery read in a daily scale job [beam] via GitHub
2026/10/28 Re: [PR] Add retries and timeout to Grafana request in flaky test detection [beam] via GitHub
2026/10/28 Re: [PR] AddFiles: widen a promoted column's bound to the table type's width [beam] via GitHub
2026/10/28 [PR] Updates Delta CDC read to fail when schemas are different at... [beam] via GitHub
2026/10/28 Re: [I] [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match [beam] via GitHub
2026/10/28 Re: [PR] [Twister2] Run local validation methods sequentially [beam] via GitHub
2026/10/28 Re: [PR] [Spark] Resolve the structured streaming pipeline state from the execution, cancel() returns the observed state [beam] via GitHub
2026/10/28 Re: [PR] AddFiles: widen a promoted column's bound to the table type's width [beam] via GitHub
2026/10/28 Re: [I] The PostCommit Python Dependency job is flaky [beam] via GitHub
2026/10/28 Re: [PR] Prevent Fn data plane deadlock via non-blocking CancellableQueue.add and gRPC inbound flow control [beam] via GitHub
2026/10/28 Re: [I] [Task]: Add perf tests [beam] via GitHub
2026/10/28 Re: [I] [Feature Request]: AddFiles dynamic destinations support [beam] via GitHub
2026/10/28 Re: [I] [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match [beam] via GitHub
2026/10/28 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
2026/10/28 Re: [I] Port DatastoreV1Test off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] Port DatastoreV1Test off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] Port DatastoreV1Test off DoFnTester [beam] via GitHub
2026/10/28 [PR] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/28 [PR] Port DatastoreV1Test off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] [Dataflow Java] Extend work item lease while DoFn.setup runs in batch worker [beam] via GitHub
2026/10/27 Re: [PR] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/27 Re: [I] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/27 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 [PR] [Twister2] Run local validation methods sequentially [beam] via GitHub
2026/10/27 [PR] [YAML] Clean up BigQuery datasets when fixtures fail [beam] via GitHub
2026/10/27 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 Re: [I] [Bug]: IcebergIO rejects timestamp strings with a space between date and time [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 [PR] [DirectRunner] Reuse ParDo metadata between bundles [beam] via GitHub
2026/10/27 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
2026/10/27 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/27 Re: [I] [Bug]: IcebergIO rejects timestamp strings with a space between date and time [beam] via GitHub
2026/10/27 Re: [PR] [Experimental] Move pinned pip in setupVirtualenv to 26.2.2 [beam] via GitHub
2026/10/27 [I] [Bug]: IcebergIO rejects timestamp strings with a space between date and time [beam] via GitHub
2026/10/27 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/27 [PR] [Go] Verify expansion service readiness before use [beam] via GitHub
2026/10/27 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/27 Re: [PR] [CI] Run the 1 TB BigQuery read in a daily scale job [beam] via GitHub
2026/10/27 [PR] [CI] Run the 1 TB BigQuery read in a daily scale job [beam] via GitHub
2026/10/27 Re: [PR] [Experimental] Move pinned pip in setupVirtualenv to 26.2.2 [beam] via GitHub
2026/10/27 [PR] [JDBC] Make autosharding test inserts idempotent [beam] via GitHub
2026/10/27 [PR] [CI] Avoid duplicate Python snapshot builds [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 Re: [I] [Bug]: RunInference reports 0 for model memory when torch isn't installed (`resource` import is coupled to the `ModelManager` import) [beam] via GitHub
2026/10/27 [I] [Bug]: RunInference reports 0 for model memory when torch isn't installed (`resource` import is coupled to the `ModelManager` import) [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 Re: [PR] Move quota_project_id [beam] via GitHub
2026/10/27 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/27 Re: [PR] Managed Iceberg AddFiles [beam] via GitHub
2026/10/27 Re: [PR] Move quota_project_id [beam] via GitHub
2026/10/27 Re: [PR] [Experimental] Move pinned pip in setupVirtualenv to 26.2.2 [beam] via GitHub
2026/10/27 [I] [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match [beam] via GitHub
2026/10/27 [PR] Move quota_project_id [beam] via GitHub
2026/10/27 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
2026/10/27 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
2026/10/27 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
2026/10/27 Re: [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] via GitHub
2026/10/27 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/27 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/27 Re: [PR] Addfiles dynamic dest4 [beam] via GitHub
2026/10/27 Re: [PR] Move quota_project_id [beam] via GitHub
2026/10/27 Re: [PR] Stable code identifier pickling [beam] via GitHub
2026/10/27 [PR] Addfiles dynamic dest4 [beam] via GitHub
2026/10/27 Re: [PR] [Java] BigQueryIO: set table labels from dynamic destinations [beam] via GitHub
2026/10/27 Re: [PR] Move quota_project_id [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] [python] - update deferredSeries.duplicated logic [beam] via GitHub
2026/10/27 [PR] [Dataflow Java] Extend work item lease while DoFn.setup runs in batch worker [beam] via GitHub
2026/10/27 Re: [PR] Fix HF Inference API test model [beam] via GitHub
2026/10/27 Re: [PR] Add WITH clause to Beam SQL to set connector properties [beam] via GitHub
2026/10/27 Re: [PR] [python] - update deferredSeries.duplicated logic [beam] via GitHub
2026/10/27 [I] [Feature Request]: AddFiles dynamic destinations support [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] [Java] Preserve BigQuery failed rows across retries [beam] via GitHub
2026/10/27 Re: [PR] Add WITH clause to Beam SQL to set connector properties [beam] via GitHub
2026/10/27 Re: [PR] Fix HF Inference API test model [beam] via GitHub
2026/10/27 Re: [PR] Add WITH clause to Beam SQL to set connector properties [beam] via GitHub
2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
2026/10/27 [PR] [Experimental] Move pinned pip in setupVirtualenv to 26.2.2 [beam] via GitHub
2026/10/27 Re: [PR] [Spanner Change Stream] Fix Change Streams PostgreSQL metadata queries [beam] via GitHub
2026/10/27 [PR] Add WITH clause to Beam SQL to set connector properties [beam] via GitHub
2026/10/27 Re: [PR] [python] - update deferredSeries.duplicated logic [beam] via GitHub
2026/10/27 [PR] [python] - update deferredSeries.duplicated logic [beam] via GitHub
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