github  

Messages by Thread

• [PR] [Spark] Fire processing-time timers in timestamp order [beam] via GitHub
  • Re: [PR] [Spark] Fire processing-time timers in timestamp order [beam] via GitHub
  • Re: [PR] [Spark] Fire processing-time timers in timestamp order [beam] via GitHub
  • Re: [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
  • Re: [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
  • Re: [PR] [Spark] Retain the last watermark of a source with no update in the batch [beam] via GitHub
  • Re: [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
  • Re: [I] [Bug]: Spark streaming drops the stored watermark of a source with no update in a batch [beam] via GitHub
  • Re: [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
  • Re: [I] [Bug]: Spanner Change Streams reading have potential data loss when the dataflow worker has high CPU utilization [beam] via GitHub
  • Re: [I] [Bug]: Spanner Change Streams reading have potential data loss when the dataflow worker has high CPU utilization [beam] via GitHub
  • Re: [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
  • Re: [PR] bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing [beam] via GitHub
  • Re: [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
  • Re: [PR] [#18194] Include all per-module JaCoCo execution data in jacocoTestReport [beam] via GitHub
  • Re: [PR] [#18194] Include all per-module JaCoCo execution data in jacocoTestReport [beam] via GitHub
  • Re: [PR] [#18194] Include all per-module JaCoCo execution data in jacocoTestReport [beam] via GitHub
• [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [PR] JmsIO yaml [beam] via GitHub
  • Re: [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]: 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
  • 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
  • Re: [PR] Set getSession to synchronized to avoid race conditions [beam] via GitHub
  • Re: [PR] Set getSession to synchronized to avoid race conditions [beam] via GitHub
• [PR] Fix race condition in getSession() [beam] via GitHub
  • Re: [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
  • Re: [PR] Bump ClassGraph from 4.8.162 to 4.8.192 [beam] via GitHub
  • Re: [PR] Bump ClassGraph from 4.8.162 to 4.8.192 [beam] via GitHub
  • Re: [PR] Bump ClassGraph from 4.8.162 to 4.8.192 [beam] via GitHub
  • Re: [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
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.4 to 2.14.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.4 to 2.14.5 in /sdks [beam] via GitHub
• [PR] Bump google.golang.org/protobuf from 1.36.11 to 1.36.12 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/protobuf from 1.36.11 to 1.36.12 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/protobuf from 1.36.11 to 1.36.12 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks [beam] via GitHub
• [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
  • Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] via GitHub
• [PR] Bump github.com/moby/go-archive from 0.2.0 to 0.3.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/go-archive from 0.2.0 to 0.3.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/go-archive from 0.2.0 to 0.3.0 in /sdks [beam] via GitHub
• [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py312 [beam] via GitHub
• [PR] [IcebergIO] Ensure compliance with table encryption [beam] via GitHub
  • Re: [PR] [IcebergIO] Ensure compliance with table encryption [beam] via GitHub
  • Re: [PR] [IcebergIO] Ensure compliance with table encryption [beam] via GitHub
• Re: [PR] [GSoC-273] Fixing the github action Unmanaged Service Account Keys [beam] via GitHub
  • Re: [PR] [GSoC-273] Fixing the github action Unmanaged Service Account Keys [beam] via GitHub
  • Re: [PR] [GSoC-273] Fixing the github action Unmanaged Service Account Keys [beam] via GitHub
• [PR] Remove nullness suppression in trigger implementation [beam] via GitHub
  • Re: [PR] Remove nullness suppression in trigger implementation [beam] via GitHub
  • Re: [PR] Remove nullness suppression in trigger implementation [beam] via GitHub
• [PR] Support secret manager for jdbcio in python, java and yaml [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
  • Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] via GitHub
• [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
  • Re: [PR] Update SKILLs based on review practice [beam] via GitHub
• [PR] Portable Time type (Java + model changes) [beam] via GitHub
  • Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
  • Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
  • Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
  • Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
  • Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
• Re: [I] [Bug][prism]: Stand alone binary should fail if unable to bind port + allow specifying Job Management + UI ports. [beam] via GitHub
• Re: [I] [Task]: Handle time.Time and time.Duration in Go xlang [beam] via GitHub
• Re: [I] [Feature Request]: Make SerializableConfiguration cacheable [beam] via GitHub
  • Re: [I] [Feature Request]: Make SerializableConfiguration cacheable [beam] via GitHub
• [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] via GitHub
• [PR] Bump golang.org/x/net from 0.57.0 to 0.58.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.57.0 to 0.58.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.57.0 to 0.58.0 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.36 to 1.32.37 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.36 to 1.32.37 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.36 to 1.32.37 in /sdks [beam] via GitHub
• [PR] [Python] Improve GroupByKey coder validation errors [beam] via GitHub
  • Re: [PR] [Python] Improve GroupByKey coder validation errors [beam] via GitHub
  • Re: [PR] [Python] Improve GroupByKey coder validation errors [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.1 to 1.107.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.1 to 1.107.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.1 to 1.107.2 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.5 to 1.43.6 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.5 to 1.43.6 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.5 to 1.43.6 in /sdks [beam] via GitHub
• [PR] Bump github.com/nats-io/nats.go from 1.52.0 to 1.53.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats.go from 1.52.0 to 1.53.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats.go from 1.52.0 to 1.53.1 in /sdks [beam] via GitHub
• [PR] Updates Dataflow Python container [beam] via GitHub
  • Re: [PR] Updates Dataflow Python container [beam] via GitHub
  • Re: [PR] Updates Dataflow Python container [beam] via GitHub
  • Re: [PR] Updates Dataflow Python container [beam] via GitHub
• [PR] Fix FlinkOrderedListState: preserve elements with same timestamp [beam] via GitHub
  • Re: [PR] Fix FlinkOrderedListState: preserve elements with same timestamp [beam] via GitHub
• Re: [I] The PostCommit Java ValidatesRunner ULR job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Java ValidatesRunner ULR job is flaky [beam] via GitHub
• [PR] Fix Duplicated Subscription Path in stale_cleaner.py [beam] via GitHub
  • Re: [PR] [GSoC 2026] Fix Duplicated Subscription Path in stale_cleaner.py [beam] via GitHub
  • Re: [PR] [GSoC 2026] Fix Duplicated Subscription Path in stale_cleaner.py [beam] via GitHub
• [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
  • Re: [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] via GitHub
• [PR] bigtable: Set Apache Beam user agent for Python BigtableIO write client [beam] via GitHub
  • Re: [PR] bigtable: Set Apache Beam user agent for Python BigtableIO write client [beam] via GitHub
  • Re: [PR] bigtable: Set Apache Beam user agent for Python BigtableIO write client [beam] via GitHub
• [PR] Merge master into feat/18479-kafka-streams-runner-skeleton [beam] via GitHub
  • Re: [PR] Merge master into feat/18479-kafka-streams-runner-skeleton [beam] via GitHub
  • Re: [PR] Merge master into feat/18479-kafka-streams-runner-skeleton [beam] via GitHub
  • Re: [PR] Merge master into feat/18479-kafka-streams-runner-skeleton [beam] via GitHub
• [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
  • Re: [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [beam] via GitHub
  • Re: [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [beam] via GitHub
• [I] [Bug]: [beam] via GitHub
  • Re: [I] [Bug]:KafkaIO OAUTHBEARER auth against GCP Managed Service for Apache Kafka broken starting 2.69.0 (works on 2.68.0) [beam] via GitHub
• Re: [I] [Bug]: Unpin spanner client version until the version from libraries-bom catches up [beam] via GitHub
  • Re: [I] [Bug]: Unpin spanner client version until the version from libraries-bom catches up [beam] via GitHub
• Re: [I] [Bug]: grpc: error while marshaling: string field contains invalid UTF-8 [beam] via GitHub
  • Re: [I] [Bug]: grpc: error while marshaling: string field contains invalid UTF-8 [beam] via GitHub
• Re: [PR] [IcebergIO] Let hash distribution mode spill over if file gets too large [beam] via GitHub
  • Re: [PR] [IcebergIO] Let hash distribution mode spill over if file gets too large [beam] via GitHub
  • Re: [PR] [IcebergIO] Let hash distribution mode spill over if file gets too large [beam] via GitHub
• Re: [I] [Feature Request]: Simplify schema fetching in ClickHouseIO by leveraging Java Client v2's built-in getTableSchema [beam] via GitHub
  • Re: [I] [Feature Request]: Simplify schema fetching in ClickHouseIO by leveraging Java Client v2's built-in getTableSchema [beam] via GitHub
• Re: [I] [Task]: Migrate from SourceFunction API to Source API for Flink runner [beam] via GitHub
  • Re: [I] [Task]: Migrate from SourceFunction API to Source API for Flink runner [beam] via GitHub
• Re: [I] [Task]: Python schema generated types uses schema registry and coder registry [beam] via GitHub
• [PR] Fix stale broken cluster connection in CassandraIO [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO [beam] via GitHub
  • Re: [PR] Fix stale broken cluster connection in CassandraIO [beam] via GitHub
• [PR] [DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged [beam] via GitHub
  • Re: [PR] [DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged [beam] via GitHub
  • Re: [PR] [DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner: update the CHANGES.md entry [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner: update the CHANGES.md entry [beam] via GitHub
• [PR] [WIP] Merge Kafka Streams Runner skeleton [beam] via GitHub
  • Re: [PR] [WIP] Merge Kafka Streams Runner skeleton [beam] via GitHub

• Earlier messages
• Later messages