github
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/09/30
Re: [PR] Include OpenTelemetry dependencies in published Dataflow runner POM [beam]
via GitHub
2026/09/30
Re: [PR] [Python] Round float seconds to the nearest microsecond in Duration [beam]
via GitHub
2026/09/30
Re: [I] [Bug][Go SDK]: Xlang Bigquery IO doesn't appear to support Time type fields. [beam]
via GitHub
2026/09/30
Re: [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam]
via GitHub
2026/09/30
Re: [PR] Fix partial insertError metric status bug [beam]
via GitHub
2026/09/30
Re: [PR] [Claude] Capture behavior of the BigQueryWrapper during requests [beam]
via GitHub
2026/09/30
Re: [PR] Fix partial insertError metric status bug [beam]
via GitHub
2026/09/30
[PR] Include OpenTelemetry dependencies in published Dataflow runner POM [beam]
via GitHub
2026/09/30
[PR] [Claude] Produce Beam-specific representation of BQ resources, rework compat shims [beam]
via GitHub
2026/09/30
[PR] [CI] Make Gradle caches read-only for untrusted presubmit workflow runs [beam]
via GitHub
2026/09/30
Re: [PR] Update list of stale bq dataset [beam]
via GitHub
2026/09/30
Re: [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam]
via GitHub
2026/09/30
Re: [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam]
via GitHub
2026/09/30
Re: [PR] Enable connection pooling by default [beam]
via GitHub
2026/09/30
[PR] [Flink] Restore source split logs [beam]
via GitHub
2026/09/30
Re: [PR] Enable connection pooling by default [beam]
via GitHub
2026/09/30
Re: [PR] Fix partial insertError metric status bug [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request][Go SDK]: Improve Native File IO Writes [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Bump HCLS API version from GA to Alpha/Beta [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: Read from datastore with inequality filters [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK][Cleanup]: Migrate passert package exclusively to the generic register package. [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Bump HCLS API version from GA to Alpha/Beta [beam]
via GitHub
2026/09/30
Re: [PR] [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336) [beam]
via GitHub
2026/09/30
Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: Avro schema support doesn't support UNION types (OneOf) for SpecificRecords [beam]
via GitHub
2026/09/30
Re: [PR] Add V2 unit tests and V1/V2 parity ITs for GcsUtil [beam]
via GitHub
2026/09/30
Re: [PR] [Python] Set a Beam user agent on the boto3 S3 client [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: [Java BQ] Race condition between copy jobs at different triggers in a streaming pipeline [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Translate the IO Authoring Guide for the Go SDK. [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Align Spark/Hadoop versions in Spark multiple-versions unit/VR tests [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK]: Update fhirio tests to not rely on direct runner. [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK]: Determine canonical local temp directory. [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request][Go SDK]: Improve Native File IO Writes [beam]
via GitHub
2026/09/30
[PR] [Claude] Capture behavior of the BigQueryWrapper during requests [beam]
via GitHub
2026/09/30
Re: [PR] swap Dataflow Streaming and Streaming Engine VR cron times [beam]
via GitHub
2026/09/30
Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam]
via GitHub
2026/09/30
Re: [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam]
via GitHub
2026/09/30
Re: [PR] Include OpenTelemetry dependencies in published Dataflow runner POM [beam]
via GitHub
2026/09/30
[PR] Fix partial insertError metric status bug [beam]
via GitHub
2026/09/30
Re: [PR] Remove upper bound pin for cryptography. [beam]
via GitHub
2026/09/30
Re: [PR] Include OpenTelemetry dependencies in published Dataflow runner POM [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: Read from datastore with inequality filters [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK]: Update datastoreio tests to not rely on direct runner. [beam]
via GitHub
2026/09/30
Re: [PR] Add V2 unit tests and V1/V2 parity ITs for GcsUtil [beam]
via GitHub
2026/09/30
Re: [PR] Add V2 unit tests and V1/V2 parity ITs for GcsUtil [beam]
via GitHub
2026/09/30
Re: [PR] Add custom window support in Go SDK [beam]
via GitHub
2026/09/30
Re: [PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/30
Re: [PR] Remove upper bound pin for cryptography. [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request]:[Go SDK]: BigTableIO should have scalable reads. [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request]: Add schema evolution/deduction to AddFiles [beam]
via GitHub
2026/09/30
Re: [PR] [Gemini] GCP BigQuery IO Modern Client Migration [beam]
via GitHub
2026/09/30
Re: [PR] [Flink] Restore source split logs [beam]
via GitHub
2026/09/30
Re: [PR] Fix invalid POM for io-component [beam]
via GitHub
2026/09/30
Re: [PR] [Flink] Restore source split logs [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request][Go SDK]: Rewrite the `dot` runner in terms of a Portable pipeline. [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK][Cleanup]: Migrate passert package exclusively to the generic register package. [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: Avro schema support doesn't support UNION types (OneOf) for SpecificRecords [beam]
via GitHub
2026/09/30
Re: [I] [Bug]: [Java BQ] Race condition between copy jobs at different triggers in a streaming pipeline [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request][Go SDK]: Rewrite the `dot` runner in terms of a Portable pipeline. [beam]
via GitHub
2026/09/30
Re: [I] [Feature Request]: Support pyarrow RecordBatch for MLTransform [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK]: Update datastoreio tests to not rely on direct runner. [beam]
via GitHub
2026/09/30
Re: [I] [Bug][Go SDK]: Native bigqueryio package doesn't have scalable writes. [beam]
via GitHub
2026/09/30
Re: [I] [Bug][Go SDK]: Xlang Bigquery IO doesn't appear to support Time type fields. [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Translate the IO Authoring Guide for the Go SDK. [beam]
via GitHub
2026/09/30
Re: [I] [Task][Go SDK]: Determine canonical local temp directory. [beam]
via GitHub
2026/09/30
Re: [I] [Task]: Align Spark/Hadoop versions in Spark multiple-versions unit/VR tests [beam]
via GitHub
2026/09/30
Re: [PR] [OpenTelemetry] set default otel.service.instance.id [beam]
via GitHub
2026/09/30
Re: [I] How to run typescript apache beam pipeline in Flink Cluster [beam]
via GitHub
2026/09/30
Re: [I] How to run typescript apache beam pipeline in Flink Cluster [beam]
via GitHub
2026/09/30
Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam]
via GitHub
2026/09/30
Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam]
via GitHub
2026/09/30
Re: [PR] swap Dataflow Streaming and Streaming Engine VR cron times [beam]
via GitHub
2026/09/30
Re: [PR] Bump brace-expansion from 1.1.12 to 1.1.21 in /sdks/typescript [beam]
via GitHub
2026/09/30
[PR] pin Side Input Test 8 container [beam]
via GitHub
2026/09/30
[PR] delay LeaderBoardIT Pub/Sub inject [beam]
via GitHub
2026/09/30
[PR] [OpenTelemetry] set default otel.service.instance.id [beam]
via GitHub
2026/09/30
Re: [PR] swap Dataflow Streaming and Streaming Engine VR cron times [beam]
via GitHub
2026/09/30
[PR] swap Dataflow Streaming and Streaming Engine VR cron times [beam]
via GitHub
2026/09/30
Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam]
via GitHub
2026/09/30
Re: [PR] Re-arrange GcsUtil unit tests and integration tests [beam]
via GitHub
2026/09/29
Re: [PR] Fix invalid POM for io-component [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Allow disable user metrics in Python SDK [beam]
via GitHub
2026/09/29
Re: [PR] Bump nodemailer from 10.0.2 to 10.0.9 in /scripts/ci/issue-report [beam]
via GitHub
2026/09/29
Re: [PR] Bump brace-expansion from 1.1.12 to 1.1.21 in /sdks/typescript [beam]
via GitHub
2026/09/29
Re: [PR] Bump nodemailer from 10.0.2 to 10.0.9 in /scripts/ci/issue-report [beam]
via GitHub
2026/09/29
Re: [PR] Re-arrange GcsUtil unit tests and integration tests [beam]
via GitHub
2026/09/29
Re: [PR] [POC] Improve ValidatesRunner performance. Parallelize runs [beam]
via GitHub
2026/09/29
[PR] Bump nodemailer from 10.0.2 to 10.0.9 in /scripts/ci/issue-report [beam]
via GitHub
2026/09/29
[PR] Bump brace-expansion from 1.1.12 to 1.1.21 in /sdks/typescript [beam]
via GitHub
2026/09/29
Re: [PR] Re-arrange GcsUtil unit tests and integration tests [beam]
via GitHub
2026/09/29
[I] [Task]: Add a GCS temp bucket cleaner to .test-infra/tools to prevent bucket leaks [beam]
via GitHub
2026/09/29
Re: [PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/29
Re: [PR] Draft: Make Presubmits faster [beam]
via GitHub
2026/09/29
[PR] Exposing evictWritersWhenFull in AvroIO [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Cache and reuse shared metrics pipeline execution in MetricsTest [beam]
via GitHub
2026/09/29
Re: [PR] Fix ML container publishing in push3XX tasks [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam]
via GitHub
2026/09/29
Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam]
via GitHub
2026/09/29
Re: [PR] [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336) [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Update Beam Grafana instance [beam]
via GitHub
2026/09/29
Re: [PR] [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336) [beam]
via GitHub
2026/09/29
Re: [I] The PostCommit SQL job is flaky [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Allow metrics to be tagged or segmented [beam]
via GitHub
2026/09/29
Re: [PR] Bump cloud.google.com/go/pubsub/v2 from 2.6.2 to 2.7.0 in /sdks [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: Okio present in beam-sdks-java-extensions-sql-jdbc [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request][prism]: Add support for the multi-chunk iterable protocol [beam]
via GitHub
2026/09/29
Re: [PR] Support Python's --files_to_stage option in Java xlang. [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Retry policies for ParDo [beam]
via GitHub
2026/09/29
Re: [PR] Bump com.diffplug.spotless from 7.2.1 to 8.10.3 [beam]
via GitHub
2026/09/29
Re: [PR] [PR Bot] Select single main and backup reviewer using label priority [beam]
via GitHub
2026/09/29
Re: [PR] [Java] ParquetIO: resolve file records against the read schema [beam]
via GitHub
2026/09/29
Re: [PR] [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML [beam]
via GitHub
2026/09/29
[PR] Fix invalid POM for io-component [beam]
via GitHub
2026/09/29
[PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam]
via GitHub
2026/09/29
Re: [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam]
via GitHub
2026/09/29
Re: [PR] [release-2.77] Cherry-pick #40259: Speed up Beam presubmits [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: ParquetIO failing to read with specified schema [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
[PR] [Java] ParquetIO: resolve file records against the read schema [beam]
via GitHub
2026/09/29
Re: [PR] [Gemini] GCP BigQuery IO Modern Client Migration [beam]
via GitHub
2026/09/29
Re: [PR] Fix ML container publishing in push3XX tasks [beam]
via GitHub
2026/09/29
Re: [PR] Fix ML container publishing in push3XX tasks [beam]
via GitHub
2026/09/29
[PR] Fix ML container publishing in push3XX tasks [beam]
via GitHub
2026/09/29
Re: [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam]
via GitHub
2026/09/29
Re: [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam]
via GitHub
2026/09/29
[PR] [release-2.77] Cherry-pick #40259: Speed up Beam presubmits [beam]
via GitHub
2026/09/29
Re: [PR] Update managed-io.md for release 2.77.0-RC2 [beam]
via GitHub
2026/09/29
Re: [PR] Remove pull request template [beam]
via GitHub
2026/09/29
Re: [PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/29
Re: [I] Eliminate nullability errors from :sdks:java:extensions:sorter [beam]
via GitHub
2026/09/29
Re: [PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/29
Re: [PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/29
[PR] Remove pull request template [beam]
via GitHub
2026/09/29
[PR] Bump nodemailer from 9.1.1 to 10.0.2 in /scripts/ci/issue-report [beam]
via GitHub
2026/09/29
[PR] add pubsub max_read_time_seconds parameter [beam]
via GitHub
2026/09/29
[PR] [Gemini] GCP BigQuery IO Modern Client Migration [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Cache and reuse shared metrics pipeline execution in MetricsTest [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Run Dataflow TFT benchmark tests on Python 3.11 to avoid protobuf resolution clash [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: condition missed after a unnest [beam]
via GitHub
2026/09/29
Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Katas need new platform/host [beam]
via GitHub
2026/09/29
Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam]
via GitHub
2026/09/29
Re: [I] Eliminate nullability errors from :sdks:java:extensions:sql:perf-tests [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: [Doc] Beam Capability Matrix space [beam]
via GitHub
2026/09/29
Re: [PR] Support Python's --files_to_stage option in Java xlang. [beam]
via GitHub
2026/09/29
Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Fix LogElements crash on global window timestamps [beam]
via GitHub
2026/09/29
Re: [PR] Re-arrange GcsUtil unit tests and integration tests [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Run Dataflow TFT benchmark tests on Python 3.11 to avoid protobuf resolution clash [beam]
via GitHub
2026/09/29
[PR] [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336) [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Improvements to file staging [beam]
via GitHub
2026/09/29
Re: [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam]
via GitHub
2026/09/29
Re: [PR] normalize BigQuery CDC [beam]
via GitHub
2026/09/29
Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam]
via GitHub
2026/09/29
Re: [PR] Adds drain support to Spanner CDC source. [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam]
via GitHub
2026/09/29
Re: [PR] reduce LeaderBoardIT flakiness [beam]
via GitHub
2026/09/29
Re: [PR] [PR Bot] Select single main and backup reviewer using label priority [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Run Dataflow TFT benchmark tests on Python 3.11 to avoid protobuf resolution clash [beam]
via GitHub
2026/09/29
Re: [PR] reduce LeaderBoardIT flakiness [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam]
via GitHub
2026/09/29
Re: [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam]
via GitHub
2026/09/29
Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam]
via GitHub
2026/09/29
Re: [PR] [Java] Fix BigQuery failed-row timestamp conversion [beam]
via GitHub
2026/09/29
Re: [PR] reduce LeaderBoardIT flakiness [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: [Doc] Beam Capability Matrix space [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: condition missed after a unnest [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Retry policies for ParDo [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: Okio present in beam-sdks-java-extensions-sql-jdbc [beam]
via GitHub
2026/09/29
Re: [PR] Disable PROJECT_SET_OP_TRANSPOSE rule in BeamRuleSets [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: [SQL] BeamKafkaTable doesn't set commitOffsetsInFinalize to KafkaIO reader [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam]
via GitHub
2026/09/29
Re: [PR] [#20501] Remove nullness suppressions from sql extensions module [beam]
via GitHub
2026/09/29
Re: [I] [Feature Request]: Allow metrics to be tagged or segmented [beam]
via GitHub
2026/09/29
[PR] [Python] Fix LogElements crash on global window timestamps [beam]
via GitHub
2026/09/29
Re: [PR] [Gemini] Add compatibility classes between apitools client and modern bq client [beam]
via GitHub
2026/09/29
Re: [PR] Bump cloud.google.com/go/pubsub/v2 from 2.6.2 to 2.7.0 in /sdks [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
[PR] Update managed-io.md for release 2.77.0-RC3 [beam]
via GitHub
2026/09/29
[PR] Addfiles partition bounds fixes (#40252) [beam]
via GitHub
2026/09/29
Re: [PR] Addfiles partition bounds fixes [beam]
via GitHub
2026/09/29
Re: [PR] [Iceberg CDC sink] Integration tests [beam]
via GitHub
2026/09/29
Re: [PR] Exposing evictWritersWhenFull in AvroIO [beam]
via GitHub
2026/09/29
Re: [PR] fix PostCommit GCP auth and reducing LeaderBoardIT flakiness [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Add reusable decision model primitives [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
Re: [PR] [#20501] Remove nullness suppressions from sql extensions module [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam]
via GitHub
2026/09/29
Re: [I] Eliminate nullability errors from :sdks:java:extensions:sorter [beam]
via GitHub
2026/09/29
Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam]
via GitHub
2026/09/29
Re: [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam]
via GitHub
2026/09/29
Re: [I] [Bug]: Update or Remove Integrations page [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam]
via GitHub
2026/09/29
Re: [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam]
via GitHub
2026/09/29
Re: [PR] Bump cloud.google.com/go/profiler from 0.6.0 to 0.7.0 in /sdks [beam]
via GitHub
2026/09/29
Re: [PR] [Python] Fix overflow in LexicographicKeyRangeTracker [beam]
via GitHub
Earlier messages
Later messages