github  

Messages by Thread

• [PR] [Python] Optimize BigQuery copy jobs in file loads using multi-source copy [beam] via GitHub
  • Re: [PR] [Python] Optimize BigQuery copy jobs in file loads using multi-source copy [beam] via GitHub
  • Re: [PR] [Python] Optimize BigQuery copy jobs in file loads using multi-source copy [beam] via GitHub
• [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] via GitHub
• [PR] [GCP] Optimize BigQuery TriggerCopyJobs performance for WRITE_APPEND [beam] via GitHub
  • Re: [PR] [GCP] Optimize BigQuery TriggerCopyJobs performance for WRITE_APPEND [beam] via GitHub
  • Re: [PR] [GCP] Optimize BigQuery TriggerCopyJobs performance for WRITE_APPEND [beam] via GitHub
• [PR] Add Flink 2.2.1 runner support [beam] via GitHub
• [PR] Add unit tests to Go harness package (issue #21386) [beam] via GitHub
  • Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] via GitHub
  • Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] via GitHub
  • Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] via GitHub
  • Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] via GitHub
• [I] [Task]: Add support for Apache Flink 2.2.x runner [beam] via GitHub
• Re: [I] In WithKeys, get coder for key more safely. [beam] via GitHub
• [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 2: wire into ExecutableStageProcessor [beam] via GitHub
• [PR] Bump cloud.google.com/go/spanner from 1.91.0 to 1.92.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/spanner from 1.91.0 to 1.92.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/spanner from 1.91.0 to 1.92.0 in /sdks [beam] via GitHub
• [PR] Bump starlette from 1.2.1 to 1.3.1 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump starlette from 1.2.1 to 1.3.1 in /sdks/python/container/ml/py311 [beam] via GitHub
• [PR] Roll forward io expansion service to Java17 [beam] via GitHub
  • Re: [PR] Roll forward io expansion service to Java17 [beam] via GitHub
  • Re: [PR] Roll forward io expansion service to Java17 [beam] via GitHub
• [PR] Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/py312 [beam] via GitHub
  • Re: [PR] Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/py312 [beam] via GitHub
• [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails consistently (io expansion-service shadowJar not found) [beam] via GitHub
• [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
  • Re: [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
  • Re: [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
  • Re: [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
  • Re: [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
  • Re: [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] via GitHub
• [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
  • Re: [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] via GitHub
• [PR] [Website] Update Python version compatibility table [beam] via GitHub
  • Re: [PR] [Website] Update Python version compatibility table [beam] via GitHub
  • Re: [PR] [Website] Update Python version compatibility table [beam] via GitHub
  • Re: [PR] [Website] Update Python version compatibility table [beam] via GitHub
• [PR] Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript [beam] via GitHub
• [PR] Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript [beam] via GitHub
• [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
  • Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] via GitHub
• Re: [I] [Feature Request]: ClickHouseIO: Add DateTime64 support for sub-second timestamp precision [beam] via GitHub
• [PR] Revert "Upgrade expansion jar to java17" [beam] via GitHub
  • Re: [PR] Revert "Upgrade expansion jar to java17" [beam] via GitHub
  • Re: [PR] Revert "Upgrade expansion jar to java17" [beam] via GitHub
  • Re: [PR] Revert "Upgrade expansion jar to java17" [beam] via GitHub
• [I] Add support for Apache Flink 2.1.2 [beam] via GitHub
  • Re: [I] Add support for Apache Flink 2.1.2 [beam] via GitHub
• Re: [I] [Bug]: Java SDK Sampling Data from PCollection at the Source is redundant, since the Source already has a perfect estimate of per element size. [beam] via GitHub
• Re: [I] [Feature Request]: HuggingFacePipelineModelHandler Load Large Models on Multiple GPUs [beam] via GitHub
• Re: [I] [Bug]: ProtoCoder fails on super large protobufs [beam] via GitHub
• Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
• Re: [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] via GitHub
  • Re: [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] via GitHub
• [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
  • Re: [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
  • Re: [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
  • Re: [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
  • Re: [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
  • Re: [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] via GitHub
• [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
  • Re: [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
  • Re: [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
  • Re: [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
  • Re: [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
  • Re: [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] via GitHub
• [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
  • Re: [PR] Add support for Apache Flink 2.1.3 [beam] via GitHub
• [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
  • Re: [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] via GitHub
• [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
• [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
  • Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
• [PR] Bump distlib from 0.4.2 to 0.4.3 in /sdks/python [beam] via GitHub
  • Re: [PR] Bump distlib from 0.4.2 to 0.4.3 in /sdks/python [beam] via GitHub
• Re: [I] [Feature Request]: Add per-worker labelled/histogram metrics to BigQuery IO for the Dataflow Legacy Harness. [beam] via GitHub
• Re: [I] [Stuck Test]: GitHub Action issue_comment trigger not scalable [beam] via GitHub
• Re: [I] [RRIO] [Call] Consider many requests to one API call use cases [beam] via GitHub
  • Re: [I] [RRIO] [Call] Consider many requests to one API call use cases [beam] via GitHub
• Re: [I] [Feature Request]: gRPC connector to Dataproc Metastore [beam] via GitHub
  • Re: [I] [Feature Request]: gRPC connector to Dataproc Metastore [beam] via GitHub
• Re: [I] [Task]: Upgrade self-hosted runner base image [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
• [PR] Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py310 [beam] via GitHub
• [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] via GitHub
• Re: [I] [Task]: [RRIO] [Testing] Support a CRUD endpoint [beam] via GitHub
• Re: [I] [Task]: Also remove META-INF for excluded transitive dependencies in Beam vendored dependencies [beam] via GitHub
• Re: [I] [Task]: [RRIO] [Throttle] transform that slows down element transmission without an external resource [beam] via GitHub
• Re: [I] [Task]: Display commit history when creating a perf alert [beam] via GitHub
• Re: [I] [Playground][Frontend] : Persist editor state and SDK selection in localStorage [beam] via GitHub
• [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
  • Re: [PR] Adds a Dataflow integration test suite for Delta Lake [beam] via GitHub
• Re: [I] [Go SDK] fileio.MatchAll() cannot match all files on GCS [beam] via GitHub
• [PR] Bump pyo3 from 0.27.2 to 0.29.0 in /sdks/python/apache_beam/examples/wordcount_rust/word_processing [beam] via GitHub
  • Re: [PR] Bump pyo3 from 0.27.2 to 0.29.0 in /sdks/python/apache_beam/examples/wordcount_rust/word_processing [beam] via GitHub
• [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
  • Re: [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] via GitHub
• [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
  • Re: [PR] SQL Database DDL & Usability Improvements [beam] via GitHub
• Re: [I] Improve memory profiling for users of Portable Beam Python [beam] via GitHub
• Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
• Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] via GitHub
• Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] via GitHub
• Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.5.1 [beam] via GitHub
  • Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.5.1 [beam] via GitHub
• Re: [PR] update spotless to 7.2 and reformat [beam] via GitHub
• [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
  • Re: [PR] Update Bigquery Client [beam] via GitHub
• [PR] address DOM text reinterpreted as HTML alert [beam] via GitHub
  • Re: [PR] address DOM text reinterpreted as HTML alert [beam] via GitHub
  • Re: [PR] address DOM text reinterpreted as HTML alert [beam] via GitHub

• Earlier messages