Messages by Thread
-
[I] [Feature Request]: Add Expire Snapshots maintenance in Iceberg [beam]
via GitHub
-
[I] [Feature Request]: Add Delete Orphan Files operation in Iceberg [beam]
via GitHub
-
[PR] [yaml] - add mongodbio and datadogio to io connectors [beam]
via GitHub
-
[I] [Feature Request]: Add Manifest File compaction in Iceberg [beam]
via GitHub
-
[I] [Feature Request]: Add DataFile compaction in Iceberg [beam]
via GitHub
-
[I] [Feature Request]: Support Iceberg table maintenance functions [beam]
via GitHub
-
[I] The PerformanceTests xlang KafkaIO Python job is flaky [beam]
via GitHub
-
[PR] Revert "Fix Python VarIntCoder OverflowError on uint64 values" [beam]
via GitHub
-
Re: [I] [Task]: Propagate context from windmill to windowedValue [beam]
via GitHub
-
Re: [I] [Feature Request]: Warn when a user's ValueState looks like it could use a better state type [beam]
via GitHub
-
Re: [I] [Feature Request]: ib.collect support wait_for_inputs option [beam]
via GitHub
-
Re: [I] [Failing Test]: Re-enable the skipped Change Stream Unit tests after refactor test code [beam]
via GitHub
-
[PR] Bump docker/login-action from 4.3.0 to 4.4.0 [beam]
via GitHub
-
[I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam]
via GitHub
-
Re: [I] Spanner is hanging when DCP is enabled [beam]
via GitHub
-
Re: [I] IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command (e.g. `pip install <pkg>`) [beam]
via GitHub
-
Re: [I] runtime_type_check DoFn wrapper doesn't call setup and teardown [beam]
via GitHub
-
Re: [I] Support Splittable DoFn in Flink Streaming Runner [python] [beam]
via GitHub
-
[I] [Feature Request]: [GSoC 2026] Managing the integrity of roles made by Terraform [beam]
via GitHub
-
Re: [PR] [3/3] sdks/python: sink data with Milvus Search I/O connector [beam]
via GitHub
-
[PR] Bump transformers from 4.55.4 to 5.3.0 in /sdks/python/container/ml/py312 [beam]
via GitHub
-
Re: [I] [Bug]: Beam Yaml Jinja option may conflict with well known Pipeline option [beam]
via GitHub
-
[PR] [Python] Drop envoy-data-plane/betterproto dependency from the Python SDK [beam]
via GitHub
-
[PR] [Docs] Add local Flink cluster guide for Python, update Flink version references [beam]
via GitHub
-
Re: [I] [Task]: Java SDK, make BigTableIO compatible with BigTable library 2.71.x [beam]
via GitHub
-
Re: [I] [Feature Request]: Add pipeline options for diskProvisionedIops and diskProvisionedThroughputMipbs [beam]
via GitHub
-
[PR] [GSoC 2026] Kafka Streams runner — KafkaStreamsTestRunner test harness [beam]
via GitHub
-
[PR] [#28420] Fix type inference for closures over local variables [beam]
via GitHub
-
Re: [PR] Bump transformers from 4.55.4 to 5.3.0 in /sdks/python/container/ml/py310 [beam]
via GitHub
-
Re: [PR] Bump docker/login-action from 4.2.0 to 4.3.0 [beam]
via GitHub
-
Re: [PR] Bump docker/setup-buildx-action from 4.1.0 to 4.2.0 [beam]
via GitHub
-
[PR] Bump cryptography from 47.0.0 to 48.0.1 in Python container images [beam]
via GitHub
-
[PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2 from 1.42.0 to 1.42.1 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.29 to 1.22.30 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.26 to 1.32.27 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.25 to 1.19.26 in /sdks [beam]
via GitHub
-
[PR] Bump docker/setup-qemu-action from 4.1.0 to 4.2.0 [beam]
via GitHub
-
[PR] Bump docker/build-push-action from 7.2.0 to 7.3.0 [beam]
via GitHub
-
[PR] fix: add retries and URL encoding to Unmanaged Keys Audit workflow (#39188) [beam]
via GitHub
-
[PR] Bump transformers from 4.38.0 to 5.3.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam]
via GitHub
-
Re: [I] [Task]: Add support for Managed IO (Beam changes) [beam]
via GitHub
-
Re: [I] [Feature Request]: Add support for Beam Python and YAML [beam]
via GitHub
-
[PR] [Gemini] Add client-side throttling to Java Remote Inference [beam]
via GitHub
-
[PR] Bump transformers from 4.55.4 to 5.3.0 in /sdks/python/container/ml/py313 [beam]
via GitHub
-
Re: [PR] Upgrade TFX stack to 1.21.0 and remove numpy/pandas bounds [beam]
via GitHub
-
[I] [GSoC 2026] Kafka Streams runner — testing infra: test runner + Create + first @ValidatesRunner [beam]
via GitHub
-
[PR] [Flink] Bound SDF self-checkpoint residual state on the portable runner [beam]
via GitHub
-
Re: [PR] Omit state commits in stateful Dofn [beam]
via GitHub
-
Re: [PR] Add primitive read translators [beam]
via GitHub
-
[PR] Update Beam website to release 2.75.0 [beam]
via GitHub
-
[PR] Fix Validate Go SDK Release Candidate workflow [beam]
via GitHub
-
[I] The Unmanaged Service Accounts Keys Audit job is flaky [beam]
via GitHub
-
[PR] Remove previous workarounds for when `super()` could not be pickled on Py3 [beam]
via GitHub
-
[PR] Bump google.golang.org/grpc from 1.81.1 to 1.82.0 in /sdks [beam]
via GitHub
-
[PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
Re: [PR] Update cython requirement from <4,>=3.2.6 to >=3.2.8,<4 in /sdks/python [beam]
via GitHub
-
[PR] Bump google.golang.org/api from 0.286.0 to 0.287.0 in /sdks [beam]
via GitHub
-
[PR] Fix flaky test by acking messages asap in pubsub test [beam]
via GitHub
-
Re: [PR] Revert previous workarounds and upgrade TFX stack to 1.21.0 [beam]
via GitHub
-
[PR] Add "-Pjava21Home" to stage docker step in build_release_candidate workflow [beam]
via GitHub
-
[PR] Migrate MqttIO to HiveMQ Mqtt client [beam]
via GitHub
-
[I] [Task]: Migrate Mqtt client [beam]
via GitHub
-
Re: [I] MQTT IO should compute watermark and ack messages outside of finalizeCheckpoint method [beam]
via GitHub
-
[PR] Update managed-io.md for release 2.75.0-RC1 [beam]
via GitHub
-
[PR] [GSoC 2026] Fixing the github action Unmanaged Service Account Keys [beam]
via GitHub
-
[I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam]
via GitHub
-
[PR] Fix lost state updates in Set state [beam]
via GitHub
-
Re: [PR] Revert previous fixes and upgrade TFX stack to 1.21.0 [beam]
via GitHub