Messages by Date
-
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
-
2026/09/25
Re: [PR] Tag the Kafka write error output with the schema it actually emits [beam]
via GitHub
-
2026/09/25
Re: [PR] Tag the Kafka write error output with the schema it actually emits [beam]
via GitHub
-
2026/09/25
Re: [PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam]
via GitHub
-
2026/09/25
Re: [I] The PostCommit Java PVR Spark4 StructuredStreaming job is flaky [beam]
via GitHub
-
2026/09/24
[PR] Fix many flaky tests [beam]
via GitHub
-
2026/09/24
Re: [PR] Restore thread interrupt status in InterruptedException catch blocks [beam]
via GitHub
-
2026/09/24
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/24
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/24
Re: [PR] Bump google.golang.org/api from 0.298.0 to 0.299.0 in /sdks [beam]
via GitHub
-
2026/09/24
[PR] Refactor test and add new ones. [beam]
via GitHub
-
2026/09/24
[PR] Bump google.golang.org/api from 0.298.0 to 0.299.0 in /sdks [beam]
via GitHub
-
2026/09/24
[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/24
[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/24
[PR] Restore thread interrupt status in InterruptedException catch blocks [beam]
via GitHub
-
2026/09/24
[PR] foo [beam]
via GitHub
-
2026/09/24
[PR] Route the remaining GCS calls through GcsUtilV2 [beam]
via GitHub
-
2026/09/24
Re: [PR] Fill gaps between GcsUtilV2 and GcsUtilV1 [beam]
via GitHub
-
2026/09/24
Re: [PR] Cherry-picking side-input Table cache renames [beam]
via GitHub
-
2026/09/24
Re: [I] [Task]: Remove support for Python 3.10 [beam]
via GitHub
-
2026/09/24
Re: [PR] [Iceberg CDC sink] Integration tests [beam]
via GitHub
-
2026/09/24
[PR] fix PostCommit GCP auth and reducing LeaderBoardIT flakiness [beam]
via GitHub
-
2026/09/24
Re: [I] [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam]
via GitHub
-
2026/09/24
Re: [PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam]
via GitHub
-
2026/09/24
[PR] Cherry-picking side-input Table cache renames [beam]
via GitHub
-
2026/09/24
Re: [PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/24
Re: [PR] Speed up Beam presubmits [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam]
via GitHub
-
2026/09/24
[PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam]
via GitHub
-
2026/09/24
Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam]
via GitHub
-
2026/09/24
Re: [PR] Support NanosInstant logical type when writing schemas to BigQuery [beam]
via GitHub
-
2026/09/24
Re: [PR] Fill gaps between GcsUtilV2 and GcsUtilV1 [beam]
via GitHub
-
2026/09/24
[PR] Some followup fixups to the schema-update code [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix nullness in extensions/avro [beam]
via GitHub
-
2026/09/24
Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam]
via GitHub
-
2026/09/24
Re: [PR] normalize BigQuery CDC [beam]
via GitHub
-
2026/09/24
Re: [PR] [Website] Add Asgarde, an error handling library, to the 3rd party Java extensions [beam]
via GitHub
-
2026/09/24
Re: [PR] [BigQueryIO] Improve error message when BigQuery API is reported as not enabled [beam]
via GitHub
-
2026/09/24
Re: [PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam]
via GitHub
-
2026/09/24
Re: [PR] all test speedups [beam]
via GitHub
-
2026/09/24
Re: [PR] Cherrypicking Iceberg CDC sink schematransform [beam]
via GitHub
-
2026/09/24
Re: [PR] Cherrypicking Iceberg CDC sink schematransform [beam]
via GitHub
-
2026/09/24
Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam]
via GitHub
-
2026/09/24
[PR] [Website] Add Asgarde, an error handling library, to the 3rd party Java extensions [beam]
via GitHub
-
2026/09/24
[PR] Cherrypicking Iceberg CDC sink schematransform [beam]
via GitHub
-
2026/09/24
[PR] Support NanosInstant logical type when writing schemas to BigQuery [beam]
via GitHub
-
2026/09/24
Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam]
via GitHub
-
2026/09/24
Re: [I] Cannot write "google.protobuf.Timestamp" (NanosInstant) to BigQuery through schemas [beam]
via GitHub
-
2026/09/24
Re: [I] Cannot write "google.protobuf.Timestamp" (NanosInstant) to BigQuery through schemas [beam]
via GitHub
-
2026/09/24
Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam]
via GitHub
-
2026/09/24
[I] [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element [beam]
via GitHub
-
2026/09/24
[PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam]
via GitHub
-
2026/09/24
Re: [I] [Feature Request]: Allow disable user metrics in Python SDK [beam]
via GitHub
-
2026/09/24
Re: [PR] [Beam SQL] Introduce call procedures [beam]
via GitHub
-
2026/09/24
Re: [PR] [Python] Round float seconds to the nearest microsecond in Duration [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Duration(float seconds) truncates instead of rounding, losing a microsecond [beam]
via GitHub
-
2026/09/24
[I] [Bug]: Duration(float seconds) truncates instead of rounding, losing a microsecond [beam]
via GitHub
-
2026/09/24
Re: [PR] [Gemini] Migrate Python BigQuery off of apitools client [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Spark Structured Streaming Runner memory leak: Datasets are persisted but never unpersisted in `ParDoTranslatorBatch` [beam]
via GitHub
-
2026/09/24
Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam]
via GitHub
-
2026/09/24
Re: [PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/24
Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam]
via GitHub
-
2026/09/24
Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam]
via GitHub
-
2026/09/24
Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam]
via GitHub
-
2026/09/24
Re: [PR] Cherry pick AddFiles: Add dry_run (#40167) [beam]
via GitHub
-
2026/09/24
Re: [PR] Round float seconds to nearest subsecond unit in Timestamp constructor [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Timestamp(float seconds) truncates instead of rounding, losing a microsecond [beam]
via GitHub
-
2026/09/24
Re: [I] The PostCommit Java PVR Spark4 StructuredStreaming job is flaky [beam]
via GitHub
-
2026/09/24
Re: [I] [Task]: Update Python slowly updating side input example [beam]
via GitHub
-
2026/09/24
Re: [PR] Close harness data/state channels and don't Recv on Send EOF [beam]
via GitHub
-
2026/09/24
Re: [I] Eliminate nullability errors from :sdks:java:extensions:google-cloud-platform-core [beam]
via GitHub
-
2026/09/24
Re: [PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix JaCoCo coverage for multiple test tasks. [beam]
via GitHub
-
2026/09/24
Re: [PR] Fix JaCoCo coverage for multiple test tasks. [beam]
via GitHub
-
2026/09/24
Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam]
via GitHub
-
2026/09/24
Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam]
via GitHub
-
2026/09/24
Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Schema providers of different types don't nest. [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Schema providers of different types don't nest. [beam]
via GitHub
-
2026/09/24
Re: [PR] [Go] Fix pubsubio import of removed genproto package [beam]
via GitHub
-
2026/09/24
Re: [PR] [Python] Round float seconds to the nearest unit in Timestamp and Duration [beam]
via GitHub
-
2026/09/24
Re: [PR] [Python] Round float seconds to the nearest unit in Timestamp and Duration [beam]
via GitHub
-
2026/09/24
Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam]
via GitHub
-
2026/09/24
Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam]
via GitHub
-
2026/09/24
Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam]
via GitHub
-
2026/09/24
Re: [PR] Close harness data/state channels and don't Recv on Send EOF [beam]
via GitHub
-
2026/09/24
Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam]
via GitHub
-
2026/09/24
[PR] Close harness data/state channels; don't Recv on Send EOF [beam]
via GitHub
-
2026/09/24
[PR] Bigtable CDC yaml [beam]
via GitHub
-
2026/09/24
Re: [I] [Bug]: Go harness leaks gRPC connections and can deadlock when closing streams [beam]
via GitHub
-
2026/09/24
[I] [Bug]: Go harness leaks gRPC connections and can deadlock when closing streams [beam]
via GitHub
-
2026/09/24
Re: [PR] normalize BigQuery CDC [beam]
via GitHub
-
2026/09/24
Re: [PR] all test speedups [beam]
via GitHub
-
2026/09/23
Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam]
via GitHub
-
2026/09/23
Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam]
via GitHub
-
2026/09/23
Re: [PR] Round float seconds to nearest subsecond unit in Timestamp constructor [beam]
via GitHub
-
2026/09/23
[PR] all test speedups [beam]
via GitHub
-
2026/09/23
[PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam]
via GitHub
-
2026/09/23
[PR] Round float seconds to nearest subsecond unit in Timestamp constructor [beam]
via GitHub
-
2026/09/23
Re: [I] [Bug]: Timestamp(float seconds) truncates instead of rounding, losing a microsecond [beam]
via GitHub
-
2026/09/23
Re: [I] [Feature Request]: Create a merge-on-read Iceberg sink [beam]
via GitHub
-
2026/09/23
Re: [PR] [Iceberg CDC sink] SchemaTransform (ManagedIO) layer [beam]
via GitHub
-
2026/09/23
[I] The PostCommit Java PVR Spark4 StructuredStreaming job is flaky [beam]
via GitHub
-
2026/09/23
Re: [PR] Reduce severity for state requests cancelled by runner [beam]
via GitHub
-
2026/09/23
Re: [PR] Cherry pick AddFiles: Add dry_run (#40167) [beam]
via GitHub
-
2026/09/23
Re: [PR] Cherry pick AddFiles: Add dry_run (#40167) [beam]
via GitHub
-
2026/09/23
[PR] Cherry pick AddFiles: Add dry_run (#40167) [beam]
via GitHub
-
2026/09/23
[PR] Reduce severity for state requests cancelled by runner [beam]
via GitHub
-
2026/09/23
Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks [beam]
via GitHub
-
2026/09/23
Re: [PR] Clean up ruff breakage findings [beam]
via GitHub
-
2026/09/23
Re: [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam]
via GitHub
-
2026/09/23
Re: [PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/23
Re: [PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/23
[PR] Rename Iceberg table cache options for clarity [beam]
via GitHub
-
2026/09/23
Re: [PR] [Iceberg CDC sink] SchemaTransform (ManagedIO) layer [beam]
via GitHub
-
2026/09/23
Re: [PR] [Iceberg CDC sink] SchemaTransform (ManagedIO) layer [beam]
via GitHub
-
2026/09/23
Re: [I] [Task]: Update BigTable to Bigtable to match industry standards [beam]
via GitHub
-
2026/09/23
Re: [PR] update BigTable to Bigtable for non-yaml related files [beam]
via GitHub
-
2026/09/23
Re: [PR] [release-2.77] [Spanner Change Streams] Leave tracker at last claimed position instead of artificial query end timestamp [beam]
via GitHub