github  

Messages by Thread

• • Re: [PR] [GSoC 2026] Requesting permissions for the TestPubSubContext cleanup handler tests [beam] via GitHub
• [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
  • Re: [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] via GitHub
• [I] [Bug]: Bigtable Python SDK upgrade [beam] via GitHub
  • Re: [I] [Bug]: Bigtable Python SDK upgrade [beam] via GitHub
  • Re: [I] [Bug]: Bigtable Python SDK upgrade [beam] via GitHub
• [I] [Feature Request]: Bound PGBKCVOperation precombine table by in-memory size, not key count [beam] via GitHub
• [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] via GitHub
  • Re: [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] via GitHub
• [PR] Fix go GBK load test [beam] via GitHub
  • Re: [PR] Fix go GBK load test [beam] via GitHub
  • Re: [PR] Fix go GBK load test [beam] via GitHub
  • Re: [PR] Fix go GBK load test [beam] via GitHub
  • Re: [PR] Fix go GBK load test [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add open telemetry dependency to dataflow pipeline runner [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] via GitHub
• [I] [Bug]: SQL AVG rounds to 10 significant digits, flipping the sign on large BIGINT values [beam] via GitHub
• [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
  • Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] via GitHub
• Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] via GitHub
• Re: [I] [Bug]: [Beam Release Automation] Cut release branch workflow doesn't correctly kick off snapshot [beam] via GitHub
  • Re: [I] [Bug]: [Beam Release Automation] Cut release branch workflow doesn't correctly kick off snapshot [beam] via GitHub
• Re: [I] [Feature Request]: Print data type of SQL plan [beam] via GitHub
  • Re: [I] [Feature Request]: Print data type of SQL plan [beam] via GitHub
• Re: [I] [Bug]: Artifact materialization can cause a race when multiple callers materialize the same artifact in the same destination. [beam] via GitHub
  • Re: [I] [Bug]: Artifact materialization can cause a race when multiple callers materialize the same artifact in the same destination. [beam] via GitHub
• [I] [Bug]: Row.toString throws for an ITERABLE field that is not backed by a List [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner: separate source poll size from bundle size, expose the session timeout [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: separate source poll size from bundle size, expose the session timeout [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.0 to 1.107.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.0 to 1.107.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.0 to 1.107.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.0 to 1.107.1 in /sdks [beam] via GitHub
• [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
  • Re: [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner: measure how long work takes to move between instances [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: measure how long work takes to move between instances [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: measure how long work takes to move between instances [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: measure how long work takes to move between instances [beam] via GitHub
• Re: [I] [Failing Test]: beam_Playground_CI_Nightly failed at 2.70.0 [beam] via GitHub
  • Re: [I] [Failing Test]: beam_Playground_CI_Nightly failed at 2.70.0 [beam] via GitHub
• Re: [I] [Feature Request]: Support more latency, throughput, and resource usage metrics in the benchmark framework [beam] via GitHub
  • Re: [I] [Feature Request]: Support more latency, throughput, and resource usage metrics in the benchmark framework [beam] via GitHub
• [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
  • Re: [PR] Accept integral JSON values that a double represents exactly [beam] via GitHub
• [I] [Bug]: RowJson rejects integral JSON values for a DOUBLE field when they exceed int range [beam] via GitHub
• [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
  • Re: [PR] SnowflakeIO yaml [beam] via GitHub
• [PR] Add per-destination GCS CMEK support to FileIO [beam] via GitHub
  • Re: [PR] Add per-destination GCS CMEK support to FileIO [beam] via GitHub
  • Re: [PR] Add per-destination GCS CMEK support to FileIO [beam] via GitHub
• [PR] Bump github.com/testcontainers/testcontainers-go from 0.43.0 to 0.44.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.43.0 to 0.44.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.43.0 to 0.44.0 in /sdks [beam] via GitHub
• Re: [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails consistently (io expansion-service shadowJar not found) [beam] via GitHub
  • Re: [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails consistently (io expansion-service shadowJar not found) [beam] via GitHub
• [PR] [IcebergIO] add test for column default values [beam] via GitHub
  • Re: [PR] [IcebergIO] add test for column default values [beam] via GitHub
  • Re: [PR] [IcebergIO] add test for column default values [beam] via GitHub
  • Re: [PR] [IcebergIO] add test for column default values [beam] via GitHub
  • Re: [PR] [IcebergIO] add test for column default values [beam] via GitHub
• Re: [I] PipelineOptions getters can produce null even if not annotated Nullable when no Default is specified [beam] via GitHub
• [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
  • Re: [PR] Implement Vertex AI Model Monitoring v2 [beam] via GitHub
• [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] via GitHub
• Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
  • Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
  • Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner: portable ValidatesRunner suite for Python [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: portable ValidatesRunner suite for Python [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: portable ValidatesRunner suite for Python [beam] via GitHub
• [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] via GitHub
  • Re: [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] via GitHub
  • Re: [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] via GitHub
  • Re: [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] via GitHub
  • Re: [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] via GitHub
• Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] via GitHub
  • Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] via GitHub
• [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] via GitHub
  • Re: [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] via GitHub
• [PR] Bump github.com/aws/smithy-go from 1.27.6 to 1.27.7 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/smithy-go from 1.27.6 to 1.27.7 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/smithy-go from 1.27.6 to 1.27.7 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/smithy-go from 1.27.6 to 1.27.7 in /sdks [beam] via GitHub
• [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.79.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.79.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.79.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.79.1 in /sdks [beam] via GitHub
• [PR] Encode DynamoDB empty list and empty map attributes [beam] via GitHub
  • Re: [PR] Encode DynamoDB empty list and empty map attributes [beam] via GitHub
  • Re: [PR] Encode DynamoDB empty list and empty map attributes [beam] via GitHub
• [I] [Bug]: DynamoDB AttributeValueCoder cannot encode an empty list or empty map attribute [beam] via GitHub
• [PR] fix: poll publish results from all producers in SolaceIO writer [beam] via GitHub
  • Re: [PR] fix: poll publish results from all producers in SolaceIO writer [beam] via GitHub
  • Re: [PR] fix: poll publish results from all producers in SolaceIO writer [beam] via GitHub
  • Re: [PR] fix: poll publish results from all producers in SolaceIO writer [beam] via GitHub
• [PR] [GSoC 2026] Active cleanup of orphaned subscriptions for the taxirides topic [beam] via GitHub
  • Re: [PR] [GSoC 2026] Active cleanup of orphaned subscriptions for the taxirides topic [beam] via GitHub
  • Re: [PR] [GSoC 2026] Active cleanup of orphaned subscriptions for the taxirides topic [beam] via GitHub
  • Re: [PR] [GSoC 2026] Active cleanup of orphaned subscriptions for the taxirides topic [beam] via GitHub
• [PR] [Beam SQL] Introduce call procedures [beam] via GitHub
  • Re: [PR] [Beam SQL] Introduce call procedures [beam] via GitHub
  • Re: [PR] [Beam SQL] Introduce call procedures [beam] via GitHub
  • Re: [PR] [Beam SQL] Introduce call procedures [beam] via GitHub
• [PR] [Iceberg compaction] Add committer DoFn [beam] via GitHub
  • Re: [PR] [Iceberg compaction] Add committer DoFn [beam] via GitHub
• [PR] [Iceberg compaction] Rewrite subgroups DoFn [beam] via GitHub
  • Re: [PR] [Iceberg compaction] Rewrite subgroups DoFn [beam] via GitHub
• [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
  • Re: [PR] [#39723] Implement model for Iceberg side input cache [beam] via GitHub
• [I] [Feature Request]: Implement Side-Input Table Cache for IcebergIO [beam] via GitHub
• [PR] Python timestamp fixes. [beam] via GitHub
  • Re: [PR] Python timestamp fixes. [beam] via GitHub
• [PR] bump FnAPI container to beam-master-20260811 [beam] via GitHub
  • Re: [PR] bump FnAPI container to beam-master-20260811 [beam] via GitHub
  • Re: [PR] bump FnAPI container to beam-master-20260811 [beam] via GitHub
• [PR] Update Beam website to release 2.76.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.76.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.76.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.76.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.76.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.76.0 [beam] via GitHub
• [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
  • Re: [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] via GitHub
• [PR] Cp39645 [beam] via GitHub
  • Re: [PR] Cp39645 [beam] via GitHub
  • Re: [PR] Cp39645 [beam] via GitHub
  • Re: [PR] Cp39645 [beam] via GitHub
  • Re: [PR] Cp39645 [beam] via GitHub
• Re: [I] [Task]: Merge Flink runner translations ? [beam] via GitHub
  • Re: [I] [Task]: Merge Flink runner translations ? [beam] via GitHub

• Earlier messages
• Later messages