github

Messages by Date

2026/10/30 Re: [PR] [Python][RunInference] Report the model identifier to model handlers [beam] via GitHub
2026/10/30 [PR] [Python][RunInference] Report the model identifier to model handlers [beam] via GitHub
2026/10/30 [PR] [Java] Improve ProtoCoder decode error for raw Message type [beam] via GitHub
2026/10/30 Re: [PR] [Java] Improve ProtoCoder decode error for raw Message type [beam] via GitHub
2026/10/30 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.16 to 1.23.17 in /sdks [beam] via GitHub
2026/10/30 Re: [PR] [CI] Route BigQuery read tests by size [beam] via GitHub
2026/10/30 Re: [PR] [Python] Wait for AsyncWrapper work before teardown [beam] via GitHub
2026/10/30 Re: [PR] [YAML] Clean up BigQuery datasets when fixtures fail [beam] via GitHub
2026/10/30 Re: [PR] [Java] Avoid per-schema RowCoder class generation [beam] via GitHub
2026/10/30 Re: [PR] Cherrypick #40852 AddFiles: Dynamic destinations [beam] via GitHub
2026/10/30 [PR] [YAML] Fix WindowInto day duration parsing and ExtractWindowingInfo duplicate field check (#40902) [beam] via GitHub
2026/10/30 Re: [I] ProtoCoder <T extends Message> throws NoSuchMethodException: com.google.protobuf.Message.getDefaultInstance() [beam] via GitHub
2026/10/30 Re: [I] ProtoCoder <T extends Message> throws NoSuchMethodException: com.google.protobuf.Message.getDefaultInstance() [beam] via GitHub
2026/10/30 Re: [I] [Bug]: [YAML] WindowInto parses 'd' (days) as 12 hours instead of 24 hours, and ExtractWindowingInfo fails to detect duplicate schema fields [beam] via GitHub
2026/10/30 [I] [Bug]: [YAML] WindowInto parses 'd' (days) as 12 hours instead of 24 hours, and ExtractWindowingInfo fails to detect duplicate schema fields [beam] via GitHub
2026/10/30 Re: [PR] [yaml] fix documentation and tests for flags [beam] via GitHub
2026/10/30 Re: [PR] [CI] Avoid duplicate Python snapshot builds [beam] via GitHub
2026/10/30 Re: [PR] AddFiles: Dynamic destinations (#40852) [beam] via GitHub
2026/10/30 Re: [PR] [yaml] fix documentation and tests for flags [beam] via GitHub
2026/10/30 Re: [I] The PostCommit Python Dependency job is flaky [beam] via GitHub
2026/10/30 Re: [PR] AddFiles: Dynamic destinations (#40852) [beam] via GitHub
2026/10/30 Re: [I] [Bug]: ReadFromKafka YAML transform cannot specify JSON schema [beam] via GitHub
2026/10/30 Re: [PR] [yaml] fix documentation and tests for flags [beam] via GitHub
2026/10/30 Re: [PR] [Python] Add prefix-aware batching and capacity-based GPU autoscaling signal for vLLM RunInference [beam] via GitHub
2026/10/30 Re: [I] [Feature Request]: Support Protobuf 7.x in Python SDK [beam] via GitHub
2026/10/30 Re: [I] DoFn invocation has wrong argument assignment [beam] via GitHub
2026/10/30 [PR] Cherrypick #40892 Drop legacy options from HF Inference api [beam] via GitHub
2026/10/30 Re: [PR] Drop legacy options from HF Inference api [beam] via GitHub
2026/10/30 Re: [PR] AddFiles: Dynamic destinations (#40852) [beam] via GitHub
2026/10/30 Re: [PR] AddFiles: Dynamic destinations (#40852) [beam] via GitHub
2026/10/30 [PR] Cherrypick #40852 AddFiles: Dynamic destinations [beam] via GitHub
2026/10/30 Re: [PR] [Python] Support Protobuf 7.x [beam] via GitHub
2026/10/30 Re: [I] Python SDK harness logs from child processes missing correct portability_worker_id in Dataflow [beam] via GitHub
2026/10/30 Re: [I] [Bug]: IcebergIO write fails with "Null value set on non-nullable field keyMetadata" — @Nullable not detected in SerializableDataFile schema [beam] via GitHub
2026/10/30 Re: [PR] [Java] FirestoreIO: ramp up writes from a pipeline-wide start time [beam] via GitHub
2026/10/30 Re: [PR] [Python] Preserve argument binding for defaulted DoFn elements [beam] via GitHub
2026/10/30 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/30 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.10 to 1.20.11 in /sdks [beam] via GitHub
2026/10/30 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.10 to 1.20.11 in /sdks [beam] via GitHub
2026/10/30 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.10 to 1.33.11 in /sdks [beam] via GitHub
2026/10/30 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.10 to 1.33.11 in /sdks [beam] via GitHub
2026/10/30 Re: [PR] [Spanner Change Stream] Claim CreatedAt timestamp before scheduling partitions in DetectNewPartitionsAction [beam] via GitHub
2026/10/29 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.10 to 1.20.11 in /sdks [beam] via GitHub
2026/10/29 Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.1 to 2.15.2 in /sdks [beam] via GitHub
2026/10/29 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.16 to 1.23.17 in /sdks [beam] via GitHub
2026/10/29 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.10 to 1.33.11 in /sdks [beam] via GitHub
2026/10/29 Re: [PR] Bump google.golang.org/api from 0.308.0 to 0.309.0 in /sdks [beam] via GitHub
2026/10/29 [PR] Bump google.golang.org/api from 0.308.0 to 0.309.0 in /sdks [beam] via GitHub
2026/10/29 [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.10 to 1.20.11 in /sdks [beam] via GitHub
2026/10/29 [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.10 to 1.33.11 in /sdks [beam] via GitHub
2026/10/29 [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.16 to 1.23.17 in /sdks [beam] via GitHub
2026/10/29 [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.1 to 2.15.2 in /sdks [beam] via GitHub
2026/10/29 Re: [PR] Bump filelock from 3.32.3 to 4.2.1 in /sdks/python/container/ml/py313 [beam] via GitHub
2026/10/29 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
2026/10/29 Re: [PR] [YAML] Clean up BigQuery datasets when fixtures fail [beam] via GitHub
2026/10/29 Re: [PR] [CI] Avoid duplicate Python snapshot builds [beam] via GitHub
2026/10/29 Re: [I] [Feature Request]: Make lineage tracking pluggable [beam] via GitHub
2026/10/29 Re: [PR] [YAML] Clean up BigQuery datasets when fixtures fail [beam] via GitHub
2026/10/29 Re: [PR] [CI] Fix Go dependency cache path [beam] via GitHub
2026/10/29 Re: [PR] [CI] Avoid duplicate Python snapshot builds [beam] via GitHub
2026/10/29 Re: [PR] Bump httplib2 to 0.32.1 and remove distrusted eMudhra roots from Java cacerts [beam] via GitHub
2026/10/29 Re: [I] The PostCommit Python Dependency job is flaky [beam] via GitHub
2026/10/29 Re: [PR] Bump httplib2 to 0.32.1 and remove distrusted eMudhra roots from Java cacerts [beam] via GitHub
2026/10/29 Re: [PR] Bump vllm from 0.10.1.1 to 0.32.0 in /sdks/python/container/ml/py312 [beam] via GitHub
2026/10/29 [PR] Bump vllm from 0.10.1.1 to 0.32.0 in /sdks/python/container/ml/py312 [beam] via GitHub
2026/10/29 Re: [PR] Bump vllm from 0.10.1.1 to 0.32.0 in /sdks/python/container/ml/py312 [beam] via GitHub
2026/10/29 Re: [PR] Drop legacy options from HF Inference api [beam] via GitHub
2026/10/29 Re: [PR] Drop legacy options from HF Inference api [beam] via GitHub
2026/10/29 [PR] Drop legacy options from HF Inference api [beam] via GitHub
2026/10/29 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/29 Re: [PR] [Python] Merge runtime type-check wrappers [beam] via GitHub
2026/10/29 Re: [PR] update pr review code flow when assigning reviewer ahead of bot [beam] via GitHub
2026/10/29 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
2026/10/29 [I] [Feature Request] : Add an experimental beam command to the Python SDK [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update container CA dependencies and remove distrusted eMudhra roots (#40811, #40889) [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update container CA dependencies and remove distrusted eMudhra roots (#40811, #40889) [beam] via GitHub
2026/10/29 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/29 Re: [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/29 Re: [PR] [Spanner Change Stream] Claim CreatedAt timestamp before scheduling partitions in DetectNewPartitionsAction [beam] via GitHub
2026/10/29 [PR] Bump filelock from 3.32.3 to 4.2.1 in /sdks/python/container/ml/py313 [beam] via GitHub
2026/10/29 Re: [PR] [IcebergIO] Ensure compliance with table encryption [beam] via GitHub
2026/10/29 Re: [PR] Register _FilteringIterable as an iterable-like type. [beam] via GitHub
2026/10/29 Re: [PR] [Python] Support Protobuf 7.x [beam] via GitHub
2026/10/29 Re: [PR] [Iceberg] Merge on read fixes [beam] via GitHub
2026/10/29 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
2026/10/29 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/29 Re: [PR] Stable code identifier pickling [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update container CA dependencies and remove distrusted eMudhra roots (#40811, #40889) [beam] via GitHub
2026/10/29 Re: [PR] Support Environment Sensitive Staging [beam] via GitHub
2026/10/29 Re: [PR] Bump httplib2 to 0.32.1 and remove distrusted eMudhra roots from Java cacerts [beam] via GitHub
2026/10/29 Re: [PR] Support pandas 3+ in the dataframes API (#40709) [beam] via GitHub
2026/10/29 Re: [I] [Feature Request]: Support pandas 3+ in the dataframes API [beam] via GitHub
2026/10/29 [PR] Bump httplib2 to 0.32.1 and remove distrusted eMudhra roots from Java cacerts [beam] via GitHub
2026/10/29 [PR] [Cherrypick] Update container CA dependencies and remove distrusted eMudhra roots (#40811, #40889) [beam] via GitHub
2026/10/29 Re: [PR] [Iceberg] Make streaming metadata assertions deterministic [beam] via GitHub
2026/10/29 Re: [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 Re: [PR] [Spanner Change Stream] Claim CreatedAt timestamp before scheduling partitions in DetectNewPartitionsAction [beam] via GitHub
2026/10/29 Re: [PR] [Java] Bound pending Watch results per poll [beam] via GitHub
2026/10/29 Re: [PR] Add Bigtable CDC YAML SchemaTransform [beam] via GitHub
2026/10/29 Re: [PR] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/29 Re: [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/29 Re: [I] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 Re: [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/29 Re: [PR] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/29 Re: [PR] Register _FilteringIterable as an iterable-like type. [beam] via GitHub
2026/10/29 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
2026/10/29 Re: [PR] [Prism] Hold time sorted input until the allowed lateness has passed [beam] via GitHub
2026/10/29 Re: [PR] Stable code identifier pickling [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 [PR] Register _FilteringIterable as an iterable-like type. [beam] via GitHub
2026/10/29 Re: [I] [Feature Request]: Provide option in ReadFromBigQuery to set project from which queries are executed/billed [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update ONNX extras (#40821) [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update ONNX extras (#40821) [beam] via GitHub
2026/10/29 [PR] [Spanner Change Stream] Use inclusive CreatedAt filter for partition discovery on split boundaries [beam] via GitHub
2026/10/29 Re: [PR] Update Python container CA dependencies and distroless base images to debian13 [beam] via GitHub
2026/10/29 Re: [PR] [Python] Add Qdrant search enrichment handler [beam] via GitHub
2026/10/29 Re: [PR] [Cherrypick] Update ONNX extras (#40821) [beam] via GitHub
2026/10/29 Re: [PR] [Spanner Change Stream] Claim CreatedAt timestamp before scheduling partitions in DetectNewPartitionsAction [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 Re: [PR] Stable code identifier pickling [beam] via GitHub
2026/10/29 Re: [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 Re: [PR] [Prism] Hold time sorted input until the allowed lateness has passed [beam] via GitHub
2026/10/29 [PR] [Prism] Hold time sorted input until the allowed lateness has passed [beam] via GitHub
2026/10/29 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
2026/10/29 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/29 Re: [PR] AddFiles: Dynamic destinations [beam] via GitHub
2026/10/29 Re: [PR] Bump filelock from 3.32.3 to 4.2.1 in /sdks/python/container/ml/py313 [beam] via GitHub
2026/10/29 Re: [PR] Bump filelock from 3.32.3 to 4.2.1 in /sdks/python/container/ml/py313 [beam] via GitHub
2026/10/29 Re: [PR] Bump vllm from 0.10.1.1 to 0.32.0 in /sdks/python/container/ml/py312 [beam] via GitHub
2026/10/29 Re: [PR] Bump vllm from 0.10.1.1 to 0.32.0 in /sdks/python/container/ml/py312 [beam] via GitHub
2026/10/29 [PR] [yaml] add pubsub to splunk e2e and example tests [beam] via GitHub
2026/10/29 [PR] [Cherrypick] Update ONNX extras (#40821) [beam] via GitHub
2026/10/29 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
2026/10/29 Re: [PR] [Experimental] Update ONNX extras [beam] via GitHub
2026/10/29 Re: [I] [Feature Request]: Make lineage tracking pluggable [beam] via GitHub
2026/10/29 Re: [PR] [Java] Bound pending Watch results per poll [beam] via GitHub
2026/10/29 Re: [PR] [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup [beam] via GitHub
2026/10/29 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/29 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
2026/10/29 Re: [I] [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag [beam] via GitHub
2026/10/29 [PR] [Python] Add Vespa write config for ml.rag ingestion (prototype) [beam] via GitHub
2026/10/29 Re: [PR] Updates Delta CDC read to fail when schemas... (#40868) [beam] via GitHub
2026/10/28 Re: [PR] [Go SDK] Make pipelinex.computeRoots and xlangx.HandlerParams ordering deterministic [beam] via GitHub
2026/10/28 Re: [PR] [Go SDK] Make pipelinex.computeRoots and xlangx.HandlerParams ordering deterministic [beam] via GitHub
2026/10/28 [PR] [Go SDK] Make pipelinex.computeRoots and xlangx.HandlerParams ordering deterministic [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] [Spanner Change Stream] Make InitializeDoFn fake parent partition creation idempotent [beam] via GitHub
2026/10/28 Re: [I] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub
2026/10/28 Re: [PR] Remove twister2 runner support [beam] via GitHub
2026/10/28 Re: [PR] Optimize Row construction, RowWithGetters field caching, and Row utilities [beam] via GitHub
2026/10/28 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/28 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [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: [I] [Feature Request]: AddFiles dynamic destinations support [beam] via GitHub
2026/10/28 Re: [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/28 [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/28 Re: [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/28 Re: [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/28 Re: [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/28 Re: [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/28 Re: [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/28 [PR] [Model] Document finishing triggers and closed windows [beam] via GitHub
2026/10/28 [PR] [Prism] Drop elements for windows whose trigger has finished [beam] via GitHub
2026/10/28 Re: [I] [Spark] Structured streaming runner: asynchronous cancel() should not report CANCELLED before the execution ended [beam] via GitHub
2026/10/28 Re: [PR] Updates Delta CDC read to fail when schemas... (#40868) [beam] via GitHub
2026/10/28 Re: [PR] Updates Delta CDC read to fail when schemas... (#40868) [beam] via GitHub
2026/10/28 Re: [PR] [Twister2] Run local validation methods sequentially [beam] via GitHub
2026/10/28 Re: [PR] [Twister2] Run local validation methods sequentially [beam] via GitHub
2026/10/28 Re: [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 [PR] Updates Delta CDC read to fail when schemas... (#40868) [beam] via GitHub
2026/10/28 Re: [PR] Support Environment Sensitive Staging [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 [PR] Keep Ctrl+C working in the SQL shell after multi-line statements [beam] via GitHub
2026/10/28 Re: [PR] Keep Ctrl+C working in the SQL shell after multi-line statements [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] Keep Ctrl+C working in the SQL shell after multi-line statements [beam] via GitHub
2026/10/28 Re: [PR] Fix IcebergIO rejecting timestamp strings with a space separator [beam] via GitHub
2026/10/28 Re: [PR] [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output [beam] via GitHub
2026/10/28 Re: [PR] [Experimental] Update ONNX extras [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] Port BigQueryIOWriteTest off DoFnTester [beam] via GitHub
2026/10/28 Re: [I] [Feature Request]: Expand the info provided in Beam Python's heap dump [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] [Experimental] Update ONNX extras [beam] via GitHub
2026/10/28 Re: [I] [Feature Request]: Expand the info provided in Beam Python's heap dump [beam] via GitHub
2026/10/28 Re: [PR] Updates Delta CDC read to fail when schemas are different at... [beam] via GitHub
2026/10/28 Re: [PR] Remove twister2 runner support [beam] via GitHub
2026/10/28 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
2026/10/28 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
2026/10/28 [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
2026/10/28 Re: [PR] [RunInference] Import resource independently of ModelManager [beam] via GitHub
2026/10/28 [PR] Bump nltk from 3.10.3 to 3.10.4 in /sdks/python/container/py313 [beam] via GitHub
2026/10/28 Re: [PR] Fixes some bugs with GroupIntoBatches. [beam] via GitHub
2026/10/28 Re: [PR] [#36841] Spark 4 streaming: Impulse, bounded reads and PAssert on the Structured Streaming runner [beam] via GitHub
2026/10/28 Re: [PR] Port SplittableParDoProcessFnTest off DoFnTester [beam] via GitHub