github
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/01/19
Re: [PR] Cleanup use of await/notify to recommended ReentrantLock/Condition and add nullness checking. [beam]
via GitHub
2026/01/19
Re: [PR] [#37328] Remove Spanner version pin and exclusions [beam]
via GitHub
2026/01/19
[PR] [#37328] Remove Spanner version pin and exclusions [beam]
via GitHub
2026/01/19
Re: [PR] support generics in from row and to row conversions [beam]
via GitHub
2026/01/19
[PR] support generics in from row and to row conversions [beam]
via GitHub
2026/01/19
Re: [PR] [#37209] Enhance serialization error messages for better developer experience [beam]
via GitHub
2026/01/19
Re: [PR] Simplify encoding kw_only args and test init=False args. [beam]
via GitHub
2026/01/19
Re: [PR] Simplify encoding kw_only args and test init=False args. [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Vertex AI Triton Inference Server Support [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Add `with_exception_handling()` for PTransforms in Python [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Add an example that uses Iceberg I/O via the Managed API [beam]
via GitHub
2026/01/19
Re: [I] [Failing Test]: TypeScript Tests continually failing [beam]
via GitHub
2026/01/19
Re: [PR] [Do not merge] [BEAM-36736] Add state sampling for timer processing [beam]
via GitHub
2026/01/19
Re: [PR] Update comment to clarify test triggering [beam]
via GitHub
2026/01/19
Re: [PR] Update comment to clarify test triggering [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Vertex AI Triton Inference Server Support [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Add `with_exception_handling()` for PTransforms in Python [beam]
via GitHub
2026/01/19
Re: [I] [Feature Request]: Add an example that uses Iceberg I/O via the Managed API [beam]
via GitHub
2026/01/19
Re: [I] [Failing Test]: TypeScript Tests continually failing [beam]
via GitHub
2026/01/19
Re: [I] [Task]: YAML - update expand_jinja method [beam]
via GitHub
2026/01/19
Re: [PR] [Do not merge] [BEAM-36736] Add state sampling for timer processing [beam]
via GitHub
2026/01/19
Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam]
via GitHub
2026/01/19
Re: [PR] Update ChangeStreamDao to query different TVF for postgresSQL based on the change stream partition mode [beam]
via GitHub
2026/01/19
Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam]
via GitHub
2026/01/19
Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam]
via GitHub
2026/01/19
Re: [PR] Fix ProtoCoder NoSuchMethodException [beam]
via GitHub
2026/01/19
Re: [PR] Added flag for overriding artifact hostname [beam]
via GitHub
2026/01/19
Re: [PR] Simplify encoding kw_only args and test init=False args. [beam]
via GitHub
2026/01/19
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/19
Re: [PR] Cleanup use of await/notify to recommended ReentrantLock/Condition and add nullness checking. [beam]
via GitHub
2026/01/19
Re: [PR] [Dataflow Streaming] Remove GetWorkBudgetRefresher which is unused and has a flaky test. [beam]
via GitHub
2026/01/19
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/19
Re: [PR] Add Python 3.14 to Python SDK configs [beam]
via GitHub
2026/01/19
Re: [PR] Add Python 3.14 to Python SDK configs [beam]
via GitHub
2026/01/19
Re: [PR] Add Python 3.14 to Python SDK configs [beam]
via GitHub
2026/01/19
[PR] Add Python 3.14 to Python SDK configs [beam]
via GitHub
2026/01/18
Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam]
via GitHub
2026/01/18
Re: [PR] [2/2] notebooks: add OpenAI text embeddings [beam]
via GitHub
2026/01/18
Re: [PR] [2/2] notebooks: add OpenAI text embeddings [beam]
via GitHub
2026/01/18
Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam]
via GitHub
2026/01/18
Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam]
via GitHub
2026/01/18
Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam]
via GitHub
2026/01/18
Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam]
via GitHub
2026/01/18
Re: [PR] [2/2] notebooks: add OpenAI text embeddings [beam]
via GitHub
2026/01/18
Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam]
via GitHub
2026/01/18
[PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam]
via GitHub
2026/01/18
[I] [Feature Request]: add OpenAI text embedding model notebook [beam]
via GitHub
2026/01/18
Re: [PR] [2/2] notebooks: add add OpenAI text embedding model [beam]
via GitHub
2026/01/18
[PR] [2/2] notebooks: add add OpenAI text embedding model [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
[PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Python job is flaky [beam]
via GitHub
2026/01/18
[I] The PreCommit Python job is flaky [beam]
via GitHub
2026/01/18
Re: [I] [Task]: YAML - E2E example pipelines for common use cases [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Go Dataflow ARM job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Python Coverage job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Python Coverage job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java Examples Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java Examples Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit GoPortable job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Go VR Spark job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit GoPortable job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Go VR Spark job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The Publish Beam SDK Snapshots job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The Publish Beam SDK Snapshots job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The go_modules in /sdks - Update #941920271 job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Examples Dataflow V2 Java job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Examples Dataflow V2 Java job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Nexmark Dataflow V2 job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Nexmark Dataflow V2 job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Nexmark Dataflow V2 Java job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Java Nexmark Dataflow V2 Java job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java PVR Flink Docker job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java Examples Dataflow Java21 job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java Examples Dataflow Java21 job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Java PVR Flink Docker job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Xlang Generated Transforms job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit Xlang Generated Transforms job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python ValidatesRunner Flink job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python ValidatesRunner Flink job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit GoPrism job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PreCommit GoPrism job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Portable Flink job is flaky [beam]
via GitHub
2026/01/18
Re: [I] The PostCommit Python Portable Flink job is flaky [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
[PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam]
via GitHub
2026/01/18
Re: [PR] Add Kerberos Authentication Support to KafkaTable [beam]
via GitHub
2026/01/18
Re: [I] [Task]: YAML - E2E example pipelines for common use cases [beam]
via GitHub
2026/01/18
Re: [I] [Failing Test]: TypeError for EncodedFIle in Python SDF [beam]
via GitHub
2026/01/18
Re: [I] [Failing Test]: Java Samza runner tests failing on Java11 [beam]
via GitHub
2026/01/18
Re: [PR] Add Kerberos Authentication Support to KafkaTable [beam]
via GitHub
2026/01/17
Re: [I] [Feature Request]: RequestResponseIO: Unable to configure retry Backoff parameters; defaults to unlimited retries [beam]
via GitHub
2026/01/17
Re: [I] [Bug]: RequestResponseIO: Call wraps retryable exceptions in UserCodeExecutionException, preventing retry/backoff [beam]
via GitHub
2026/01/17
Re: [I] [Feature Request]: RequestResponseIO: Unable to configure retry Backoff parameters; defaults to unlimited retries [beam]
via GitHub
2026/01/17
Re: [PR] Fix iceberg nested filter [beam]
via GitHub
2026/01/17
Re: [PR] Fix iceberg nested filter [beam]
via GitHub
2026/01/17
[PR] Fix iceberg nested filter [beam]
via GitHub
2026/01/17
Re: [I] Support OrderedListState in Google Cloud Dataflow Runner V2 [beam]
via GitHub
2026/01/17
Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam]
via GitHub
2026/01/17
Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam]
via GitHub
2026/01/17
Re: [PR] DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner [beam]
via GitHub
2026/01/17
Re: [I] [Bug]: Row is not adaptable from Scala/JVM -> Python via PythonExternalTransform [beam]
via GitHub
2026/01/17
Re: [I] [Bug]: Row is not adaptable from Scala/JVM -> Python via PythonExternalTransform [beam]
via GitHub
2026/01/17
Re: [I] [Bug]: Duplicate rows inserted in BigQuery [beam]
via GitHub
2026/01/17
Re: [I] [Feature Request]: Allow a flag so that "with pipeline" will not wait_until_finish so that this paradigm can be used for streaming jobs [beam]
via GitHub
2026/01/16
Re: [PR] Add YAML SQL example using calcite_connection_properties [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/16
Re: [PR] test [beam]
via GitHub
2026/01/16
[PR] test [beam]
via GitHub
2026/01/16
Re: [PR] Move the logic to calculate changeStreamQueryEndTimestamp after fetching PartitionMetadata. [beam]
via GitHub
2026/01/16
Re: [PR] Move the logic to calculate changeStreamQueryEndTimestamp after fetching PartitionMetadata. [beam]
via GitHub
2026/01/16
Re: [PR] Move the logic to calculate changeStreamQueryEndTimestamp after fetching PartitionMetadata. [beam]
via GitHub
2026/01/16
[PR] Move the logic to calculate changeStreamQueryEndTimestamp after fetching PartitionMetadata. [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py313 [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py313 [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py313 [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/ml/py311 [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/ml/py313 [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Fix PostCommit Python Arm job [beam]
via GitHub
2026/01/16
Re: [PR] Undo #35962 and move from distutils to setuptools instead [beam]
via GitHub
2026/01/16
[PR] Undo #35962 and move from distutils to setuptools instead [beam]
via GitHub
2026/01/16
Re: [PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py312 [beam]
via GitHub
2026/01/16
Re: [PR] Update managed-io.md for release 2.71.0-RC3 [beam]
via GitHub
2026/01/16
Re: [PR] Fix PostCommit Python Arm job [beam]
via GitHub
2026/01/16
Re: [PR] Fix PostCommit Python Arm job [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Disable build isolation for workflow tarball by default [beam]
via GitHub
2026/01/16
[PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/ml/py313 [beam]
via GitHub
2026/01/16
[PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/ml/py311 [beam]
via GitHub
2026/01/16
[PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py313 [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Update managed-io.md for release 2.71.0-RC3 [beam]
via GitHub
2026/01/16
[PR] Update managed-io.md for release 2.71.0-RC3 [beam]
via GitHub
2026/01/16
[PR] Bump pyasn1 from 0.6.1 to 0.6.2 in /sdks/python/container/py312 [beam]
via GitHub
2026/01/16
Re: [PR] Disable build isolation for workflow tarball by default [beam]
via GitHub
2026/01/16
Re: [PR] Disable build isolation for workflow tarball by default [beam]
via GitHub
2026/01/16
Re: [PR] Disable build isolation for workflow tarball by default [beam]
via GitHub
2026/01/16
[PR] Disable build isolation for workflow tarball by default [beam]
via GitHub
2026/01/16
Re: [I] [Feature Request]: RequestResponseIO: Unable to configure retry Backoff parameters; defaults to unlimited retries [beam]
via GitHub
2026/01/16
Re: [PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
Re: [PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
Re: [I] [Bug]: Remove Spanner exclusion once bug is fixed [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Add Datadog IO [beam]
via GitHub
2026/01/16
Re: [PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
Re: [PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
[PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
Re: [PR] Spanner cherry-picks [beam]
via GitHub
2026/01/16
Re: [PR] Pin spanner to old version in gcp bom [beam]
via GitHub
2026/01/16
Re: [PR] Migrate Cloud Build usage to Python client [beam]
via GitHub
2026/01/16
Re: [PR] Fix spanner io hang by closing connections [beam]
via GitHub
2026/01/16
Re: [PR] Pin spanner to old version in gcp bom [beam]
via GitHub
2026/01/16
Re: [PR] Pin spanner to old version in gcp bom [beam]
via GitHub
2026/01/16
Re: [PR] Pin spanner to old version in gcp bom [beam]
via GitHub
2026/01/16
[PR] Pin spanner to old version in gcp bom [beam]
via GitHub
2026/01/16
[I] [Bug]: Remove Spanner exclusion once bug is fixed [beam]
via GitHub
2026/01/16
Re: [PR] [Dataflow Streaming] Remove GetWorkBudgetRefresher which is unused and has a flaky test. [beam]
via GitHub
2026/01/16
Re: [PR] Pin spanner version, not just spanner bom [beam]
via GitHub
2026/01/16
Re: [PR] Fix spanner io hang by closing connections [beam]
via GitHub
2026/01/16
Re: [PR] Fix spanner io hang by closing connections [beam]
via GitHub
2026/01/16
Re: [PR] Bump keras from 3.12.0 to 3.13.1 in /sdks/python/container/ml/py310 [beam]
via GitHub
2026/01/16
[PR] Fix spanner io hang by closing connections [beam]
via GitHub
2026/01/16
Re: [PR] Fix spanner io hang by closing connections [beam]
via GitHub
2026/01/16
Re: [PR] Add Terraform files to deploy Envoy RateLimiter [beam]
via GitHub
2026/01/16
Re: [PR] Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [PR] Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [PR] Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [I] [Task]: TypeScript SDK: Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [PR] Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [PR] Add LRU cache eviction to CachingStateProvider [beam]
via GitHub
2026/01/16
Re: [I] [Failing Test]: ValueError in yaml for Python SDK [beam]
via GitHub
2026/01/16
Re: [PR] [Dataflow Streaming] Remove GetWorkBudgetRefresher which is unused and has a flaky test. [beam]
via GitHub
2026/01/16
Re: [PR] [Spanner Change Streams] Fix potential data loss issue by ensuring to only claim timestamps that have been fully processed from the restriction tracker. [beam]
via GitHub
Earlier messages
Later messages