github  

Messages by Date

• 2025/06/21 [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] via GitHub
• 2025/06/21 [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
• 2025/06/21 Re: [PR] Support Docker Compose v2 in Python TransformServiceLauncher [beam] via GitHub
• 2025/06/21 [PR] Support Docker Compose v2 in Python TransformServiceLauncher [beam] via GitHub
• 2025/06/21 Re: [I] [Bug]: Bigquery python streaming insertAll SSLError leads to stuck streaming job [beam] via GitHub
• 2025/06/21 Re: [I] [Bug]: BQ TableRow does not accept column named 'f' [beam] via GitHub
• 2025/06/21 Re: [PR] [yaml]: Phase2 High Usage Yaml examples [beam] via GitHub
• 2025/06/20 Re: [PR] Improve LogElements to show pane_info and timestamps in seconds. [beam] via GitHub
• 2025/06/20 Re: [PR] Fix the issue of sliding window firing early. [beam] via GitHub
• 2025/06/20 [PR] Improve LogElements to show pane_info and timestamps in seconds. [beam] via GitHub
• 2025/06/20 Re: [PR] reconnect when publishMessage in JMS fails [beam] via GitHub
• 2025/06/20 [PR] reconnect when publishMessage in JMS fails [beam] via GitHub
• 2025/06/20 Re: [PR] reconnect when publishMessage in JMS fails [beam] via GitHub
• 2025/06/20 [PR] Fix the issue of sliding window firing early. [beam] via GitHub
• 2025/06/20 Re: [I] [Bug]: Prism firing windows incorrectly when sliding windows are used [beam] via GitHub
• 2025/06/20 [I] [Bug]: Prism firing windows incorrectly when sliding windows are used [beam] via GitHub
• 2025/06/20 Re: [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] via GitHub
• 2025/06/20 [I] The PostCommit Java Nexmark Dataflow V2 Java job is flaky [beam] via GitHub
• 2025/06/20 [I] The PostCommit Java Nexmark Direct job is flaky [beam] via GitHub
• 2025/06/20 [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] via GitHub
• 2025/06/20 Re: [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/20 [I] The PostCommit Python Nexmark Direct job is flaky [beam] via GitHub
• 2025/06/20 Re: [PR] GCP Access Control [beam] via GitHub
• 2025/06/20 [PR] define display_data as a appliedptransform attribute similar to annot… [beam] via GitHub
• 2025/06/20 Re: [PR] Allow Dofn Input/Output Typing [beam] via GitHub
• 2025/06/20 Re: [PR] Allow Dofn Input/Output Typing [beam] via GitHub
• 2025/06/20 Re: [PR] Allow STRING format in Kafka config [beam] via GitHub
• 2025/06/20 Re: [PR] Fix data race ExecutionStateSampler.java:491 in ExecutionStateImpl.reset() [beam] via GitHub
• 2025/06/20 Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [I] [Feature Request]: Update Python JDBC write transforms to support configuring the batch size [beam] via GitHub
• 2025/06/20 Re: [PR] Enable prism by default (where supported) [beam] via GitHub
• 2025/06/20 Re: [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/20 Re: [PR] GCP Access Control [beam] via GitHub
• 2025/06/20 Re: [PR] try kafka-clients 4.0.0 [beam] via GitHub
• 2025/06/20 Re: [PR] Estimate req size in BQ streaming when auto sharding is true [beam] via GitHub
• 2025/06/20 Re: [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/20 Re: [PR] [Java] Add parsedData to Hl7v2Message and Update HL7v2IO Docs [beam] via GitHub
• 2025/06/20 Re: [PR] fix user metrics in @OnTimer [beam] via GitHub
• 2025/06/20 Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
• 2025/06/20 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/20 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/20 Re: [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] via GitHub
• 2025/06/20 Re: [PR] Updates Dataflow Python container [beam] via GitHub
• 2025/06/20 Re: [PR] [yaml]: uncomment WriteToKafka portion of test [beam] via GitHub
• 2025/06/20 Re: [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] via GitHub
• 2025/06/20 Re: [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] via GitHub
• 2025/06/20 Re: [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/20 Re: [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/20 Re: [I] [Task]: Add more info on setting up alloy db instance in notebook [beam] via GitHub
• 2025/06/20 Re: [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/20 Re: [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/20 Re: [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] via GitHub
• 2025/06/20 Re: [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/20 Re: [PR] Bump requests from 2.31.0 to 2.32.4 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] via GitHub
• 2025/06/20 Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] via GitHub
• 2025/06/20 Re: [PR] Add checkpoint during progress reporting. [beam] via GitHub
• 2025/06/20 Re: [PR] [DO NOT MERGE] tried to add artifactApiService [beam] via GitHub
• 2025/06/20 Re: [I] [Bug]: Array is missing in `ColumnType` descriptor - ClickHouseIO [beam] via GitHub
• 2025/06/20 Re: [PR] Unpin antlr in BeamModulePlugins [beam] via GitHub
• 2025/06/20 Re: [PR] Bump requests from 2.31.0 to 2.32.4 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] via GitHub
• 2025/06/20 Re: [PR] Estimate req size in BQ streaming when auto sharding is true [beam] via GitHub
• 2025/06/20 Re: [PR] fix arbitrary file access during archive extraction ("Zip Slip") [beam] via GitHub
• 2025/06/19 Re: [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/19 [PR] Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/19 Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] via GitHub
• 2025/06/19 Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
• 2025/06/19 [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
• 2025/06/19 Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] via GitHub
• 2025/06/19 Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: Got error 'ValueError: Schema with id <some uuid> has encoding_positions_set=True, but not all fields have encoding_position set' for no apparent reason [beam] via GitHub
• 2025/06/19 Re: [PR] Add Async Dofn and Test to BEAM [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: Got error 'ValueError: Schema with id <some uuid> has encoding_positions_set=True, but not all fields have encoding_position set' for no apparent reason [beam] via GitHub
• 2025/06/19 [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] via GitHub
• 2025/06/19 Re: [PR] try kafka-clients 4.0.0 [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: Got error 'ValueError: Schema with id <some uuid> has encoding_positions_set=True, but not all fields have encoding_position set' for no apparent reason [beam] via GitHub
• 2025/06/19 Re: [PR] Fix(yaml): Handle missing optional fields in JSON parsing [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: BigTable client "One or more TimeSeries could not be written" Java 2.65.0 [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: relax dill version [beam] via GitHub
• 2025/06/19 Re: [I] [Bug]: relax dill version [beam] via GitHub
• 2025/06/19 Re: [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] via GitHub
• 2025/06/19 [PR] try kafka-clients 4.0.0 [beam] via GitHub
• 2025/06/19 Re: [PR] Fix(yaml): Handle missing optional fields in JSON parsing [beam] via GitHub
• 2025/06/19 Re: [PR] Bump cloud.google.com/go/profiler from 0.4.2 to 0.4.3 in /sdks [beam] via GitHub
• 2025/06/19 Re: [PR] added defaultQueryTimeout for jdbc io [beam] via GitHub
• 2025/06/19 [PR] added defaultQueryTimeout for jdbc io [beam] via GitHub
• 2025/06/19 Re: [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] via GitHub
• 2025/06/19 Re: [PR] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] via GitHub
• 2025/06/19 Re: [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] via GitHub
• 2025/06/19 Re: [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] via GitHub
• 2025/06/19 [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] via GitHub
• 2025/06/19 Re: [I] [yaml] Normalize SpannerIO [beam] via GitHub
• 2025/06/19 Re: [PR] Update JupyterLab Sidepanel yarn.lock file [beam] via GitHub
• 2025/06/19 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/06/19 Re: [PR] added timeout for Direct_Read with Bigquery IO [beam] via GitHub
• 2025/06/19 Re: [PR] Distinguishing bigquery logging failures severities [beam] via GitHub
• 2025/06/19 [PR] Fix broad suppression of dataflow worker windmill package. [beam] via GitHub
• 2025/06/19 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/06/19 Re: [PR] Add withReshuffle(boolean) option to FileIO.matchAll() [beam] via GitHub
• 2025/06/19 Re: [PR] Fix out of range [beam] via GitHub
• 2025/06/19 Re: [PR] Estimate req size in BQ streaming when auto sharding is true [beam] via GitHub
• 2025/06/19 Re: [PR] Bump com.google.cloud.tools:dependencies from 1.5.6 to 1.5.15 [beam] via GitHub
• 2025/06/19 Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
• 2025/06/19 Re: [PR] [Java Harness] Improve heap dump support by configuring JVM to dump heap on OOM exceptions [beam] via GitHub
• 2025/06/19 Re: [PR] [Java Harness] Improve heap dump support by configuring JVM to dump heap on OOM exceptions [beam] via GitHub
• 2025/06/19 Re: [PR] Distinguishing bigquery logging failures severities [beam] via GitHub
• 2025/06/19 Re: [PR] Fix PubsubIOLT [beam] via GitHub
• 2025/06/19 [PR] Distinguishing bigquery logging failures severities [beam] via GitHub
• 2025/06/19 [PR] Fix PubsubIOLT [beam] via GitHub
• 2025/06/19 Re: [PR] BEAM-9626: Move out optional packages from core dependencies - 20259 [beam] via GitHub
• 2025/06/19 Re: [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] via GitHub
• 2025/06/19 Re: [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] via GitHub
• 2025/06/19 Re: [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] via GitHub
• 2025/06/18 [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] via GitHub
• 2025/06/18 Re: [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] via GitHub
• 2025/06/18 Re: [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] via GitHub
• 2025/06/18 Re: [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] via GitHub
• 2025/06/18 Re: [PR] Bump cloud.google.com/go/profiler from 0.4.2 to 0.4.3 in /sdks [beam] via GitHub
• 2025/06/18 Re: [PR] Bump github.com/go-sql-driver/mysql from 1.9.2 to 1.9.3 in /sdks [beam] via GitHub
• 2025/06/18 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.80.3 to 1.81.0 in /sdks [beam] via GitHub
• 2025/06/18 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.81 in /sdks [beam] via GitHub
• 2025/06/18 Re: [PR] Bump google.golang.org/api from 0.237.0 to 0.238.0 in /sdks [beam] via GitHub
• 2025/06/18 [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] via GitHub
• 2025/06/18 [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] via GitHub
• 2025/06/18 [PR] Bump google.golang.org/api from 0.237.0 to 0.238.0 in /sdks [beam] via GitHub
• 2025/06/18 [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.81 in /sdks [beam] via GitHub
• 2025/06/18 [PR] Bump github.com/go-sql-driver/mysql from 1.9.2 to 1.9.3 in /sdks [beam] via GitHub
• 2025/06/18 [PR] Bump cloud.google.com/go/profiler from 0.4.2 to 0.4.3 in /sdks [beam] via GitHub
• 2025/06/18 [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.80.3 to 1.81.0 in /sdks [beam] via GitHub
• 2025/06/18 Re: [I] [Bug]: BigQuery failures logged as warning even when the rows won't be retried [beam] via GitHub
• 2025/06/18 Re: [PR] Update Beam Protobuf Schema (Java) [beam] via GitHub
• 2025/06/18 Re: [PR] Unpin antlr in BeamModulePlugins [beam] via GitHub
• 2025/06/18 Re: [PR] Fix buildx always enabled [beam] via GitHub
• 2025/06/18 [I] How do I compress the output of using the WriteToFiles method? [beam] via GitHub
• 2025/06/18 Re: [PR] Update Beam Protobuf Schema (Java) [beam] via GitHub
• 2025/06/18 [PR] WIP - fix Debezium xlang test [beam] via GitHub
• 2025/06/18 Re: [PR] Use splitAsStream for wordcount [beam] via GitHub
• 2025/06/18 Re: [PR] Fix buildx always enabled [beam] via GitHub
• 2025/06/18 [PR] Fix buildx always enabled [beam] via GitHub
• 2025/06/18 Re: [PR] Adjust runners/local-java so constructor does not throw exception [beam] via GitHub
• 2025/06/18 Re: [PR] Add filter to GetMinUnfinishedWatermark queryAdd filter tester [beam] via GitHub
• 2025/06/18 Re: [PR] Use now + 2mins as the end timestamp for change stream read API if the connector endTimestamp is omitted [beam] via GitHub
• 2025/06/18 Re: [PR] Use splitAsStream for wordcount [beam] via GitHub
• 2025/06/18 Re: [PR] Use splitAsStream for wordcount [beam] via GitHub
• 2025/06/18 [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] via GitHub
• 2025/06/18 Re: [PR] Update Beam website to release 2.66.0 [beam] via GitHub
• 2025/06/18 Re: [PR] Add Async Dofn and Test to BEAM [beam] via GitHub
• 2025/06/18 Re: [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] via GitHub
• 2025/06/18 Re: [PR] Add dynamic read support to KafkaIO in Python SDK [beam] via GitHub
• 2025/06/18 Re: [PR] Add dynamic read support to KafkaIO in Python SDK [beam] via GitHub
• 2025/06/18 Re: [I] [Feature Request]: Support for KafkaIO Dynamic Read in Python SDK [beam] via GitHub
• 2025/06/18 Re: [PR] [IcebergIO] Add ITs for RESTCatalog using BLMS [beam] via GitHub
• 2025/06/18 [PR] [IcebergIO] Add ITs for RESTCatalog using BLMS [beam] via GitHub
• 2025/06/18 [PR] Update Beam website to release 2.66.0 [beam] via GitHub
• 2025/06/18 Re: [PR] Dont exit execution loop before bundle is done [beam] via GitHub
• 2025/06/18 [PR] Use splitAsStream for wordcount [beam] via GitHub
• 2025/06/18 Re: [I] The LoadTests Go GBK Flink Batch job is flaky [beam] via GitHub
• 2025/06/18 [I] The LoadTests Go GBK Flink Batch job is flaky [beam] via GitHub
• 2025/06/18 Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
• 2025/06/18 Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
• 2025/06/18 Re: [PR] Dont exit execution loop before bundle is done [beam] via GitHub
• 2025/06/18 Re: [PR] Fix The PostCommit Python job [beam] via GitHub
• 2025/06/18 Re: [I] The PostCommit Python job is flaky [beam] via GitHub
• 2025/06/18 Re: [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/18 Re: [PR] Updates Dataflow Python container [beam] via GitHub
• 2025/06/18 Re: [PR] added timeout for Direct_Read with Bigquery IO [beam] via GitHub
• 2025/06/18 Re: [PR] [IcebergIO SQL] create real iceberg table [beam] via GitHub
• 2025/06/18 Re: [PR] BEAM-9626: Move out optional packages from core dependencies - 20259 [beam] via GitHub
• 2025/06/18 Re: [PR] Updates Dataflow Python container [beam] via GitHub
• 2025/06/18 Re: [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/18 Re: [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/18 Re: [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/18 [PR] Updates Dataflow Python container [beam] via GitHub
• 2025/06/18 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/18 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/18 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/18 [I] [Bug]: BigQuery failures logged as warning even [beam] via GitHub
• 2025/06/18 Re: [PR] Fix(yaml): Handle missing optional fields in JSON parsing [beam] via GitHub
• 2025/06/18 Re: [PR] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] via GitHub
• 2025/06/18 Re: [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/18 Re: [PR] add back-off retry for JMS write [beam] via GitHub
• 2025/06/18 [PR] Clear space before generating the beam site pr - it seems this takes … [beam] via GitHub
• 2025/06/18 Re: [PR] Add dynamic read support to KafkaIO in Python SDK [beam] via GitHub
• 2025/06/18 Re: [PR] create helper function [beam] via GitHub
• 2025/06/18 Re: [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/18 [PR] Cherrypick #35341 [beam] via GitHub
• 2025/06/18 Re: [PR] Allow running TFT benchmarks from pr [beam] via GitHub
• 2025/06/18 [I] [Task]: Sliding window ptransform for time series data [beam] via GitHub
• 2025/06/18 Re: [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] via GitHub
• 2025/06/18 Re: [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] via GitHub
• 2025/06/18 Re: [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/06/18 Re: [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/06/18 Re: [PR] [IcebergIO SQL] create real iceberg table [beam] via GitHub
• 2025/06/18 Re: [PR] [KafkaIO] Report unknown backlog size when latest offset lags behind next offset [beam] via GitHub
• 2025/06/18 Re: [PR] Bump @octokit/request-error, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub

• Later messages