github  

Messages by Thread

• [PR] [Python] Keep Nexmark Query 1 bid prices as integers [beam] via GitHub
  • Re: [PR] [Python] Keep Nexmark Query 1 bid prices as integers [beam] via GitHub
• [PR] [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights [beam] via GitHub
  • Re: [PR] [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights [beam] via GitHub
• Re: [I] ZeroDivisionError if source bundle smaller than 1mb [beam] via GitHub
• Re: [I] [Bug]: Python Nexmark Query 1 is broken unsupported operand & float and int [beam] via GitHub
• Re: [PR] [Python] Fail bundles on state write errors [beam] via GitHub
• Re: [PR] [Python] Keep BigQuery load jobs distinct for table aliases [beam] via GitHub
• Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
  • Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
• [PR] [Python] Resolve AWS credentials through a secret manager (`--aws_credentials_secret_manager`) [beam] via GitHub
  • Re: [PR] [Python] Resolve AWS credentials through a secret manager (`--aws_credentials_secret_manager`) [beam] via GitHub
  • Re: [PR] [Python] Resolve AWS credentials through a secret manager (`--aws_credentials_secret_manager`) [beam] via GitHub
• [PR] add googleads version upgrade workflow [beam] via GitHub
  • Re: [PR] add googleads version upgrade workflow [beam] via GitHub
  • Re: [PR] add googleads version upgrade workflow [beam] via GitHub
• [PR] switch blueprint to pipelines [beam] via GitHub
  • Re: [PR] [yaml] switch blueprint to pipelines [beam] via GitHub
  • Re: [PR] [yaml] switch blueprint to pipelines [beam] via GitHub
• [PR] [Go SDK] Replace deprecated reflect.PtrTo in schema test [beam] via GitHub
  • Re: [PR] [Go SDK] Replace deprecated reflect.PtrTo in schema test [beam] via GitHub
  • Re: [PR] [Go SDK] Replace deprecated reflect.PtrTo in schema test [beam] via GitHub
  • Re: [PR] [Go SDK] Replace deprecated reflect.PtrTo in schema test [beam] via GitHub
• [PR] [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533) [beam] via GitHub
  • Re: [PR] [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533) [beam] via GitHub
• [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] via GitHub
  • Re: [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] via GitHub
  • Re: [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] via GitHub
  • Re: [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] via GitHub
• [PR] Secret manager 6 [beam] via GitHub
  • Re: [PR] [Python] Add `AwsOptions` and deprecate `S3Options` [beam] via GitHub
  • Re: [PR] [Python] Add `AwsOptions` and deprecate `S3Options` [beam] via GitHub
  • Re: [PR] [Python] Add `AwsOptions` and deprecate `S3Options` [beam] via GitHub
• [I] [Feature Request]: Support AWS secrets manager [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.6 to 1.33.8 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.6 to 1.33.8 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.6 to 1.33.8 in /sdks [beam] via GitHub
• [PR] Restrict BeamInfluxDB Grafana datasource to HTTP GET queries [beam] via GitHub
  • Re: [PR] Restrict BeamInfluxDB Grafana datasource to HTTP GET queries [beam] via GitHub
  • Re: [PR] Restrict BeamInfluxDB Grafana datasource to HTTP GET queries [beam] via GitHub
  • Re: [PR] Restrict BeamInfluxDB Grafana datasource to HTTP GET queries [beam] via GitHub
• Re: [PR] [PubsubIO] Account for message metadata in bounded write batch size [beam] via GitHub
• [PR] Bump golang.org/x/sync from 0.23.0 to 0.24.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/sync from 0.23.0 to 0.24.0 in /sdks [beam] via GitHub
• [PR] Lock down provisioned Grafana dashboards as non-editable and non-deletable [beam] via GitHub
  • Re: [PR] Lock down provisioned Grafana dashboards as non-editable and non-deletable [beam] via GitHub
  • Re: [PR] Lock down provisioned Grafana dashboards as non-editable and non-deletable [beam] via GitHub
  • Re: [PR] Lock down provisioned Grafana dashboards as non-editable and non-deletable [beam] via GitHub
• [PR] Bump gradle-wrapper from 8.14.3 to 9.8.1 [beam] via GitHub
  • Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.8.1 [beam] via GitHub
  • Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.8.1 [beam] via GitHub
  • Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.8.1 [beam] via GitHub
• [PR] Add YAML tests for writing to Iceberg CDC sink [beam] via GitHub
  • Re: [PR] Add YAML tests for writing to Iceberg CDC sink [beam] via GitHub
  • Re: [PR] Add YAML tests for writing to Iceberg CDC sink [beam] via GitHub
  • Re: [PR] Add YAML tests for writing to Iceberg CDC sink [beam] via GitHub
  • Re: [PR] Add YAML tests for writing to Iceberg CDC sink [beam] via GitHub
• [PR] Modifies Hugging Face model handlers to not use ML packages... [beam] via GitHub
  • Re: [PR] Modifies Hugging Face model handlers to not use ML packages... [beam] via GitHub
  • Re: [PR] Modifies Hugging Face model handlers to not use ML packages... [beam] via GitHub
  • Re: [PR] Modifies Hugging Face model handlers to not use ML packages... [beam] via GitHub
• [PR] Bump google.golang.org/api from 0.300.0 to 0.301.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.300.0 to 0.301.0 in /sdks [beam] via GitHub
• [PR] Bump github/codeql-action from 4.38.2 to 4.38.3 [beam] via GitHub
  • Re: [PR] Bump github/codeql-action from 4.38.2 to 4.38.3 [beam] via GitHub
• [PR] Clean up Python load test version configs [beam] via GitHub
  • Re: [PR] Clean up Python load test version configs [beam] via GitHub
  • Re: [PR] Fix slow SyntheticSource in Python3.11+, clean up Python load test version configs [beam] via GitHub
  • Re: [PR] Fix slow SyntheticSource in Python3.11+, clean up Python load test version configs [beam] via GitHub
  • Re: [PR] Fix slow SyntheticSource in Python3.11+, clean up Python load test version configs [beam] via GitHub
• [PR] Enforce read-only PostgreSQL permissions for kubeproxyuser_ro [beam] via GitHub
  • Re: [PR] Enforce read-only PostgreSQL permissions for kubeproxyuser_ro [beam] via GitHub
  • Re: [PR] Enforce read-only PostgreSQL permissions for kubeproxyuser_ro [beam] via GitHub
  • Re: [PR] Enforce read-only PostgreSQL permissions for kubeproxyuser_ro [beam] via GitHub
• [I] [Feature Request][RunInference] Support multi-model KeyedModelHandler with ModelManager [beam] via GitHub
• [PR] Harden Grafana anonymous access, Explore, data proxy, and version disclosure settings [beam] via GitHub
  • Re: [PR] Harden Grafana anonymous access, Explore, data proxy, and version disclosure settings [beam] via GitHub
  • Re: [PR] Harden Grafana anonymous access, Explore, data proxy, and version disclosure settings [beam] via GitHub
  • Re: [PR] Harden Grafana anonymous access, Explore, data proxy, and version disclosure settings [beam] via GitHub
• [PR] Apply beamgrafana-deploy.yaml manifest during Beam Metrics deploy task [beam] via GitHub
  • Re: [PR] Apply beamgrafana-deploy.yaml manifest during Beam Metrics deploy task [beam] via GitHub
  • Re: [PR] Apply beamgrafana-deploy.yaml manifest during Beam Metrics deploy task [beam] via GitHub
  • Re: [PR] Apply beamgrafana-deploy.yaml manifest during Beam Metrics deploy task [beam] via GitHub
• [PR] [Experimental] Update ML deps extras [beam] via GitHub
  • Re: [PR] [Experimental] Update ML deps extras [beam] via GitHub
• [PR] [Python] Preserve DaskRunner finish_bundle outputs [beam] via GitHub
  • Re: [PR] [Python] Preserve DaskRunner finish_bundle outputs [beam] via GitHub
  • Re: [PR] [Python] Preserve DaskRunner finish_bundle outputs [beam] via GitHub
  • Re: [PR] [Python] Preserve DaskRunner finish_bundle outputs [beam] via GitHub
• [I] [Feature Request]: Optimized GCS Direct Write for Dense Keys [beam] via GitHub
• [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] via GitHub
  • Re: [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] via GitHub
  • Re: [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] via GitHub
  • Re: [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] via GitHub
  • Re: [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] via GitHub
• [PR] [Python] Resolve AWS credentials from a secret manager via `--aws_credentials_secret_manager` [beam] via GitHub
  • Re: [PR] [Python] Resolve AWS credentials from a secret manager via `--aws_credentials_secret_manager` [beam] via GitHub
  • Re: [PR] [Python] Keep `--s3_api_version` in `S3Options` and remove `--aws_api_version` [beam] via GitHub
  • Re: [PR] [Python] Make `--aws_*` options defaults and `--s3_*` options S3 overrides [beam] via GitHub
• [PR] Fix Playground Frontend cloud build [beam] via GitHub
  • Re: [PR] Fix Playground Frontend cloud build [beam] via GitHub
• [I] [Bug]: DaskRunner silently drops DoFn.finish_bundle outputs [beam] via GitHub
  • Re: [I] [Bug]: DaskRunner silently drops DoFn.finish_bundle outputs [beam] via GitHub
  • Re: [I] [Bug]: DaskRunner silently drops DoFn.finish_bundle outputs [beam] via GitHub
• [PR] Bump cloud.google.com/go/spanner from 1.95.1 to 1.96.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/spanner from 1.95.1 to 1.96.1 in /sdks [beam] via GitHub
• [PR] Bump golang.org/x/sys from 0.48.0 to 0.49.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/sys from 0.48.0 to 0.49.0 in /sdks [beam] via GitHub
• [I] [Bug]: Tour of Beam Firebase Authentication fails with API key expired error [beam] via GitHub
• [I] [Task]: Clear per key watermark and timer state of the Spark 4 streaming stateful processor [beam] via GitHub
  • Re: [I] [Task]: Clear per key watermark and timer state of the Spark 4 streaming stateful processor [beam] via GitHub
  • Re: [I] [Task]: Clear per key watermark and timer state of the Spark 4 streaming stateful processor [beam] via GitHub
• [PR] Fix WriteToFiles not creating nested directories for file_naming paths [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: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] via GitHub
• [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [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
• [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
• Re: [I] Java core tests fails on windows: io.TextIOReadTest.testInitialSplitAutoModeGz [beam] via GitHub
• Re: [PR] [Iceberg compaction] Add committer DoFn [beam] via GitHub
• Re: [PR] [Iceberg compaction] Rewrite subgroups DoFn [beam] via GitHub
• Re: [PR] Invalidate cached ContinuationIterable when its continuation fails [beam] via GitHub
• Re: [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] via GitHub
• [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
  • Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
  • Re: [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] via GitHub
• [I] [Bug]: DataFrame API Series.value_counts(bins=...) always fails with TypeError [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API Series.value_counts(bins=...) always fails with TypeError [beam] via GitHub
• [PR] [Python] Wait for AsyncWrapper work before teardown [beam] via GitHub
  • Re: [PR] [Python] Wait for AsyncWrapper work before teardown [beam] via GitHub
• Re: [PR] [Python] Reset BigQuery retries for each batch [beam] via GitHub
  • Re: [PR] [Python] Reset BigQuery retries for each batch [beam] via GitHub
  • Re: [PR] [Python] Reset BigQuery retries for each batch [beam] via GitHub
• [PR] [Python] Fix DataFrame Series.value_counts with bins [beam] via GitHub
  • Re: [PR] [Python] Fix DataFrame Series.value_counts with bins [beam] via GitHub
  • Re: [PR] [Python] Fix DataFrame Series.value_counts with bins [beam] via GitHub
  • Re: [PR] [Python] Fix DataFrame Series.value_counts with bins [beam] via GitHub
• [PR] [Python] Keep count/size labels in DataFrame agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep count/size labels in DataFrame agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep count/size labels in DataFrame agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep count/size labels in DataFrame agg with a list [beam] via GitHub
• [I] [Bug]: DataFrame API agg(['count', ...]) labels the count/size row as 'sum' [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API agg(['count', ...]) labels the count/size row as 'sum' [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API agg(['count', ...]) labels the count/size row as 'sum' [beam] via GitHub
• Re: [PR] [Python] Finish async bundles after processing outputs [beam] via GitHub
  • Re: [PR] [Python] Finish async bundles after processing outputs [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
• [PR] [Python] Optionally write chunk content to Qdrant payload [beam] via GitHub
  • Re: [PR] [Python] Optionally write chunk content to Qdrant payload [beam] via GitHub
  • Re: [PR] [Python] Optionally write chunk content to Qdrant payload [beam] via GitHub
• Re: [I] python typehints: reduce the number of runtime-type-check wrappers [beam] via GitHub
• [PR] [Python] Merge runtime type-check wrappers [beam] via GitHub
  • Re: [PR] [Python] Merge runtime type-check wrappers [beam] via GitHub
  • Re: [PR] [Python] Merge runtime type-check wrappers [beam] via GitHub
• Re: [PR] [DO NOT MERGE] compaction wip [beam] via GitHub
• Re: [I] [Bug]: beam.io.WriteToBigQuery failed when given schema with space [beam] via GitHub
• Re: [I] [Bug]: Beam SDK throws `NoClassDefFoundError` using SparkRunner in Dataproc 2.1 (Java 11) [beam] via GitHub
• [PR] [Python] Fix max_models_per_worker_hint not being enforced in KeyedModelHandler [beam] via GitHub
  • Re: [PR] [Python] Fix max_models_per_worker_hint not being enforced in KeyedModelHandler [beam] via GitHub
  • Re: [PR] [Python] Fix max_models_per_worker_hint not being enforced in KeyedModelHandler [beam] via GitHub
• Re: [I] fileio calls mkdirs with basepath and not dirname(full_file_name) [beam] via GitHub
  • Re: [I] fileio calls mkdirs with basepath and not dirname(full_file_name) [beam] via GitHub
• Re: [I] [Bug]: retain_unknown_options incorrectly assumes unknown arguments are consecutive [beam] via GitHub
• [PR] [Python] Strip whitespace around ':' in BigQuery string schemas [beam] via GitHub
  • Re: [PR] [Python] Strip whitespace around ':' in BigQuery string schemas [beam] via GitHub
• [PR] [Python] Create file_naming subdirectories in WriteToFiles [beam] via GitHub
  • Re: [PR] [Python] Create file_naming subdirectories in WriteToFiles [beam] via GitHub
• [PR] [Python] Decide unknown pipeline option arity from the original flags [beam] via GitHub
  • Re: [PR] [Python] Decide unknown pipeline option arity from the original flags [beam] via GitHub
• [PR] Stream Dask side inputs one partition at a time [beam] via GitHub
  • Re: [PR] Stream Dask side inputs one partition at a time [beam] via GitHub
  • Re: [PR] Add opt-in lazy Dask side inputs with worker-safe computation [beam] via GitHub
  • Re: [PR] Add opt-in lazy Dask side inputs with worker-safe computation [beam] via GitHub
  • Re: [PR] Add opt-in lazy Dask side inputs with worker-safe computation [beam] via GitHub
  • Re: [PR] Add opt-in lazy Dask side inputs with worker-safe computation [beam] via GitHub
• [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] via GitHub
• [PR] Add gcs_avro_to_cloud_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
  • Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] via GitHub
• Re: [PR] Document required Go SDK initialization [beam] via GitHub
• [PR] [SpannerIO] Add withWriteResults() to SpannerIO.Write to emit commit metadata [beam] via GitHub
  • Re: [PR] [SpannerIO] Add withWriteResults() to SpannerIO.Write to emit commit metadata [beam] via GitHub
  • Re: [PR] [SpannerIO] Add withWriteResults() to SpannerIO.Write to emit commit metadata [beam] via GitHub
• [PR] [security-assessment] non-destructive fork-PR approval-gate probe [beam] via GitHub
  • Re: [PR] [security-assessment] non-destructive fork-PR approval-gate probe [beam] via GitHub

• Earlier messages