github  

Messages by Date

• 2026/09/28 Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] via GitHub
• 2026/09/28 [PR] Clarify element processing timeout help text [beam] via GitHub
• 2026/09/28 Re: [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [beam] via GitHub
• 2026/09/28 Re: [PR] [Website] Add Asgarde, an error handling library, to the 3rd party Java extensions [beam] via GitHub
• 2026/09/28 Re: [PR] DNR! POC! Merge validates runner phase2 [beam] via GitHub
• 2026/09/28 Re: [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] via GitHub
• 2026/09/28 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
• 2026/09/28 Re: [I] [IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected [beam] via GitHub
• 2026/09/28 Re: [I] [IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected [beam] via GitHub
• 2026/09/27 Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.8.0 [beam] via GitHub
• 2026/09/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.8 to 1.23.10 in /sdks [beam] via GitHub
• 2026/09/27 Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.0 to 1.47.1 in /sdks [beam] via GitHub
• 2026/09/27 Re: [PR] Bump cloud.google.com/go/bigquery from 1.84.0 to 1.85.0 in /sdks [beam] via GitHub
• 2026/09/27 Re: [PR] Bump cloud.google.com/go/datastore from 1.26.0 to 1.27.0 in /sdks [beam] via GitHub
• 2026/09/27 Re: [I] [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element [beam] via GitHub
• 2026/09/27 Re: [PR] DNR! POC! Merge validates runner phase2 [beam] via GitHub
• 2026/09/27 [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.0 to 1.47.1 in /sdks [beam] via GitHub
• 2026/09/27 [PR] Bump cloud.google.com/go/bigquery from 1.84.0 to 1.85.0 in /sdks [beam] via GitHub
• 2026/09/27 [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.8 to 1.23.10 in /sdks [beam] via GitHub
• 2026/09/27 [PR] Bump github/codeql-action from 4.38.1 to 4.38.2 [beam] via GitHub
• 2026/09/27 [PR] Bump cloud.google.com/go/datastore from 1.26.0 to 1.27.0 in /sdks [beam] via GitHub
• 2026/09/27 [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.113.2 to 1.113.4 in /sdks [beam] via GitHub
• 2026/09/27 [PR] Bump gradle-wrapper from 8.14.3 to 9.8.0 [beam] via GitHub
• 2026/09/27 Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] via GitHub
• 2026/09/27 Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] via GitHub
• 2026/09/27 Re: [PR] DNR! POC! Merge validates runner phase2 [beam] via GitHub
• 2026/09/27 Re: [PR] DNR! POC! Merge validates runner phase2 [beam] via GitHub
• 2026/09/27 Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam] via GitHub
• 2026/09/27 [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam] via GitHub
• 2026/09/27 [PR] DNR! POC! Merge validates runner phase2 [beam] via GitHub
• 2026/09/27 Re: [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/27 Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] via GitHub
• 2026/09/27 Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] via GitHub
• 2026/09/27 [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] via GitHub
• 2026/09/27 Re: [PR] Fix IcebergIO failing to write EnumerationType (proto enum) fields [beam] via GitHub
• 2026/09/27 Re: [I] [Bug]: ValueError: Invalid DisplayDataItem when using AsSingleton for side input (need better parameter validation before it hits this) [beam] via GitHub
• 2026/09/27 Re: [I] [Bug]: Python ReadFromMongoDB/RangeTracker raises OverflowError [beam] via GitHub
• 2026/09/27 Re: [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/27 Re: [PR] [BEAM-20503] Replace inert nullness suppressions in BigQueryIOPushDownIT [beam] via GitHub
• 2026/09/27 Re: [PR] [BEAM-20503] Replace inert nullness suppressions in BigQueryIOPushDownIT [beam] via GitHub
• 2026/09/27 [PR] [BEAM-20503] Replace inert nullness suppressions in BigQueryIOPushDownIT [beam] via GitHub
• 2026/09/27 Re: [I] Eliminate nullability errors from :sdks:java:extensions:sorter [beam] via GitHub
• 2026/09/27 [PR] Fix IcebergIO failing to write EnumerationType (proto enum) fields [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Java tests [beam] via GitHub
• 2026/09/27 Re: [I] [Bug]: IcebergIO cannot write Beam rows containing EnumerationType (proto enum) fields [beam] via GitHub
• 2026/09/27 [I] [Bug]: IcebergIO cannot write Beam rows containing EnumerationType (proto enum) fields [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Java tests [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Python tests [beam] via GitHub
• 2026/09/27 Re: [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/27 Re: [PR] Merge runtime type-checking wrappers into a single layer (BEAM-9489) [beam] via GitHub
• 2026/09/27 Re: [PR] Merge runtime type-checking wrappers into a single layer (BEAM-9489) [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Prism tests [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Java tests [beam] via GitHub
• 2026/09/27 Re: [PR] Fix flaky Python tests [beam] via GitHub
• 2026/09/26 Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• 2026/09/26 Re: [PR] Treat a 404 from BigQuery table and dataset deletes as success [beam] via GitHub
• 2026/09/26 [PR] Fix flaky Java tests [beam] via GitHub
• 2026/09/26 [PR] Fix flaky Python tests [beam] via GitHub
• 2026/09/26 [PR] Fix flaky Prism tests [beam] via GitHub
• 2026/09/26 Re: [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/26 Re: [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/26 [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] via GitHub
• 2026/09/26 Re: [PR] [Java] Bound pending Watch results per poll [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam] via GitHub
• 2026/09/26 Re: [I] Improve scalability of the Watch transform [beam] via GitHub
• 2026/09/26 Re: [I] Improve scalability of the Watch transform [beam] via GitHub
• 2026/09/26 [PR] [Java] Bound pending Watch results per poll [beam] via GitHub
• 2026/09/26 Re: [PR] [Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Add a Beam utility for efficiently copying files across file-systems [beam] via GitHub
• 2026/09/26 Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Add library stubs or py.typed marker [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Add a test suite for the transform service [beam] via GitHub
• 2026/09/26 Re: [PR] Add SINGLE_VALUE aggregate function [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Support default log level and log level overrides for java direct runner [beam] via GitHub
• 2026/09/26 Re: [PR] Decorrelate sub-queries using normalizeForVolcano pass [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Add a test suite for the transform service [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Add library stubs or py.typed marker [beam] via GitHub
• 2026/09/26 Re: [I] [Feature Request]: Support default log level and log level overrides for java direct runner [beam] via GitHub
• 2026/09/26 Re: [PR] Add parser conformance resolution and logical plan parsing [beam] via GitHub
• 2026/09/26 Re: [PR] Remove upper bound pin for cryptography. [beam] via GitHub
• 2026/09/26 Re: [PR] [POC] Improve ValidatesRunner performance. Phase 0 [beam] via GitHub
• 2026/09/26 Re: [PR] [POC] Improve ValidatesRunner performance. Phase 0 [beam] via GitHub
• 2026/09/26 Re: [PR] [Python] Fix ParquetIO silently corrupting data across windows in unbounded pipelines [beam] via GitHub
• 2026/09/25 Re: [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2026/09/25 [PR] [Python] Fix ParquetIO silently corrupting data across windows in unbounded pipelines [beam] via GitHub
• 2026/09/25 Re: [I] [Bug]: Python `ParquetIO` `_WriteBatches` DoFn silently corrupts data across windows in unbounded pipelines [beam] via GitHub
• 2026/09/25 [PR] [POC] Improve ValidatesRunner performance. Phase 0 [beam] via GitHub
• 2026/09/25 [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2026/09/25 [I] The PostCommit SQL job is flaky [beam] via GitHub
• 2026/09/25 [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
• 2026/09/25 [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit SQL job is flaky [beam] via GitHub
• 2026/09/25 Re: [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] Fix many flaky tests [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [I] [Failing Test]: PulsarIOTest.testRead is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] Make PulsarIOTest.testRead order-independent [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [PR] Addfiles partition bounds fixes [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Make PulsarIOTest.testRead order-independent [beam] via GitHub
• 2026/09/25 Re: [PR] Deflake JmsIOTest checkpoint and authentication tests [beam] via GitHub
• 2026/09/25 Re: [PR] Update list of stale bq dataset [beam] via GitHub
• 2026/09/25 Re: [PR] [Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter [beam] via GitHub
• 2026/09/25 Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• 2026/09/25 [PR] Make PulsarIOTest.testRead order-independent [beam] via GitHub
• 2026/09/25 [PR] Deflake JmsIOTest checkpoint and authentication tests [beam] via GitHub
• 2026/09/25 Re: [I] [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ) [beam] via GitHub
• 2026/09/25 Re: [I] [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ) [beam] via GitHub
• 2026/09/25 [I] [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ) [beam] via GitHub
• 2026/09/25 Re: [I] [Failing Test]: JmsIOTest. testCheckpointMark flaky [beam] via GitHub
• 2026/09/25 Re: [I] [Failing Test]: PulsarIOTest.testRead is flaky [beam] via GitHub
• 2026/09/25 [I] [Failing Test]: PulsarIOTest.testRead is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Add examples for cloudsql [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [PR] Update list of stale bq dataset [beam] via GitHub
• 2026/09/25 Re: [PR] fix bigtable schema issue [beam] via GitHub
• 2026/09/25 Re: [PR] [Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter [beam] via GitHub
• 2026/09/25 Re: [I] [Bug]: pubsubio imports google.golang.org/genproto/googleapis/pubsub/v1, which was removed from current genproto releasess [beam] via GitHub
• 2026/09/25 Re: [PR] [Go] Fix pubsubio import of removed genproto package [beam] via GitHub
• 2026/09/25 Re: [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam] via GitHub
• 2026/09/25 Re: [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam] via GitHub
• 2026/09/25 Re: [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam] via GitHub
• 2026/09/25 [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam] via GitHub
• 2026/09/25 [PR] Update list of stale bq dataset [beam] via GitHub
• 2026/09/25 Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam] via GitHub
• 2026/09/25 Re: [PR] [Iceberg CDC sink] Integration tests [beam] via GitHub
• 2026/09/25 Re: [PR] Fix many flaky tests [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Fix many flaky tests [beam] via GitHub
• 2026/09/25 Re: [PR] Resolve ParquetIO cross-window state leakage in unbounded pipelines [beam] via GitHub
• 2026/09/25 Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Cherry-picking side-input Table cache renames [beam] via GitHub
• 2026/09/25 Re: [PR] Cherry-picking side-input Table cache renames [beam] via GitHub
• 2026/09/25 Re: [PR] Resolve DaskRunner side input OOM by iteratively computing delayed partition [beam] via GitHub
• 2026/09/25 Re: [PR] Speed up Beam presubmits [beam] via GitHub
• 2026/09/25 Re: [PR] Some followup fixups to the schema-update code [beam] via GitHub
• 2026/09/25 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
• 2026/09/25 Re: [PR] Fix new flaky schema test [beam] via GitHub
• 2026/09/25 Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
• 2026/09/25 [I] The PreCommit YAML Xlang Direct job is perma-red [beam] via GitHub
• 2026/09/25 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
• 2026/09/25 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
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] via GitHub
• 2026/09/25 [PR] Resolve ParquetIO cross-window state leakage in unbounded pipelines [beam] via GitHub
• 2026/09/25 [I] [Bug]: Python `ParquetIO` `_WriteBatches` DoFn silently corrupts data across windows in unbounded pipelines [beam] via GitHub
• 2026/09/25 [I] [Bug]: DaskRunner `DaskBagWindowedIterator` materializes entire dataset into memory causing OOM [beam] via GitHub
• 2026/09/25 [PR] Resolve DaskRunner side input OOM by iteratively computing delayed partition [beam] via GitHub
• 2026/09/25 Re: [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] via GitHub
• 2026/09/25 Re: [PR] fix flaky python tests [beam] via GitHub
• 2026/09/25 Re: [PR] Reduce severity for state requests cancelled by runner [beam] via GitHub
• 2026/09/25 Re: [PR] fix flaky python tests [beam] via GitHub
• 2026/09/25 Re: [PR] Fix many flaky tests [beam] via GitHub
• 2026/09/25 Re: [PR] Add test case verifying metric capture in Setup() lifecycle method [beam] via GitHub
• 2026/09/25 Re: [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] Cherrypicking Iceberg CDC sink schematransform [beam] via GitHub
• 2026/09/25 Re: [PR] Prevent CommitTooLargeException in OrderedEventProcessor on duplicate floods [beam] via GitHub
• 2026/09/25 [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] via GitHub
• 2026/09/25 Re: [PR] Prevent CommitTooLargeException in OrderedEventProcessor on duplicate floods [beam] via GitHub
• 2026/09/25 Re: [PR] fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss [beam] via GitHub
• 2026/09/25 Re: [PR] Add BigQueryIO support for clone table creation [beam] via GitHub
• 2026/09/25 Re: [I] [Task]: Add 3.13 GPU containers when dependencies are ready [beam] via GitHub
• 2026/09/25 Re: [I] [Task]: Add 3.13 GPU containers when dependencies are ready [beam] via GitHub
• 2026/09/25 Re: [I] Duplicate ShardedKey implementations in core module [beam] via GitHub
• 2026/09/25 Re: [I] Duplicate ShardedKey implementations in core module [beam] via GitHub
• 2026/09/25 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.7 to 1.23.8 in /sdks [beam] via GitHub
• 2026/09/25 Re: [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] via GitHub
• 2026/09/25 Re: [PR] Add test case verifying metric capture in Setup() lifecycle method [beam] via GitHub
• 2026/09/25 Re: [PR] Portable Time type (Java + model changes) [beam] via GitHub
• 2026/09/25 Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
• 2026/09/25 Re: [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] via GitHub
• 2026/09/25 Re: [PR] Adds drain support to Spanner CDC source. [beam] via GitHub
• 2026/09/25 Re: [PR] Update Beam website to release 2.77.0 [beam] via GitHub
• 2026/09/25 Re: [PR] Add OpenTelemetry tracing support to SolaceIO [beam] via GitHub
• 2026/09/25 Re: [PR] Bump google.golang.org/api from 0.298.0 to 0.299.0 in /sdks [beam] via GitHub
• 2026/09/25 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.113.1 to 1.113.2 in /sdks [beam] via GitHub
• 2026/09/25 Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] via GitHub
• 2026/09/25 Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
• 2026/09/25 Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• 2026/09/25 Re: [PR] Fix new flaky schema test [beam] via GitHub
• 2026/09/25 Re: [PR] Fix nullness in extensions/avro [beam] via GitHub
• 2026/09/25 Re: [PR] reduce LeaderBoardIT flakiness [beam] via GitHub
• 2026/09/25 Re: [PR] Some followup fixups to the schema-update code [beam] via GitHub
• 2026/09/25 Re: [PR] Fix many flaky tests [beam] via GitHub
• 2026/09/25 Re: [PR] [BigQueryIO] Improve error message when BigQuery API is reported as not enabled [beam] via GitHub
• 2026/09/25 Re: [PR] [BigQueryIO] Improve error message when BigQuery API is reported as not enabled [beam] via GitHub
• 2026/09/25 Re: [PR] [BigQueryIO] Improve error message when BigQuery API is reported as not enabled [beam] via GitHub

• Earlier messages
• Later messages