Messages by Thread
-
-
[PR] [OpenTelemetry] Add tracing support to GCP Spanner IO [beam]
via GitHub
-
[PR] Write append tables can be asynchronous (#39120) [beam]
via GitHub
-
Re: [PR] [Dataflow Streaming] [Multi Key] Prepare StreamingModeExecutionContext and StreamingWorkScheduler for multi-key execution. [beam]
via GitHub
-
Re: [PR] [Dataflow Streaming] Access state/timerinternals via StepContext [beam]
via GitHub
-
Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.6.0 [beam]
via GitHub
-
[PR] Bump gradle-wrapper from 8.14.3 to 9.6.1 [beam]
via GitHub
-
[PR] Bump github.com/aws/smithy-go from 1.27.2 to 1.27.3 in /sdks [beam]
via GitHub
-
[PR] Bump cloud.google.com/go/storage from 1.62.3 to 1.63.0 in /sdks [beam]
via GitHub
-
[I] The LoadTests Python ParDo Flink Streaming job is flaky [beam]
via GitHub
-
[PR] try to fix post commit yaml test [beam]
via GitHub
-
Re: [I] [yaml] Normalize FirestoreIO [beam]
via GitHub
-
Re: [I] [yaml] Normalize MongoDBIO [beam]
via GitHub
-
Re: [I] [yaml] Normalize KinesisIO [beam]
via GitHub
-
Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam]
via GitHub
-
Re: [PR] Improve WithKeys coder inference context [beam]
via GitHub
-
[PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [PR] [BEAM] Fix Python VarIntCoder OverflowError on uint64 values [beam]
via GitHub
-
[PR] ci: pin GitHub Actions to full commit SHAs [beam]
via GitHub
-
[I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam]
via GitHub
-
[I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam]
via GitHub
-
[PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam]
via GitHub
-
[I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam]
via GitHub
-
Re: [I] [yaml] Normalize SnowflakeIO [beam]
via GitHub
-
Re: [I] [yaml] Normalize io.gcp.DicomSearch [beam]
via GitHub
-
Re: [I] [Bug]: Add system/user prefix to getId in StateTable, CachingStateTable [beam]
via GitHub
-
Re: [I] [Feature Request]: Set quota project in `beam.io.ReadFromBigQuery` [beam]
via GitHub
-
Re: [I] [Bug]: Beam roles infra - Unable to run the Dataflow TPU example [beam]
via GitHub
-
Re: [PR] Add metrics for Kafka offset commit failures [beam]
via GitHub
-
Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam]
via GitHub
-
Re: [PR] Fix dataframe warnings on ChainedAssignmentError [beam]
via GitHub
-
[PR] Deduplicate messages in PubSub ordering key integration test [beam]
via GitHub
-
Re: [I] [GSoC 2026] Kafka Streams runner — KStreamsPayload Serde (GroupByKey prerequisite) [beam]
via GitHub
-
[I] Account Keys Compliance Issue Detected [beam]
via GitHub
-
[PR] Fix a flaky test in ApproximateQuantilesTest [beam]
via GitHub
-
[I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam]
via GitHub
-
Re: [I] The IcebergIO Integration Tests job is flaky [beam]
via GitHub
-
[PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam]
via GitHub
-
[I] The PostCommit YAML Xlang Direct job is flaky [beam]
via GitHub
-
[PR] Bump gradle-wrapper from 8.12 to 9.6.1 [beam-starter-kotlin]
via GitHub
-
Re: [PR] Bump gradle-wrapper from 8.12 to 9.6.0 [beam-starter-kotlin]
via GitHub
-
[PR] fix race condition in statesampler with lock for reset [beam]
via GitHub
-
[PR] Add ValidatesRunner cross-SDK test coverage comparison [beam]
via GitHub