Messages by Thread
-
Re: [I] [Feature Request]: BigQuery Storage Write API Partition Decorator Support [beam]
via GitHub
-
[PR] fix(dataframe): handle pandas dimensionality reduction in .xs() for single-item matches [beam]
via GitHub
-
Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam]
via GitHub
-
[PR] Install Cloud Spanner emulator component in Go PreCommit CI [beam]
via GitHub
-
[I] [Bug]: Prism ignores the resume delay of self-checkpointing SDFs, so polling SDFs busy-spin [beam]
via GitHub
-
Re: [I] [Feature Request]: Rewrite pytest markers to avoid including ML test suites into a catch-all postcommit suite. [beam]
via GitHub
-
Re: [I] [Bug]: Datastore's Read fails Pipeline validation and throws on DataflowRunner [beam]
via GitHub
-
[PR] [GSoC 2026] Kafka Streams runner: say what the Python side is, and is not [beam]
via GitHub
-
[PR] fix pickling issue [beam]
via GitHub
-
[PR] ClickHouseIO: Add Decimal(P, S) support for fixed-point columns [beam]
via GitHub
-
[I] [Bug]: Bigtable segment truncation creates invalid range when open end key is startKey + null byte [beam]
via GitHub
-
[PR] Fix KafkaIO wrtie SchemaTransform parallelism [beam]
via GitHub
-
[PR] [Bigtable] Fix Bigtable segment truncation when open end key is startKey + null byte (#39842) [beam]
via GitHub
-
[I] [Bug]: KafkaWriteSchemaTransformProvider write messages to route to a single partition [beam]
via GitHub
-
Re: [I] [Prism] Watermark deadlock when unbounded source is initially empty [beam]
via GitHub
-
[I] [Feature Request]: ClickHouseIO: Add Decimal(P, S) support for fixed-point columns [beam]
via GitHub
-
[PR] Update managed-io.md for release 2.76.0-RC4 [beam]
via GitHub
-
Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam]
via GitHub
-
Re: [I] [Task]: Build a cleaner for assets in the GCP test environment [beam]
via GitHub
-
Re: [I] [Feature request] Consider installing the same artifact in Beam Python RC Docker containers as is being published to PyPi [beam]
via GitHub
-
Re: [I] [Feature Request]: DICOM IO `delete` [beam]
via GitHub
-
[PR] Cherrypick #39837: Update google-cloud-bigtable version [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] Update google-cloud-bigtable [beam]
via GitHub
-
[PR] AddFiles: regenerate name mapping, read footers once, error helper [beam]
via GitHub
-
[I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam]
via GitHub
-
Re: [I] [Feature Request]: Add ARM unit test suites for all Beam SDK languages [beam]
via GitHub
-
[PR] Make primary channel failover timeout configurable (#39646) [beam]
via GitHub
-
[PR] Support Secret Manager in JdbcIO for Java, Python and YAML [beam]
via GitHub
-
[PR] Update managed-io.md for release 2.76.0-RC3 [beam]
via GitHub
-
[PR] [CP] bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing (#39820) [beam]
via GitHub
-
Re: [I] [Feature Request]: Write integration tests for DICOM IO (Java SDK) [beam]
via GitHub
-
Re: [I] [Task]: Update GitHub Actions Self-Hosted Runners to Ubuntu 24.04 [beam]
via GitHub
-
[PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam]
via GitHub
-
[PR] Bump docker/setup-buildx-action from 4.2.0 to 4.3.0 [beam]
via GitHub
-
[PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.0 [beam]
via GitHub
-
[PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.0 [beam]
via GitHub
-
[PR] [GSoC-273] Feat: Integrate TestPubsubContext to prevent Pub/Sub resource leaks and expand stale cleaner scope [beam]
via GitHub
-
[PR] [Spark] Fire processing-time timers in timestamp order [beam]
via GitHub
-
[I] [Bug]: Spark streaming fires processing-time timers in reverse timestamp order [beam]
via GitHub
-
[PR] [Spark] Retain the last watermark of a source with no update in the batch [beam]
via GitHub
-
[I] [Bug]: Spark streaming drops the stored watermark of a source with no update in a batch [beam]
via GitHub
-
[I] [Bug]: Spanner Change Streams reading have potential data loss when the dataflow worker has high CPU utilization [beam]
via GitHub
-
[PR] bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing [beam]
via GitHub
-
[PR] [#18194] Include all per-module JaCoCo execution data in jacocoTestReport [beam]
via GitHub
-
[PR] JmsIO yaml [beam]
via GitHub
-
Re: [I] [Feature Request]: Upgrade to Iceberg >1.7.0 and support timestamp nano types [beam]
via GitHub
-
Re: [I] [Feature Request]: Add Postcommit Dataflow ARM tests for Java and Python [beam]
via GitHub
-
Re: [I] [Bug]: Eliminate field sorting in Beam schema-aware transforms which can result in compatibility issues [beam]
via GitHub
-
[PR] Set getSession to synchronized to avoid race conditions [beam]
via GitHub
-
[PR] Fix race condition in getSession() [beam]
via GitHub
-
Re: [PR] [Prism] Add more logging to debug [beam]
via GitHub
-
[PR] Bump ClassGraph from 4.8.162 to 4.8.192 [beam]
via GitHub
-
[PR] Bump github.com/nats-io/nats-server/v2 from 2.14.4 to 2.14.5 in /sdks [beam]
via GitHub