github  

Messages by Thread

• [PR] [DRAFT] Fix bug when DataframeTransform a dictionary of Pcoll [beam] via GitHub
• Re: [I] [Bug]: TextIO.read() runs in only one executor when using SparkStructuredStreamingRunner but runs in distributed manner with SparkRunner [beam] via GitHub
• Re: [PR] Support Protobuf 6.x. [beam] via GitHub
• Re: [I] [Feature Request]: Support Protobuf 6.x in Python SDK [beam] via GitHub
• [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• Re: [I] [Bug]: Cannot transform multiple PCollections to Dataframe using the apache_beam.dataframe.transforms.DataframeTransform function [beam] via GitHub
  • Re: [I] [Bug]: Cannot transform multiple PCollections to Dataframe using the apache_beam.dataframe.transforms.DataframeTransform function [beam] via GitHub
• Re: [I] [Feature Request]: Add support for tracking lineage with BoundedTrie [beam] via GitHub
• Re: [I] [Bug]: Unauthenticated error when running tests on Dataproc using Flink and Docker with private repos [beam] via GitHub
• [PR] 30813 make tests deterministic [beam] via GitHub
  • Re: [PR] 30813 make tests deterministic [beam] via GitHub
  • Re: [PR] 30813 make tests deterministic [beam] via GitHub
  • Re: [PR] 30813 make tests deterministic [beam] via GitHub
• [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [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: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] via GitHub
• [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] via GitHub
• [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
  • Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] via GitHub
• [PR] Pin a mocking test to DirectRunner [beam] via GitHub
  • Re: [PR] Pin a mocking test to DirectRunner [beam] via GitHub
• Re: [PR] [2/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] via GitHub
• [PR] fix(yaml): handle grpc channel serialization in yaml testing framework [beam] via GitHub
  • Re: [PR] fix(yaml): handle grpc channel serialization in yaml testing framework [beam] via GitHub
  • Re: [PR] fix(yaml): handle grpc channel serialization in yaml testing framework [beam] via GitHub
  • Re: [PR] fix(yaml): handle grpc channel serialization in yaml testing framework [beam] via GitHub
• [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
  • Re: [PR] Add validation to check for non-ints from partitionfns [beam] via GitHub
• Re: [I] [Feature Request]: extensions/protobuf does not support google.protobuf.Struct [beam] via GitHub
• Re: [I] [Bug]: Issue with the script for adding execute task in "Convert from Maven to Gradle" section [beam] via GitHub
• Re: [I] [Bug][Prism]: Java Prism Runner tests always pass despite Job failure [beam] via GitHub
  • Re: [I] [Bug][Prism]: Java Prism Runner tests always pass despite Job failure [beam] via GitHub
  • Re: [I] [Bug][Prism]: Java Prism Runner tests always pass despite Job failure [beam] via GitHub
• [PR] [Dataflow Java Streaming] Reduce log spam for direct path mode and improve status page. [beam] via GitHub
  • Re: [PR] [Dataflow Java Streaming] Reduce log spam for direct path mode and improve status page. [beam] via GitHub
  • Re: [PR] [Dataflow Java Streaming] Reduce log spam for direct path mode and improve status page. [beam] via GitHub
• [PR] Bump google.golang.org/api from 0.243.0 to 0.247.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.243.0 to 0.247.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.243.0 to 0.247.0 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.86.0 to 1.87.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.86.0 to 1.87.0 in /sdks [beam] via GitHub
• [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.0.2 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.0.2 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.0.2 [beam] via GitHub
  • Re: [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.0.2 [beam] via GitHub
• [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
  • Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] via GitHub
• [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] via GitHub
• Re: [I] OrderedListState [beam] via GitHub
  • Re: [I] OrderedListState [beam] via GitHub
• [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
  • Re: [PR] Add type checking to confirm that the flatten inputs are actually pco… [beam] via GitHub
• [I] [Feature Request]: [Go SDK] Add Write support to xlang/bigtableio [beam] via GitHub
  • Re: [I] [Feature Request]: [Go SDK] Add Write support to xlang/bigtableio [beam] via GitHub
  • Re: [I] [Feature Request]: [Go SDK] Add Write support to xlang/bigtableio [beam] via GitHub
• [PR] Remove test forcing Devs to update managed-io doc [beam] via GitHub
  • Re: [PR] Remove test forcing Devs to update managed-io doc [beam] via GitHub
  • Re: [PR] Remove test forcing Devs to update managed-io doc [beam] via GitHub
• [PR] Fix Deploy-Update-Playground-environment-stg Cloud Build trigger [beam] via GitHub
  • Re: [PR] Fix Deploy-Update-Playground-environment-stg Cloud Build trigger [beam] via GitHub
  • Re: [PR] Fix Deploy-Update-Playground-environment-stg Cloud Build trigger [beam] via GitHub
• [PR] [#35869] [Go SDK] Fix Duplicated elements on Blind Writes to Bag State, to avoid spurious duplicated elements. [beam] via GitHub
  • Re: [PR] [#35869] [Go SDK] Fix Duplicated elements on Blind Writes to Bag State. [beam] via GitHub
• [I] [Bug]: [Go SDK] Blind Writes to Bag State lead to duplicate values returned in the same bundle. [beam] via GitHub
  • Re: [I] [Bug]: [Go SDK] Blind Writes to Bag State lead to duplicate values returned in the same bundle. [beam] via GitHub
• [I] [Failing Test]: Spanner change stream tests failing on latest GCP BOM [beam] via GitHub
• [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 28.0.0+incompatible [beam-starter-go] via GitHub
  • Re: [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 28.0.0+incompatible [beam-starter-go] via GitHub
• [I] [Bug]: PrismRunner fails to execute pipeline that DirectRunner succeeds at [beam] via GitHub
• [PR] Fix website license formatting [beam] via GitHub
  • Re: [PR] Fix website license formatting [beam] via GitHub
  • Re: [PR] Fix website license formatting [beam] via GitHub
• Re: [I] [Feature Request]: Add A Freature to get bigquery schema dynamically from a POJO class. [beam] via GitHub
• Re: [I] [Bug]: Beam Interactive Tour Mismatch [beam] via GitHub
• Re: [I] [Bug]: ./gradlew checkSetup fails with Java 8 on Docker dev image [beam] via GitHub
• [PR] [Java] Throw an exception for invalid empty pubsub messages before attempting to publish. [beam] via GitHub
  • Re: [PR] [Java] Throw an exception for invalid empty pubsub messages before attempting to publish. [beam] via GitHub
  • Re: [PR] [Java] Throw an exception for invalid empty pubsub messages before attempting to publish. [beam] via GitHub
  • Re: [PR] [Java] Throw an exception for invalid empty pubsub messages before attempting to publish. [beam] via GitHub
• [PR] [Java] Allow users to pass service name for profiler [beam] via GitHub
  • Re: [PR] [Java] Allow users to pass service name for profiler [beam] via GitHub
• [PR] Add mask for PyPI API token [beam] via GitHub
  • Re: [PR] Add mask for PyPI API token [beam] via GitHub
  • Re: [PR] Add mask for PyPI API token [beam] via GitHub
  • Re: [PR] Add mask for PyPI API token [beam] via GitHub
• [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
  • Re: [PR] Fix a bug in cogbk for not using registered coder. [beam] via GitHub
• [PR] Bump github.com/apple/swift-nio-http2 from 1.37.0 to 1.38.0 [beam-swift] via GitHub
  • Re: [PR] Bump github.com/apple/swift-nio-http2 from 1.37.0 to 1.38.0 [beam-swift] via GitHub
• [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
  • Re: [PR] Update Release Guide to add managed-io doc info [beam] via GitHub
• [I] [Task]: Deprecate Python native SpannerIO [beam] via GitHub
• [PR] Deprecate native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
  • Re: [PR] Deprecate Python native SpannerIO, with exposed bug fix [beam] via GitHub
• Re: [I] [Task]: Complete support for logical types that require arguments in Python SDK [beam] via GitHub
  • Re: [I] [Task]: Complete support for logical types that require arguments in Python SDK [beam] via GitHub
• Re: [PR] Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.5.1 [beam-starter-java] via GitHub
• [I] [Bug]: Old MongoDB Driver isn’t compatible with MongoDB 8.1.1. [beam] via GitHub
• [PR] Bump org.apache.beam:beam-sdks-java-core from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • [PR] Bump org.apache.beam:beam-sdks-java-core from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
• [PR] Bump org.apache.beam:beam-runners-direct-java from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • [PR] Bump org.apache.beam:beam-runners-direct-java from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.66.0 to 2.67.0 [beam-starter-java] via GitHub
• Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] via GitHub
• [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
  • Re: [PR] fix(test): improve redis container startup reliability in tests [beam] via GitHub
• [PR] Update ensurepip to avoid vulnerabilities in wheels [beam] via GitHub
• [PR] Bump apache-beam from 2.66.0 to 2.67.0 [beam-starter-python] via GitHub
  • Re: [PR] Bump apache-beam from 2.66.0 to 2.67.0 [beam-starter-python] via GitHub
• [PR] Update code-change-guide add back build SDK container [beam] via GitHub
  • Re: [PR] Update code-change-guide add back build SDK container [beam] via GitHub
  • Re: [PR] Update code-change-guide add back build SDK container [beam] via GitHub
• [PR] Bump actions/checkout from 4 to 5 [beam-starter-python] via GitHub
  • Re: [PR] Bump actions/checkout from 4 to 5 [beam-starter-python] via GitHub
• [PR] Bump actions/checkout from 4 to 5 [beam-starter-go] via GitHub
• [PR] Update BOM to 26.65.0 [beam] via GitHub
  • Re: [PR] Update BOM to 26.65.0 [beam] via GitHub
  • Re: [PR] Update BOM to 26.65.0 [beam] via GitHub
• [PR] Update Republish Released Docker Containers [beam] via GitHub
  • Re: [PR] Update Republish Released Docker Containers [beam] via GitHub
  • Re: [PR] Update Republish Released Docker Containers [beam] via GitHub
  • Re: [PR] Update Republish Released Docker Containers [beam] via GitHub
• [PR] Bump to Beam 2.67.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump to Beam 2.67.0 [beam-starter-java] via GitHub
• Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] via GitHub
• Re: [PR] Adjust runners/local-java so constructor does not throw exception [beam] via GitHub
  • Re: [PR] Adjust runners/local-java so constructor does not throw exception [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] via GitHub
• Re: [PR] Extending WindowedValue with ElementMetadata [beam] via GitHub
• Re: [PR] Allow Dofn Input/Output Typing [beam] via GitHub
• Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
• Re: [PR] fix arbitrary file access during archive extraction ("Zip Slip") [beam] via GitHub
• Re: [PR] Added documentation for return vs yield usage in DoFn.process() [beam] via GitHub
• Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub

• Earlier messages