github  

Messages by Thread

• • Re: [PR] fix post commit yaml test [beam] via GitHub
  • Re: [PR] fix post commit yaml test [beam] via GitHub
  • Re: [PR] fix post commit yaml test [beam] via GitHub
  • Re: [PR] fix post commit yaml test [beam] via GitHub
  • Re: [PR] 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 MongoDBIO [beam] via GitHub
• Re: [I] [yaml] Normalize KinesisIO [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
• [PR] ci: pin GitHub Actions to full commit SHAs [beam] via GitHub
  • Re: [PR] ci: pin GitHub Actions to full commit SHAs [beam] via GitHub
  • Re: [PR] ci: pin GitHub Actions to full commit SHAs [beam] via GitHub
  • Re: [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
  • Re: [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
  • Re: [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] via GitHub
  • Re: [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] via GitHub
  • Re: [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] via GitHub
  • Re: [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] via GitHub
  • Re: [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] via GitHub
  • Re: [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] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] via GitHub
  • Re: [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] [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] [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] Fix dataframe warnings on ChainedAssignmentError [beam] via GitHub
• [PR] Deduplicate messages in PubSub ordering key integration test [beam] via GitHub
  • Re: [PR] Deduplicate messages in PubSub ordering key integration test [beam] via GitHub
  • Re: [PR] Deduplicate messages in PubSub ordering key integration test [beam] via GitHub
  • Re: [PR] Deduplicate messages in PubSub ordering key integration test [beam] via GitHub
  • Re: [PR] Fix flaky PubSub integration test by deduplicating messages [beam] via GitHub
  • Re: [PR] Fix flaky PubSub integration test by deduplicating messages [beam] via GitHub
  • Re: [PR] Fix flaky PubSub integration test by deduplicating messages [beam] via GitHub
• [I] Account Keys Compliance Issue Detected [beam] via GitHub
  • Re: [I] Account Keys Compliance Issue Detected [beam] via GitHub
  • Re: [I] Account Keys Compliance Issue Detected [beam] via GitHub
  • [I] Account Keys Compliance Issue Detected [beam] via GitHub
  • Re: [I] Account Keys Compliance Issue Detected [beam] via GitHub
• [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [PR] Fix a flaky test in ApproximateQuantilesTest [beam] via GitHub
  • Re: [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] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] via GitHub
• [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] via GitHub
  • Re: [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] via GitHub
  • Re: [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] via GitHub
  • Re: [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] via GitHub
  • Re: [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] via GitHub
  • Re: [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
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [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
• [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
  • Re: [PR] fix race condition in statesampler with lock for reset [beam] via GitHub
• [PR] Add ValidatesRunner cross-SDK test coverage comparison [beam] via GitHub
• Re: [I] Replace dataflow_v1b3_client with a Google Cloud Python client [beam] via GitHub
  • Re: [I] Replace dataflow_v1b3_client with a Google Cloud Python client [beam] via GitHub
• Re: [I] Replace cloudbuild_v1_client with Google Cloud Build client [beam] via GitHub
  • Re: [I] Replace cloudbuild_v1_client with Google Cloud Build client [beam] via GitHub
• [I] [Bug]: ClickHouseIO.Write hangs indefinitely on stalled connection — no socket/connect timeout configured on client-v2 [beam] via GitHub
  • Re: [I] [Bug]: ClickHouseIO.Write hangs indefinitely on stalled connection — no socket/connect timeout configured on client-v2 [beam] via GitHub
  • Re: [I] [Bug]: ClickHouseIO.Write hangs indefinitely on stalled connection — no socket/connect timeout configured on client-v2 [beam] via GitHub
• [PR] add more coverage for yaml [beam] via GitHub
  • Re: [PR] add more coverage for yaml [beam] via GitHub
  • Re: [PR] add more coverage for yaml [beam] via GitHub
  • Re: [PR] add more coverage for yaml [beam] via GitHub
• [I] [Task]: Increase Yaml code coverage to a minimum of 80% overall [beam] via GitHub
• [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
  • Re: [PR] Avoid output inside try-catch in Java IO [beam] via GitHub
• Re: [I] [yaml] Add Beam YAML Troubleshooting Guide [beam] via GitHub
• Re: [I] [Feature]: Custom timestamps for Kinesis IO reader (currently always approx publish timestamp) [beam] via GitHub
• Re: [I] [yaml] Add resource hints to Beam YAML syntax [beam] via GitHub
• Re: [I] [Bug]: DirectRunner fails after grouping into batches, and applying flat map with assertion error [beam] via GitHub
• Re: [I] [Test Fix]: Reduce size of Fhir IO integration tests [beam] via GitHub
• Re: [I] [Bug]: Cannot use S3 with Cloudflare R2. [beam] via GitHub
  • Re: [I] [Bug]: Cannot use S3 with Cloudflare R2. [beam] via GitHub
• Re: [I] [Task]: Write artifacts in human readable form generated by MLTransform along with generated TF graph. [beam] via GitHub
  • Re: [I] [Task]: Write artifacts in human readable form generated by MLTransform along with generated TF graph. [beam] via GitHub
• Re: [PR] Bump torch from 2.7.1 to 2.12.1 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump torch from 2.7.1 to 2.12.1 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump torch from 2.7.1 to 2.12.1 in /sdks/python/container/ml/py312 [beam] via GitHub
• [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] via GitHub
  • Re: [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] via GitHub
  • Re: [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] via GitHub
  • Re: [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] via GitHub
  • Re: [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] via GitHub
• [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
  • Re: [PR] Docs: update Python version support in Python quickstart [beam] via GitHub
• [I] [Task]: Python quickstart lists outdated Python version support (missing 3.13, still lists 3.8) [beam] via GitHub
  • Re: [I] [Task]: Python quickstart lists outdated Python version support (missing 3.13, still lists 3.8) [beam] via GitHub
• [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
  • Re: [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
  • Re: [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
  • Re: [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
  • Re: [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
  • Re: [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] via GitHub
• [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.3 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.3 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.3 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.3 [beam] via GitHub
• [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] via GitHub
  • Re: [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] via GitHub
  • Re: [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] via GitHub
  • Re: [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] via GitHub
  • Re: [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] via GitHub
• [I] The PostCommit Python Arm job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
• [PR] [release-2.75] Cherry-pick #39100 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39100 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39100 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39100 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39100 and #39106 to the branch [beam] via GitHub
• [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
  • Re: [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] via GitHub
• Re: [I] Add support for dynamic destinations when writing to Kafka [beam] via GitHub
  • Re: [I] Add support for dynamic destinations when writing to Kafka [beam] via GitHub
  • Re: [I] Add support for dynamic destinations when writing to Kafka [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add open telemetry dependency to dataflow pipeline runner [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add open telemetry dependency to dataflow pipeline runner [beam] via GitHub
• [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] via GitHub
  • [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] via GitHub
  • Re: [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] via GitHub

• Earlier messages
• Later messages