github  

Messages by Date

• 2026/10/20 Re: [PR] [Python] Infer the right type for slices of fixed-size tuples [beam] via GitHub
• 2026/10/20 Re: [PR] Trigger BQ CDC IT. Fix impl [beam] via GitHub
• 2026/10/20 Re: [PR] [Python] Support custom BigQuery endpoints and universe domains [beam] via GitHub
• 2026/10/20 Re: [PR] [Java] Honor GOOGLE_CLOUD_UNIVERSE_DOMAIN for the Dataflow endpoint [beam] via GitHub
• 2026/10/20 Re: [PR] Trigger BQ CDC IT. Fix impl [beam] via GitHub
• 2026/10/20 Re: [PR] [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 [beam] via GitHub
• 2026/10/20 Re: [PR] Fix Release Nightly Snapshot job [beam] via GitHub
• 2026/10/20 Re: [PR] Upgrade google-api-client to 2.7.2 and use bomupgrade to manage [beam] via GitHub
• 2026/10/20 Re: [PR] Fix SpannerIO PerformanceTests workflows [beam] via GitHub
• 2026/10/20 Re: [I] The Release Nightly Snapshot job is flaky [beam] via GitHub
• 2026/10/20 [PR] Fix Release Nightly Snapshot job [beam] via GitHub
• 2026/10/20 Re: [PR] [Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo [beam] via GitHub
• 2026/10/20 Re: [PR] Fix SpannerIO PerformanceTests workflows [beam] via GitHub
• 2026/10/20 Re: [I] [Task]: Implement BeamFileSystemClient [beam] via GitHub
• 2026/10/20 Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
• 2026/10/20 Re: [I] [Feature Request]: Support for efficient serialization of more built-in types [beam] via GitHub
• 2026/10/20 Re: [I] [Task]: Remove hadoop-common pin from expansion service and Iceberg modules [beam] via GitHub
• 2026/10/20 Re: [PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam] via GitHub
• 2026/10/20 Re: [PR] [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup [beam] via GitHub
• 2026/10/20 [PR] Fix SpannerIO PerformanceTests workflows [beam] via GitHub
• 2026/10/20 Re: [PR] Bump distlib from 0.4.3 to 0.4.4 in /sdks/python [beam] via GitHub
• 2026/10/20 Re: [I] [Bug]: Tour of Beam Firebase Authentication fails with API key expired error [beam] via GitHub
• 2026/10/20 Re: [I] [Bug]: Tour of Beam Firebase Authentication fails with API key expired error [beam] via GitHub
• 2026/10/20 Re: [PR] Update api key for tour of beam [beam] via GitHub
• 2026/10/20 Re: [PR] [#40644][Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful and keyed RunInference batching [beam] via GitHub
• 2026/10/20 Re: [PR] [#40644][Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful and keyed RunInference batching [beam] via GitHub
• 2026/10/20 Re: [I] The Flaky test detection job is flaky [beam] via GitHub
• 2026/10/20 Re: [I] The Flaky test detection job is flaky [beam] via GitHub
• 2026/10/20 [PR] [#40644][Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful and keyed RunInference batching [beam] via GitHub
• 2026/10/20 Re: [I] [Bug]: [RunInference] Pipelines using ModelHandlers with max_batch_weight fail at construction time [beam] via GitHub
• 2026/10/20 Re: [PR] Adds bytes read reporting for SDF. [beam] via GitHub
• 2026/10/20 Re: [I] [Bug]: [RunInference] Pipelines using ModelHandlers with max_batch_weight fail at construction time [beam] via GitHub
• 2026/10/20 Re: [I] Upgrade DebeziumIO to Debezium 3.5.2.Final [beam] via GitHub
• 2026/10/20 Re: [PR] [Python] Infer the right type for slices of fixed-size tuples [beam] via GitHub
• 2026/10/20 [PR] [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 [beam] via GitHub
• 2026/10/20 Re: [PR] [Python] Accept int tags on Partition results applied to a list [beam] via GitHub
• 2026/10/20 Re: [I] _MaterializedDoOutputsTuple doesn't support __getitem__ by integer values [beam] via GitHub
• 2026/10/20 [PR] [Python] Accept int tags on Partition results applied to a list [beam] via GitHub
• 2026/10/20 Re: [PR] [Python] Infer the right type for slices of fixed-size tuples [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Accept int tags on Partition results applied to a list [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 [beam] via GitHub
• 2026/10/19 [PR] [Python] Infer the right type for slices of fixed-size tuples [beam] via GitHub
• 2026/10/19 Re: [I] Type inference works incorrectly with tuple slices [beam] via GitHub
• 2026/10/19 Re: [PR] Bump distlib from 0.4.3 to 0.4.4 in /sdks/python [beam] via GitHub
• 2026/10/19 Re: [PR] [Iceberg] Merge on read fixes [beam] via GitHub
• 2026/10/19 [PR] Bump distlib from 0.4.3 to 0.4.4 in /sdks/python [beam] via GitHub
• 2026/10/19 [PR] [Iceberg] Merge on read fixes [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 [beam] via GitHub
• 2026/10/19 Re: [PR] Fix bigquery_tools_test to mock gcp_bigquery library instead... [beam] via GitHub
• 2026/10/19 Re: [PR] Fix bigquery_tools_test to mock gcp_bigquery library instead... [beam] via GitHub
• 2026/10/19 Re: [PR] Allow canceling SQL streaming pipeline [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fix GCS client creation in non-default universes [beam] via GitHub
• 2026/10/19 [PR] [Python] Support custom BigQuery endpoints and universe domains [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fix GCS client creation in non-default universes (TPC) [beam] via GitHub
• 2026/10/19 [PR] Fix bigquery_tools_test to mock gcp_bigquery library instead... [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] Avoid per-schema RowCoder class generation [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fix GCS client creation in non-default universes (TPC) [beam] via GitHub
• 2026/10/19 [PR] [Python] Fix GCS client creation in non-default universes (TPC) [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] Honor GOOGLE_CLOUD_UNIVERSE_DOMAIN for the Dataflow endpoint [beam] via GitHub
• 2026/10/19 Re: [I] [Bug]: Using MultiProcessShared handle can deadlock when always_proxy=True [beam] via GitHub
• 2026/10/19 [I] [Bug]: Using MultiProcessShared handle can deadlock when always_proxy=True [beam] via GitHub
• 2026/10/19 [PR] [Java] Honor GOOGLE_CLOUD_UNIVERSE_DOMAIN for the Dataflow endpoint [beam] via GitHub
• 2026/10/19 Re: [PR] Fix Release NightlySnapshot after enabling errorprone for Java17+ build [beam] via GitHub
• 2026/10/19 Re: [PR] Upgrade google-api-client to 2.7.2 [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit SQL job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [PR] Scope RunInference model_identifier annotation and preserve ModelManager metric_tag across model updates [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights [beam] via GitHub
• 2026/10/19 Re: [PR] Upgrade google-api-client to 2.7.2 [beam] via GitHub
• 2026/10/19 [PR] Scope RunInference model_identifier annotation and preserve ModelManager metric_tag across model updates [beam] via GitHub
• 2026/10/19 Re: [PR] Upgrade google-api-client to 2.7.2 [beam] via GitHub
• 2026/10/19 Re: [PR] Upgrade google-api-client to 2.7.2 [beam] via GitHub
• 2026/10/19 Re: [PR] Update nlp_tensorflow_streaming.ipynb [beam] via GitHub
• 2026/10/19 Re: [PR] Run portable ValidatesRunner tests one at a time [beam] via GitHub
• 2026/10/19 Re: [PR] Allow canceling SQL streaming pipeline [beam] via GitHub
• 2026/10/19 [PR] Upgrade google-api-client to 2.7.2 [beam] via GitHub
• 2026/10/19 Re: [PR] Default to parquet in AddFiles for extension less files. [beam] via GitHub
• 2026/10/19 Re: [PR] Allow canceling SQL streaming pipeline [beam] via GitHub
• 2026/10/19 Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam] via GitHub
• 2026/10/19 [PR] Add retries and timeout to Grafana request in flaky test detection [beam] via GitHub
• 2026/10/19 [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] Add retries and timeout to Grafana request in flaky test detection [beam] via GitHub
• 2026/10/19 [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] via GitHub
• 2026/10/19 [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] [Feature Request]: Support for iceberg dynamic destination with varying schema [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fail bundles on state write errors [beam] via GitHub
• 2026/10/19 Re: [I] [Failing Test]: portable_runner_test in Python SDK [beam] via GitHub
• 2026/10/19 Re: [I] [Failing Test]: portable_runner_test in Python SDK [beam] via GitHub
• 2026/10/19 Re: [PR] Fix Release NightlySnapshot after enabling errorprone for Java17+ build [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [PR] Model updates [beam] via GitHub
• 2026/10/19 Re: [PR] Add Bigtable CDC YAML SchemaTransform [beam] via GitHub
• 2026/10/19 Re: [I] [Bug]: Tour of Beam Firebase Authentication fails with API key expired error [beam] via GitHub
• 2026/10/19 Re: [PR] Fix Release NightlySnapshot after enabling errorprone for Java17+ build [beam] via GitHub
• 2026/10/19 Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
• 2026/10/19 [I] [Bug]: [RunInference] When load_model_at_runtime=True, the first batch always ignores model side-input updates. [beam] via GitHub
• 2026/10/19 Re: [PR] fix readFromKafka schema error [beam] via GitHub
• 2026/10/19 Re: [PR] Model updates [beam] via GitHub
• 2026/10/19 [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] via GitHub
• 2026/10/19 [PR] Allow canceling SQL streaming pipeline [beam] via GitHub
• 2026/10/19 Re: [PR] fix readFromKafka schema error [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 [PR] Fix Release NightlySnapshot after enabling errorprone for Java17+ build [beam] via GitHub
• 2026/10/19 Re: [I] [Failing Test]: Flink 1.20 portable DataSet ValidatesRunner tests hang [beam] via GitHub
• 2026/10/19 Re: [PR] Allow canceling SQL streaming pipeline [beam] via GitHub
• 2026/10/19 Re: [PR] Default to parquet in AddFiles for extension less files. [beam] via GitHub
• 2026/10/19 Re: [PR] Model updates [beam] via GitHub
• 2026/10/19 Re: [PR] Model updates [beam] via GitHub
• 2026/10/19 Re: [I] [Feature Request]: Modernize legacy DoFn in BatchElementsExample to use parameter injection [beam] via GitHub
• 2026/10/19 Re: [PR] Modernize legacy DoFn in BatchElementsExample (#40557) [beam] via GitHub
• 2026/10/19 Re: [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/py311 [beam] via GitHub
• 2026/10/19 Re: [PR] Invalidate cached ContinuationIterable when its continuation fails [beam] via GitHub
• 2026/10/19 Re: [PR] [Iceberg compaction] Rewrite planner transform [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] ParquetIO: resolve file records against the read schema [beam] via GitHub
• 2026/10/19 Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• 2026/10/19 Re: [PR] Run portable ValidatesRunner tests one at a time [beam] via GitHub
• 2026/10/19 Re: [I] The Community Metrics Prober job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Iceberg compaction] Add committer DoFn [beam] via GitHub
• 2026/10/19 Re: [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] via GitHub
• 2026/10/19 Re: [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/py311 [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [PR] Process deletes before adds when committing OrderedList state updates. [beam] via GitHub
• 2026/10/19 [I] The PerformanceTests SpannerIO Read 2GB Python job is flaky [beam] via GitHub
• 2026/10/19 [I] The PreCommit SQL Java17 job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] Process deletes before adds when committing OrderedList state updates. [beam] via GitHub
• 2026/10/19 Re: [I] ZeroDivisionError if source bundle smaller than 1mb [beam] via GitHub
• 2026/10/19 [PR] Model updates [beam] via GitHub
• 2026/10/19 Re: [PR] Default to parquet in AddFiles for extension less files. [beam] via GitHub
• 2026/10/19 Re: [PR] Model updates [beam] via GitHub
• 2026/10/19 Re: [I] The Flaky test detection job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] Update api key for tour of beam [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit SQL job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fail bundles on state write errors [beam] via GitHub
• 2026/10/19 Re: [PR] Update users.yml [beam] via GitHub
• 2026/10/19 Re: [PR] Remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [PR] Default to parquet in AddFiles for extension less files. [beam] via GitHub
• 2026/10/19 Re: [PR] Bump zizmorcore/zizmor-action from 0.6.4 to 0.7.1 [beam] via GitHub
• 2026/10/19 Re: [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/py311 [beam] via GitHub
• 2026/10/19 [I] The Community Metrics Prober job is flaky [beam] via GitHub
• 2026/10/19 [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/py311 [beam] via GitHub
• 2026/10/19 [PR] remove Beam SQL Data Catalog provider [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit SQL job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Go SDK] Fix generic registration of anonymous struct types [beam] via GitHub
• 2026/10/19 Re: [PR] [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533) [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Add typed decision questions and model adapters [beam] via GitHub
• 2026/10/19 [I] The Flaky test detection job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [IcebergIO] Support sorted writes and RANGE distribution mode [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique [beam] via GitHub
• 2026/10/19 Re: [PR] [Go SDK] Return job message id from WaitForCompletion [beam] via GitHub
• 2026/10/19 Re: [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] via GitHub
• 2026/10/19 Re: [I] The Publish Website job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Add Qdrant search enrichment handler [beam] via GitHub
• 2026/10/19 [I] The Publish Website job is flaky [beam] via GitHub
• 2026/10/19 [I] The Release Nightly Snapshot job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] The Release Nightly Snapshot job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] via GitHub
• 2026/10/19 Re: [I] The PreCommit SQL Java17 job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Add Qdrant search enrichment handler [beam] via GitHub
• 2026/10/19 [I] The PerformanceTests SpannerIO Write 2GB Python Batch job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] [Python] Fail bundles on state write errors [beam] via GitHub
• 2026/10/19 Re: [PR] [Iceberg CDC source] Allow dropping PK or watermark columns [beam] via GitHub
• 2026/10/19 Re: [PR] Update api key for tour of beam [beam] via GitHub
• 2026/10/19 Re: [PR] [Prism] Keep a stateful key in progress while a split primary holds it [beam] via GitHub
• 2026/10/19 Re: [PR] Process deletes before adds when committing OrderedList state updates. [beam] via GitHub
• 2026/10/19 Re: [I] [Feature Request]: Support for iceberg dynamic destination with varying schema [beam] via GitHub
• 2026/10/19 Re: [PR] Add OpenTelemetry tracing support to SolaceIO [beam] via GitHub
• 2026/10/19 Re: [PR] [yaml] - add openai model handler [beam] via GitHub
• 2026/10/19 Re: [PR] Process deletes before adds when committing OrderedList state updates. [beam] via GitHub
• 2026/10/19 Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] via GitHub
• 2026/10/19 [PR] Process deletes before adds when committing OrderedList state updates. [beam] via GitHub
• 2026/10/19 Re: [PR] Modernize legacy DoFn in BatchElementsExample (#40557) [beam] via GitHub
• 2026/10/19 Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
• 2026/10/19 Re: [I] [Bug]: [RunInference] Pipelines using ModelHandlers with max_batch_weight fail at construction time [beam] via GitHub
• 2026/10/19 Re: [PR] Add OpenTelemetry tracing support to SolaceIO [beam] via GitHub
• 2026/10/19 Re: [PR] [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533) [beam] via GitHub
• 2026/10/19 Re: [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] via GitHub
• 2026/10/19 [PR] Document Beam Playground security model and result caching [beam] via GitHub
• 2026/10/19 Re: [I] Non-transient non-serializable instance field in WatermarkHold [beam] via GitHub
• 2026/10/19 Re: [PR] Only feed total memory readings to the ModelManager resource estimator [beam] via GitHub
• 2026/10/19 Re: [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] via GitHub
• 2026/10/19 Re: [PR] Only feed total memory readings to the ModelManager resource estimator [beam] via GitHub
• 2026/10/19 [PR] [yaml] - add openai model handler [beam] via GitHub
• 2026/10/19 Re: [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] via GitHub
• 2026/10/19 Re: [PR] Remove a race with another file write that is not essential to test presence of duplicates. [beam] via GitHub
• 2026/10/19 Re: [PR] Update api key for tour of beam [beam] via GitHub
• 2026/10/19 Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] via GitHub
• 2026/10/19 Re: [I] The PostCommit Java PVR Flink Batch job is flaky [beam] via GitHub
• 2026/10/19 Re: [PR] Run portable ValidatesRunner tests one at a time [beam] via GitHub
• 2026/10/19 Re: [I] Non-transient non-serializable instance field in WatermarkHold [beam] via GitHub
• 2026/10/19 Re: [PR] [IcebergIO] Support sorted writes and RANGE distribution mode [beam] via GitHub
• 2026/10/19 Re: [PR] Fix postgres database for grafana [beam] via GitHub
• 2026/10/19 Re: [PR] Update users.yml [beam] via GitHub
• 2026/10/19 [PR] Fix postgres database for grafana [beam] via GitHub
• 2026/10/19 [PR] Update api key for tour of beam [beam] via GitHub
• 2026/10/19 [PR] Update users.yml [beam] via GitHub
• 2026/10/19 Re: [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] via GitHub
• 2026/10/19 Re: [PR] Update users.yml [beam] via GitHub

• Earlier messages
• Later messages