You are viewing a plain text version of this content. The canonical link for it is here.

---

- Re: [I] JUnit5 support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/01 01:04:33 UTC, 1 replies.
- Re: [PR] Remove allJavadoc from javaPreCommit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 02:32:01 UTC, 1 replies.
- [PR] Blog post: Beam modernization at project 10-year mark [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/01 03:07:52 UTC, 2 replies.
- Re: [PR] [Python] Fix ParquetIO silently corrupting data across windows in unbounded pipelines [beam] - posted by "developer-rpai (via GitHub)" <gi...@apache.org> on 2026/10/01 05:28:50 UTC, 2 replies.
- Re: [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/10/01 05:38:12 UTC, 3 replies.
- Re: [I] [Task]: Add a GCS temp bucket cleaner to .test-infra/tools to prevent bucket leaks [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/10/01 06:54:30 UTC, 2 replies.
- Re: [PR] Close harness data/state channels and don't Recv on Send EOF [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/01 07:58:19 UTC, 3 replies.
- [PR] Update managed-io.md for release 2.77.0-RC4 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/01 09:15:21 UTC, 2 replies.
- Re: [I] [Bug]: Go harness leaks gRPC connections and can deadlock when closing streams [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2026/10/01 10:10:24 UTC, 0 replies.
- [PR] fix leader board trigger [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/01 10:18:51 UTC, 12 replies.
- [PR] Remove outdated pull_request_target permission comments from workflows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 11:46:30 UTC, 6 replies.
- [PR] [2/3] Migrate PreCommit workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 11:57:53 UTC, 0 replies.
- [PR] [3/3] Migrate PostCommit workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 11:57:58 UTC, 0 replies.
- Re: [I] The PostCommit SQL job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/01 12:24:02 UTC, 5 replies.
- Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:35:14 UTC, 6 replies.
- Re: [PR] [Gemini] Add ExpireSnapshots maintenance operation to Iceberg IO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:35:16 UTC, 9 replies.
- Re: [PR] [Beam SQL] Introduce call procedures [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:35:19 UTC, 2 replies.
- Re: [I] [Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:51:57 UTC, 0 replies.
- Re: [I] [Feature Request]: Expose pvalue.Row in core.py rather than pvalue.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:51:59 UTC, 3 replies.
- Re: [I] [Bug]: 16177 has type numpy.int64, but expected one of: bytes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:04 UTC, 1 replies.
- Re: [I] [Feature Request]: Create a "Try Apache Beam YAML" landing page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:10 UTC, 1 replies.
- Re: [I] [Failing Test]: Python GCP xlang fails if a node run two test concurrently [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:14 UTC, 1 replies.
- Re: [I] [Task]: Enable Checker framework on `it` module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:18 UTC, 1 replies.
- Re: [I] [Failing Test]: beam_PostRelease_Python_Candidate script broken [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:24 UTC, 1 replies.
- Re: [I] [Feature Request]: Add hint to ReadFromMongoDB, MongoDBIO Connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:28 UTC, 1 replies.
- Re: [I] [Task]: Rewrite Go README [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:32 UTC, 1 replies.
- Re: [I] [Bug]: Java portable SDK should enable heap dumping with HeapDumpOnOutOfMemoryError if configured [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:36 UTC, 1 replies.
- Re: [I] [Bug]: [Java BQ] Reduce the number of retries for streaming Storage API writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:40 UTC, 1 replies.
- Re: [I] [Bug]: JdbcIO.readRows() incompatible with AvroUtils for DECIMAL\NUMERIC(10,2) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:44 UTC, 1 replies.
- Re: [I] [Task]: Build RC and non-RC wheels in parallel. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:48 UTC, 1 replies.
- Re: [I] Columns and DataType Not Explicitly Set on line 137 of utils.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:53 UTC, 0 replies.
- Re: [I] [Bug]: JmsIO create connection based on the number of threads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:54 UTC, 0 replies.
- Re: [I] [Feature Request][Go]: Demonstrate building a pipeline from scratch using Beam Go [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:57 UTC, 0 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Go_Cron failing beam/util/pubsubx timeout [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 12:52:59 UTC, 0 replies.
- Re: [PR] delay LeaderBoardIT Pub/Sub inject [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/01 12:53:03 UTC, 0 replies.
- [I] [Bug]: ParDo._get_key_and_window_coder fails to filter side inputs when determining main input for stateful DoFns [beam] - posted by "sofiathoren (via GitHub)" <gi...@apache.org> on 2026/10/01 13:38:20 UTC, 2 replies.
- [PR] [4/4] Migrate secret-using workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 13:43:53 UTC, 3 replies.
- Re: [PR] [1/4] Migrate 7 pilot CI workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 13:54:53 UTC, 2 replies.
- Re: [PR] normalize BigQuery CDC [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/01 14:02:52 UTC, 1 replies.
- [PR] Parallelize per-file rewrites in GcsUtilV2 copy and move [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/01 14:03:55 UTC, 11 replies.
- [PR] Remove redundant GCP auth steps and secrets from self-hosted PR workflows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 14:04:40 UTC, 5 replies.
- Re: [PR] [2/4] Migrate PreCommit workflows from pull_request_target to pull_request [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/01 14:09:39 UTC, 8 replies.
- Re: [PR] fix performance plot [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/01 14:18:17 UTC, 3 replies.
- Re: [PR] Adds drain support to Spanner CDC source. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/01 14:26:03 UTC, 0 replies.
- [PR] [Claude] Plumb through pipeline-level resource hints to cross-language transforms [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/01 14:41:29 UTC, 3 replies.
- Re: [PR] [Python] Fix BigtableIO write test mocks for google-cloud-bigtable batcher delegation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 14:43:26 UTC, 4 replies.
- [PR] [Python] Fix stateful ParDo taking the timer key coder from a side input [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/01 14:44:59 UTC, 5 replies.
- Re: [PR] Temporarily set Bigtable client version upper bound [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/01 15:12:12 UTC, 0 replies.
- Re: [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/01 15:23:24 UTC, 2 replies.
- Re: [PR] Port Wait.On to the Go SDK [beam] - posted by "vgough (via GitHub)" <gi...@apache.org> on 2026/10/01 17:09:08 UTC, 1 replies.
- [PR] Set ALLOYDB_PASSWORD directly in workflows for sandboxed test database [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 17:22:47 UTC, 3 replies.
- Re: [PR] [Cherry-pick] Return last evaluated progress on lock timeout in RestrictionTrackers.getProgress (#40205) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 17:47:15 UTC, 0 replies.
- [PR] Enforce TLS 1.2+ on ARC webhook GCE Ingress [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 18:07:58 UTC, 3 replies.
- [PR] Add check_run fork guard to beam_PreCommit_Python_Dill.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 18:48:05 UTC, 2 replies.
- Re: [PR] [Python] Add reusable decision model primitives [beam] - posted by "IRONICBo (via GitHub)" <gi...@apache.org> on 2026/10/01 19:01:46 UTC, 2 replies.
- Re: [PR] [3/4] Migrate PostCommit workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/01 19:26:05 UTC, 2 replies.
- Re: [PR] Make Java PreSubmit faster: Parallelize test [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/10/01 19:30:14 UTC, 0 replies.
- [PR] Bump urllib3 from 2.7.0 to 2.8.0 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/01 19:55:19 UTC, 3 replies.
- Re: [PR] IcebergIO and AddFiles multi bucket catalog validation [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/01 21:00:01 UTC, 2 replies.
- [PR] [Go SDK] Use deterministic protobuf marshaling in protox helpers [beam] - posted by "malo-denielou (via GitHub)" <gi...@apache.org> on 2026/10/01 22:05:16 UTC, 2 replies.
- [PR] Add stale GCS test bucket cleaner [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/10/01 23:24:14 UTC, 4 replies.
- Re: [PR] Add custom window support in Go SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/02 00:57:27 UTC, 3 replies.
- Re: [I] [Feature Request]: Wait.on for Go SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/02 01:03:59 UTC, 0 replies.
- [PR] Adds an end-to-end example for migrating change data (CDC)... [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/02 01:08:16 UTC, 8 replies.
- Re: [PR] Update managed-io.md for release 2.77.0-RC3 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/02 07:21:24 UTC, 0 replies.
- Re: [PR] Fix JaCoCo coverage for multiple test tasks. [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/02 07:22:18 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/02 10:23:51 UTC, 0 replies.
- [PR] Remove comment-based workflow run and rerun triggers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/02 10:52:12 UTC, 4 replies.
- Re: [PR] Add OpenTelemetry tracing support to SolaceIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/02 11:28:32 UTC, 5 replies.
- Re: [PR] Restore thread interrupt status in InterruptedException catch blocks [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/10/02 12:33:18 UTC, 0 replies.
- Re: [PR] [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:34:32 UTC, 5 replies.
- Re: [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:34:44 UTC, 5 replies.
- Re: [PR] Deprecate ParquetIO.withProjection (#20770) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:34:58 UTC, 2 replies.
- Re: [PR] [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/10/02 12:35:20 UTC, 2 replies.
- Re: [I] [Bug]: GBK with global window must fit all values for a key into a memory [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:00 UTC, 1 replies.
- Re: [I] [Feature Request]: Document how xlang users should avoid a mismatch between expansion environment and runtime environment [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:04 UTC, 0 replies.
- Re: [I] [Feature Request]: Support running multi-language pipelines locally without Docker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:06 UTC, 0 replies.
- Re: [I] [Feature Request]: Pipeline Cost Estimation Tool [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:08 UTC, 0 replies.
- Re: [I] [Feature Request]: Increase State commit limit of 2GB in beam [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:10 UTC, 0 replies.
- Re: [I] [Feature Request]: Add a De-ID PTransform for the DicomIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:12 UTC, 0 replies.
- Re: [I] [Bug]: KafkaIO missing initial messages when using automatic topic creation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:14 UTC, 0 replies.
- Re: [I] [Bug]: Links to articles in RSS feed do not work [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:16 UTC, 0 replies.
- Re: [I] [Bug]: Window trigger has lag when using Kafka and GroupByKey on Dataflow Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:18 UTC, 0 replies.
- Re: [I] [Feature Request]: Automatically use the Docker-compose based transform service for cross-language expansion - Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:20 UTC, 0 replies.
- Re: [I] [Bug]: streaming is set to True in PipelineOptions but condition is evaluating as false for is_streaming_pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:22 UTC, 0 replies.
- Re: [I] [Task]: Tour of Beam Java Typos/Issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:26 UTC, 0 replies.
- Re: [I] [Bug]: Interactive Mode is not properl detecting `is_in_notebook` with Jupyter Enterprise Gateway [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:28 UTC, 0 replies.
- Re: [I] Use ruptures module for detecting change points in performance tests. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:30 UTC, 0 replies.
- Re: [I] [Bug]: The default config for FirestoreV1.write().batchWrite() on smaller java jobs has an abysmal throughput [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 12:51:32 UTC, 3 replies.
- Re: [PR] Fix exception masking in FileSystems.matchSingleFileSpec [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/02 15:45:30 UTC, 4 replies.
- Re: [PR] [Python] Support Lakehouse runtime catalog tables in ReadFromBigQuery… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/02 17:15:12 UTC, 8 replies.
- [PR] Update Jetty to 9.4.58.v20250814 and exclude shaded Jetty pom metadat… [beam] - posted by "ashwin-sampathkumar (via GitHub)" <gi...@apache.org> on 2026/10/02 18:28:48 UTC, 3 replies.
- [PR] [Java] FirestoreIO: add RpcQosOptions.withRampupThrottlingDisabled() [beam] - posted by "nbali (via GitHub)" <gi...@apache.org> on 2026/10/02 20:24:04 UTC, 7 replies.
- [PR] [Java] FirestoreIO: ramp up writes from a pipeline-wide start time [beam] - posted by "nbali (via GitHub)" <gi...@apache.org> on 2026/10/02 20:27:43 UTC, 4 replies.
- Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/03 00:12:17 UTC, 3 replies.
- [PR] Fix Iceberg CDC sink messaging [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/03 05:29:16 UTC, 5 replies.
- Re: [I] MqttIOTest testReadNoClientId failure timeout flaky test (sickbayed) [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/10/03 05:47:13 UTC, 1 replies.
- [PR] Deflake MqttIOTest read tests and re-enable testReadNoClientId [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/10/03 05:47:59 UTC, 2 replies.
- [PR] Use more robust Iceberg CDC metrics [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/03 06:03:03 UTC, 4 replies.
- Re: [PR] [Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 07:03:07 UTC, 8 replies.
- Re: [PR] Deflake JmsIOTest checkpoint and authentication tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 13:52:59 UTC, 2 replies.
- Re: [PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 13:53:05 UTC, 4 replies.
- Re: [PR] Add examples for cloudsql [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 13:53:09 UTC, 2 replies.
- Re: [PR] fix bigtable schema issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 13:53:11 UTC, 2 replies.
- Re: [PR] Decorrelate sub-queries using normalizeForVolcano pass [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:15:46 UTC, 1 replies.
- Re: [PR] Add parser conformance resolution and logical plan parsing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:15:52 UTC, 1 replies.
- Re: [PR] Add SINGLE_VALUE aggregate function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:15:56 UTC, 1 replies.
- Re: [I] [Feature Request]: Add support for BigQuery structs in BigQueryIO with BEAM_ROW output type [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:08 UTC, 0 replies.
- Re: [I] [Bug]: When using beam.io.kinesis.ReadDataFromKinesis, a java error is raised in DataFlowRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:10 UTC, 0 replies.
- Re: [I] [Feature Request]: WriteToParquet schema as side input [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:12 UTC, 0 replies.
- Re: [I] [Bug]: unexpected duplicate outputs triggered by quota exceeded exception in finish_bundle() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:18 UTC, 0 replies.
- Re: [I] [Task]: disable examples checks in integration tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:21 UTC, 0 replies.
- Re: [I] Improve the recoverability of DoFn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/03 14:16:23 UTC, 0 replies.
- Re: [I] Upgrade DebeziumIO to Debezium 3.5.2.Final [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/03 15:19:28 UTC, 7 replies.
- [I] [Feature Request]: Fully support new parameters for ReadFromKafka Yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/03 23:10:15 UTC, 1 replies.
- [PR] add redistribute kafka io parameters [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/03 23:40:25 UTC, 6 replies.
- [PR] try to fix async wrapper test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/04 02:36:46 UTC, 4 replies.
- Re: [I] [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element [beam] - posted by "dhruv-dagar (via GitHub)" <gi...@apache.org> on 2026/10/04 03:51:18 UTC, 4 replies.
- [PR] [BEAM-40264] Fix Spark MapState and SetState isEmpty after removals [beam] - posted by "dhruv-dagar (via GitHub)" <gi...@apache.org> on 2026/10/04 04:05:42 UTC, 4 replies.
- [PR] [Python] Return every group from Regex.find_all with Regex.ALL [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/04 13:37:41 UTC, 10 replies.
- [PR] assign reviewers immediately when PR is marked ready for review [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/04 14:16:49 UTC, 3 replies.
- Re: [PR] [Python] Round float seconds to the nearest microsecond in Duration [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/04 14:23:32 UTC, 1 replies.
- Re: [PR] Adds the Delta Lake CDC read transforms to the Managed I/O API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:23:59 UTC, 2 replies.
- Re: [I] YAML Test CLI flag mismatch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:05 UTC, 0 replies.
- Re: [I] [Feature Request]: BigqueryIO.java WriteTableRows RangePartitioning support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:19 UTC, 0 replies.
- Re: [I] [Failing Test]: BigQueryIOWriteTest.testWriteFileSchemaUpdateOptionAllowFieldAddition [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:21 UTC, 0 replies.
- Re: [I] [Task]: Update BigQuery IO Docs: BigQuery IO supports READ_API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:23 UTC, 0 replies.
- Re: [I] [Bug]: Possible data loss in BigtableIO r/w if timestamp not set (default to epoch) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:25 UTC, 0 replies.
- Re: [I] [Bug]: Beam Website cannot run locally on Mac [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/04 14:24:27 UTC, 0 replies.
- Re: [PR] Update Beam website to release 2.77.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/04 15:08:32 UTC, 1 replies.
- Re: [PR] [Iceberg CDC] Finish wiring CDC source together and add external API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/04 15:14:40 UTC, 2 replies.
- Re: [I] [Bug]: Duration(float seconds) truncates instead of rounding, losing a microsecond [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/04 16:54:25 UTC, 0 replies.
- Re: [PR] [Gemini] Prototype OpenAI RemoteInferenceModelHandler Implementation [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/04 19:40:04 UTC, 4 replies.
- [I] Self-hosted runner images: RUNNER_VERSION=2.296.2 is below GitHub's new minimum (2.329.0) [beam] - posted by "otisz22 (via GitHub)" <gi...@apache.org> on 2026/10/04 20:35:38 UTC, 2 replies.
- [I] [Feature Request]: Preserve JobMessage id on WaitForCompletion failure [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/04 20:59:19 UTC, 1 replies.
- [PR] Update self-hosted runner versions to meet GitHub's minimum runner version [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/04 21:00:03 UTC, 5 replies.
- [PR] [Go SDK] Return job message id from WaitForCompletion [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/04 21:09:08 UTC, 13 replies.
- [I] [Bug]: Go harness last dataWriter/timerWriter send errors are not wrapped [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/04 21:24:16 UTC, 2 replies.
- [PR] [Go SDK] wrap a failed last data/timer send like Flush [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/04 21:27:47 UTC, 5 replies.
- [PR] Bump github.com/moby/moby/api from 1.56.0 to 1.56.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:40:02 UTC, 4 replies.
- [PR] Bump github.com/moby/moby/client from 0.6.0 to 0.6.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:40:07 UTC, 4 replies.
- [PR] Bump net.researchgate.release from 2.8.1 to 3.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:40:16 UTC, 6 replies.
- [PR] Bump google.golang.org/api from 0.299.0 to 0.300.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:40:18 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.10 to 1.23.11 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:41:33 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.113.4 to 1.114.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 04:42:43 UTC, 5 replies.
- Re: [I] [Task]: Remove support for Python 3.10 [beam] - posted by "parvarh26 (via GitHub)" <gi...@apache.org> on 2026/10/05 06:11:09 UTC, 2 replies.
- [PR] [#40250] Remove support for Python 3.10 [beam] - posted by "parvarh26 (via GitHub)" <gi...@apache.org> on 2026/10/05 07:43:24 UTC, 13 replies.
- [I] [Bug]: Go harness can deadlock when recreating a data/state channel [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/05 11:07:22 UTC, 2 replies.
- [PR] [Go SDK] Recreate a failed data/state channel without holding the lock [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/10/05 11:11:57 UTC, 8 replies.
- [PR] bump code coverage to v7 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/05 12:02:01 UTC, 2 replies.
- Re: [PR] Cache BigQuery table definitions in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 12:54:07 UTC, 2 replies.
- Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 12:54:10 UTC, 2 replies.
- Re: [PR] Add support for datetime, date, and frozenset to FastPrimitivesCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 12:54:12 UTC, 2 replies.
- Re: [I] [Bug]: [IcebergIO] Use RecordWriterManager for Partitioned writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 12:54:15 UTC, 0 replies.
- Re: [I] [Feature Request]: Support reading from BigTable Continuous Materialized Views in BigtableIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/05 12:54:19 UTC, 1 replies.
- [PR] Handle null split initialization results in Flink lazy source enumerator [beam] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/10/05 12:58:15 UTC, 5 replies.
- [PR] simple comment to test reviewers [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/05 14:02:03 UTC, 2 replies.
- Re: [PR] Prevent CommitTooLargeException in OrderedEventProcessor on duplicate floods [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/05 14:33:46 UTC, 0 replies.
- Re: [I] [Bug]: Unrecoverable Runner Errors (CommitTooLargeException) When Emitting High Volume of Duplicate/Unprocessed Events in OrderedEventProcessor [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/05 14:33:48 UTC, 0 replies.
- Re: [I] Deprecate .withProjection from ParquetIO [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/05 15:53:33 UTC, 0 replies.
- Re: [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/05 15:59:34 UTC, 5 replies.
- Re: [I] [Feature Request][Go SDK]: Improve TextIO splitting performance [beam] - posted by "ManvithPanyam (via GitHub)" <gi...@apache.org> on 2026/10/05 16:03:29 UTC, 0 replies.
- [I] [Bug]: BigQueryIO streaming insert silently ignores transient network errors during response body read [beam] - posted by "damjad (via GitHub)" <gi...@apache.org> on 2026/10/05 18:39:14 UTC, 2 replies.
- [PR] Fix BigQueryIO streaming insert silently dropping transient network errors during response body read [beam] - posted by "damjad (via GitHub)" <gi...@apache.org> on 2026/10/05 18:43:07 UTC, 5 replies.
- [PR] Add a security model for Beam [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/05 19:19:10 UTC, 5 replies.
- Re: [I] [Feature Request]: Improve exception visibility in `FileSystems.matchSingleFileSpec` to prevent masking of root-cause Exceptions [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/05 20:42:09 UTC, 0 replies.
- [PR] Remove whitespace for generated managed doc [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/05 20:52:24 UTC, 5 replies.
- Re: [PR] [Python] Fix LogElements crash on global window timestamps [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/05 20:53:17 UTC, 2 replies.
- [PR] fix whitespace [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/05 20:58:25 UTC, 1 replies.
- [PR] Bump github.com/proullon/ramsql from 0.1.4 to 0.1.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 04:23:39 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.68.0 to 1.69.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 04:23:54 UTC, 2 replies.
- [I] [Bug]: Spark ValidatesRunner PostCommits red since parallel test threads (#40324) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/06 09:39:37 UTC, 3 replies.
- [PR] [Spark] Run ValidatesRunner tests serially, runner metrics are JVM wide [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/06 09:39:54 UTC, 14 replies.
- Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/06 09:41:14 UTC, 0 replies.
- [PR] pass the runner clock into batch triggers [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/06 10:08:33 UTC, 3 replies.
- [PR] [Python] Remove leftover "### Labels" debug log in the BigQuery source [beam] - posted by "Ayoubhm07 (via GitHub)" <gi...@apache.org> on 2026/10/06 10:17:11 UTC, 3 replies.
- [PR] Bump pymongo from 4.17.0 to 4.18.2 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 11:37:08 UTC, 3 replies.
- [PR] Bump multidict from 6.7.1 to 6.9.1 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 11:37:17 UTC, 3 replies.
- [PR] Flink source split strategy [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/06 11:59:23 UTC, 1 replies.
- Re: [PR] Fix flaky Python tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:34:11 UTC, 10 replies.
- Re: [PR] Resolve DaskRunner side input OOM by iteratively computing delayed partition [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:34:13 UTC, 11 replies.
- Re: [PR] [Python] Isolate async work by key and window [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:34:16 UTC, 2 replies.
- Re: [PR] Portable Time type (Java + model changes) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:34:20 UTC, 3 replies.
- Re: [PR] [draft] adk example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:32 UTC, 2 replies.
- Re: [PR] Fix GRPC channel leak [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:35 UTC, 3 replies.
- Re: [PR] add another jdbc yaml pipeline and other fixes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:37 UTC, 1 replies.
- Re: [PR] [FnApi Java] Close named data stream multiplexers once no bundle is u… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:42 UTC, 2 replies.
- Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:49 UTC, 2 replies.
- Re: [I] [Bug]: Append to stream projects/my-project/datasets/my-dataset/tables/my-table/streams/_default failed with Status Code NOT_FOUND. The stream may not exist. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:53 UTC, 1 replies.
- Re: [I] [Task]: Add YAML examples using Cloud SQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 12:49:57 UTC, 3 replies.
- [PR] Update Grafana version to 12.4.12 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/06 13:34:57 UTC, 1 replies.
- Re: [PR] Simplify pull request template [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/06 14:19:26 UTC, 1 replies.
- Re: [PR] [PR Bot] Select single main and backup reviewer using label priority [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/06 14:57:29 UTC, 5 replies.
- [PR] Add FlareDB to Beam runner docs [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/10/06 15:46:06 UTC, 6 replies.
- Re: [I] [Feature Request]: Update Beam Grafana instance [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/06 17:52:31 UTC, 0 replies.
- [PR] Prep changes for merging ValidatesRunner jobs [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/10/06 20:27:18 UTC, 5 replies.
- Re: [PR] add more coverage for yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/06 20:32:55 UTC, 1 replies.
- Re: [PR] fix readFromKafka schema error [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/06 20:35:48 UTC, 3 replies.
- [PR] Add PipelineOptions changes for merging ValidatesRunner tests. [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/10/06 20:51:59 UTC, 5 replies.
- [PR] Filter classes accepted by TransformUpgrader deserialization [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/06 20:59:45 UTC, 6 replies.
- Re: [PR] add pubsub max_read_time_seconds parameter [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 22:29:39 UTC, 0 replies.
- Re: [PR] [IcebergIO] Ensure compliance with table encryption [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/06 22:30:47 UTC, 0 replies.
- [PR] Removes usages of the sentence-transformers package... [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/06 22:59:57 UTC, 10 replies.
- [I] [Bug]: RunInference transform might reload the model more than once when a DoFn instance goes out of scope. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/07 02:17:22 UTC, 1 replies.
- [PR] Remove usage of (leaking) shared handles, which can also accidentally release the last reference holding the model. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/07 02:57:26 UTC, 3 replies.
- [I] [Bug]: Uncaught permission exception during VertexAIFeatureStoreEnrichmentHandler initialization [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/10/07 04:53:20 UTC, 2 replies.
- [PR] Fix uncaught permission exception in VertexAIFeatureStoreEnrichmentHandler [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/10/07 04:59:33 UTC, 3 replies.
- [PR] [Java] Make non-extensible classes final instead of suppressing CT_CONSTRUCTOR_THROW [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/10/07 08:30:35 UTC, 3 replies.
- [PR] Fix Grafana alerting [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/07 09:56:33 UTC, 1 replies.
- [I] [Task]: Tighten the late data bound of the Spark 4 streaming stateful ParDo to the previous batch watermark [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/07 11:23:37 UTC, 0 replies.
- [PR] [Spark 4] Filter late data against the key's previous watermark in the streaming stateful ParDo [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/07 11:23:51 UTC, 4 replies.
- [I] [Failing Test]: AsyncWrapperTest.testBufferStopsAcceptingItems flaky on Windows [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/07 11:38:40 UTC, 3 replies.
- Re: [PR] [OpenTelemetry] set default otel.service.instance.id [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 12:35:58 UTC, 4 replies.
- Re: [PR] [Java] Bound pending Watch results per poll [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 12:36:00 UTC, 5 replies.
- Re: [I] [Task][Maintenance]: Maintain Apache Beam Quest Labs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 12:53:49 UTC, 0 replies.
- [PR] Make AsyncWrapperTest deterministic (#40448) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/07 13:42:16 UTC, 9 replies.
- Re: [I] [Bug]: BeamSchema issue [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/07 13:57:14 UTC, 0 replies.
- Re: [PR] Add Dynamic Schema support to StorageWriteToBigQuery [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/07 13:59:57 UTC, 6 replies.
- Re: [PR] fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/07 14:08:24 UTC, 1 replies.
- [PR] Export runtimeOnly dependencies to Maven POM for unshaded modules [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/07 14:47:25 UTC, 7 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/07 14:51:01 UTC, 0 replies.
- [PR] Bump pymongo from 4.17.0 to 4.18.2 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 15:34:21 UTC, 3 replies.
- [PR] Bump multidict from 6.7.1 to 6.9.1 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 15:35:18 UTC, 3 replies.
- Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/07 15:45:25 UTC, 4 replies.
- Re: [PR] Flink dropping watermarks hold fix [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/07 15:59:55 UTC, 4 replies.
- [PR] Propagate stable code identifier pickling and preserve pickler config [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2026/10/07 16:03:34 UTC, 6 replies.
- Re: [I] [Task]: Create a script to train sklearn model for IT test. [beam] - posted by "EddySmith345 (via GitHub)" <gi...@apache.org> on 2026/10/07 16:18:18 UTC, 0 replies.
- [I] [Task]: Use Timestamp logical type in Beam SQL [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/07 16:21:05 UTC, 1 replies.
- [PR] Fix Iceberg CDC reads with filtering on DATE, TIME, TIMESTAMP [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/07 17:05:50 UTC, 6 replies.
- [PR] Add warning for KryoCoder deserialization [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/07 17:17:44 UTC, 7 replies.
- [PR] [Iceberg CDC source] Allow dropping PK or watermark columns [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/07 18:40:21 UTC, 8 replies.
- Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/07 18:46:30 UTC, 7 replies.
- [PR] Reduce Gradle build and test log spam in Java CI workflows [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/07 20:04:57 UTC, 7 replies.
- [PR] [Go SDK] Add the standard millis_instant and decimal logical types [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/10/07 22:53:12 UTC, 7 replies.
- [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/10/07 22:53:27 UTC, 4 replies.
- [I] [Bug]: ReadFromText with escapechar skips a delimiter that comes right after an escaped one [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/07 23:27:11 UTC, 2 replies.
- [PR] [Python] Don't skip a delimiter right after an escaped one in ReadFromText [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/07 23:28:52 UTC, 3 replies.
- Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/07 23:51:46 UTC, 4 replies.
- Re: [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 01:16:22 UTC, 6 replies.
- [I] [Bug]: SortAndBatchElements batches never reach max_batch_weight [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/08 04:28:22 UTC, 2 replies.
- [PR] Let SortAndBatchElements batches reach max_batch_weight [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/08 04:28:59 UTC, 3 replies.
- [PR] [Python] Catch PermissionDenied when checking the feature store in VertexAIFeatureStoreEnrichmentHandler [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/08 07:59:56 UTC, 4 replies.
- Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/10/08 08:33:00 UTC, 3 replies.
- Re: [PR] pin Side Input Test 8 container [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/08 11:39:58 UTC, 0 replies.
- Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/08 12:27:05 UTC, 1 replies.
- Re: [PR] Fix flaky Java tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 12:36:41 UTC, 6 replies.
- Re: [PR] Add Bigtable CDC YAML SchemaTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 12:36:44 UTC, 16 replies.
- Re: [PR] [Java] Fix TextIO gzip split test on Windows [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 12:36:47 UTC, 1 replies.
- Re: [PR] fix: drain all producer queues in SolaceIO publishResults, not just the current bundle's producer [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 12:53:09 UTC, 2 replies.
- Re: [PR] [Python] Set a Beam user agent on the boto3 S3 client [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 12:53:12 UTC, 1 replies.
- [PR] Remove kafka reviewers label [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/08 13:18:43 UTC, 3 replies.
- Re: [PR] Add OpenLineage extension for Java SDK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/08 13:30:14 UTC, 1 replies.
- [PR] Remove unused net.researchgate.release Gradle plugin [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/08 13:36:52 UTC, 2 replies.
- [I] [Failing Test]: Spanner test timeout blocking release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/08 14:19:17 UTC, 2 replies.
- Re: [I] [Bug]: Go SDK row coder encodes INT16 schema fields as varint instead of big endian [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/08 15:40:27 UTC, 0 replies.
- [PR] Fix flaky test 2 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/08 16:03:17 UTC, 0 replies.
- Re: [PR] [YAML] Fix flaky ErrorHandlingTest: don't pickle Scope into user DoFn closures [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/08 16:07:30 UTC, 4 replies.
- Re: [PR] fix pickling issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 16:21:00 UTC, 1 replies.
- [I] [Bug]: [RunInference] max_models_per_worker_hint is not enforced [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/08 19:31:54 UTC, 2 replies.
- Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 19:39:11 UTC, 1 replies.
- [I] [Bug]: [RunInference] With use_model_manager=True, _RunInferenceDoFn acquires acquires models from ModelManager under the tag of the loaded model but it releases them under the transform's original tag. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/08 19:48:53 UTC, 0 replies.
- Re: [I] [Bug]: [RunInference] _RunInferenceDoFn acquires acquires and releases models from ModelManager under different tags when a model is updated. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/08 19:55:07 UTC, 5 replies.
- [I] [Feature Request]: Normalize splunkIO for yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 20:01:29 UTC, 1 replies.
- Re: [I] [Task]: YAML - E2E example pipelines for common use cases [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 20:02:24 UTC, 1 replies.
- Re: [PR] [Python] Configure object detection benchmark timeout [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/08 21:06:04 UTC, 0 replies.
- [PR] remove redundant Thank you [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 21:09:21 UTC, 0 replies.
- [PR] Add bigquery_to_bigtable yaml blueprint example and e2e test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 21:24:54 UTC, 5 replies.
- Re: [PR] remove redundant PR template thank you [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/08 21:26:48 UTC, 0 replies.
- [PR] Fix ModelManager tag mismatch on release after model update (#40469) [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/10/08 21:34:54 UTC, 10 replies.
- Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/10/08 22:21:30 UTC, 2 replies.
- [I] [Bug]: Typo `__int__` in MilvusBaseRanker and wrong type hint on milvus_search.join_fn [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/09 02:24:45 UTC, 3 replies.
- [PR] [Python] Fix __int__ typo and join_fn type hints in Milvus search handler [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/09 02:31:08 UTC, 3 replies.
- [I] [Feature Request]: Optionally write chunk content to the payload in QdrantWriteConfig [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/09 02:45:38 UTC, 5 replies.
- [PR] [DebeziumIO] Update Debezium documentation link to version 3.5 [beam] - posted by "ilyasahsan123 (via GitHub)" <gi...@apache.org> on 2026/10/09 03:05:36 UTC, 3 replies.
- [PR] Fix "Load more" button on blog page [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/09 03:46:55 UTC, 4 replies.
- [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.4.6,<2.5.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 04:23:20 UTC, 4 replies.
- [PR] [SpannerIO] Add withWriteResults() to SpannerIO.Write to emit commit metadata [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/09 08:30:02 UTC, 2 replies.
- [PR] [YAML] Add SplunkIO write SchemaTransform and WriteToSplunk [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/09 09:45:21 UTC, 12 replies.
- [PR] [Solace] Add OpenTelemetry distributed tracing support to SolaceIO (#40175) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/09 09:45:47 UTC, 5 replies.
- [PR] [OpenTelemetry] Fix OpenTelemetry span kinds and add write spans in PubsubIO and KafkaIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/09 12:23:35 UTC, 3 replies.
- [PR] Add gcs_avro_to_cloud_bigtable yaml blueprint example and e2e test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/09 12:36:48 UTC, 0 replies.
- [PR] Add mongodb_to_bigquery yaml blueprint example and e2e test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/09 12:40:57 UTC, 3 replies.
- Re: [PR] Document required Go SDK initialization [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 12:50:56 UTC, 2 replies.
- Re: [PR] Fix Windows paths for Dataflow job files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 12:50:58 UTC, 2 replies.
- Re: [I] [Feature Request]: Add a Variant type to Beam Schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 12:51:08 UTC, 1 replies.
- Re: [PR] Add gcs_avro_to_bigtable yaml blueprint example and e2e test [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 13:13:24 UTC, 7 replies.
- Re: [I] [Failing Test]: JmsIOTest. testCheckpointMark flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/09 13:33:37 UTC, 0 replies.
- Re: [I] [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/09 13:33:37 UTC, 0 replies.
- [PR] Temporarily allow Python 3.10 installations [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/09 14:38:09 UTC, 2 replies.
- [PR] Bump handlebars from 4.7.9 to 4.7.10 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/09 15:31:37 UTC, 2 replies.
- [PR] add typescript reviewers [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/09 16:14:57 UTC, 3 replies.
- [PR] [SpannerIO] Support excludeTxnFromChangeStreams and transactionTag in SpannerIO.Write [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2026/10/09 16:33:48 UTC, 7 replies.
- [PR] [Website] Update IO connector support status post Beam 2.77.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/09 18:03:33 UTC, 3 replies.
- [PR] [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/10/09 18:48:30 UTC, 5 replies.
- [I] [Feature Request]: Avoid reflective lookup and interning in BigQuery Storage Write API unknown-column collectors [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/10/09 19:01:58 UTC, 2 replies.
- [PR] [security-assessment] non-destructive fork-PR gate probe [beam] - posted by "pentestingoverflow (via GitHub)" <gi...@apache.org> on 2026/10/09 20:09:33 UTC, 1 replies.
- [PR] [security-assessment] non-destructive fork-PR approval-gate probe [beam] - posted by "pentestingoverflow (via GitHub)" <gi...@apache.org> on 2026/10/09 20:19:42 UTC, 1 replies.
- [PR] [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/10/10 01:47:52 UTC, 4 replies.
- [PR] Stream Dask side inputs one partition at a time [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/10 02:53:32 UTC, 1 replies.
- Re: [I] [Bug]: DaskRunner `DaskBagWindowedIterator` materializes entire dataset into memory causing OOM [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/10 03:45:16 UTC, 1 replies.
- Re: [PR] Add opt-in lazy Dask side inputs with worker-safe computation [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/10 04:11:03 UTC, 5 replies.
- Re: [I] [Bug]: beam.io.WriteToBigQuery failed when given schema with space [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:40:50 UTC, 0 replies.
- Re: [I] [Bug]: retain_unknown_options incorrectly assumes unknown arguments are consecutive [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:40:51 UTC, 1 replies.
- Re: [I] fileio calls mkdirs with basepath and not dirname(full_file_name) [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:40:53 UTC, 1 replies.
- [PR] [Python] Strip whitespace around ':' in BigQuery string schemas [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:40:56 UTC, 1 replies.
- [PR] [Python] Decide unknown pipeline option arity from the original flags [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:40:58 UTC, 1 replies.
- [PR] [Python] Create file_naming subdirectories in WriteToFiles [beam] - posted by "ODriscollBoys (via GitHub)" <gi...@apache.org> on 2026/10/10 10:41:00 UTC, 1 replies.
- [PR] [Python] Fix max_models_per_worker_hint not being enforced in KeyedModelHandler [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/10 11:00:16 UTC, 8 replies.
- Re: [PR] [DO NOT MERGE] compaction wip [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/10 12:47:27 UTC, 2 replies.
- Re: [I] [Bug]: Beam SDK throws `NoClassDefFoundError` using SparkRunner in Dataproc 2.1 (Java 11) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/10 12:47:38 UTC, 0 replies.
- Re: [I] python typehints: reduce the number of runtime-type-check wrappers [beam] - posted by "Mazen050 (via GitHub)" <gi...@apache.org> on 2026/10/10 18:02:25 UTC, 0 replies.
- [PR] [Python] Merge runtime type-check wrappers [beam] - posted by "Mazen050 (via GitHub)" <gi...@apache.org> on 2026/10/10 20:11:36 UTC, 9 replies.
- [PR] [Python] Optionally write chunk content to Qdrant payload [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/10 21:22:14 UTC, 3 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/10 22:29:15 UTC, 0 replies.
- Re: [PR] [Python] Finish async bundles after processing outputs [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/10 23:12:31 UTC, 2 replies.
- [I] [Bug]: DataFrame API Series.value_counts(bins=...) always fails with TypeError [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/11 01:50:02 UTC, 2 replies.
- [I] [Bug]: DataFrame API agg(['count', ...]) labels the count/size row as 'sum' [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/11 01:50:04 UTC, 2 replies.
- [PR] [Python] Fix DataFrame Series.value_counts with bins [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/11 01:51:06 UTC, 4 replies.
- [PR] [Python] Keep count/size labels in DataFrame agg with a list [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/11 01:51:09 UTC, 3 replies.
- Re: [PR] [Python] Reset BigQuery retries for each batch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 03:30:55 UTC, 2 replies.
- [PR] [Python] Wait for AsyncWrapper work before teardown [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/10/11 03:35:42 UTC, 1 replies.
- [PR] WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2026/10/11 07:34:41 UTC, 6 replies.
- Re: [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 12:49:12 UTC, 2 replies.
- Re: [PR] [Iceberg compaction] Add committer DoFn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 12:49:15 UTC, 2 replies.
- Re: [PR] [Iceberg compaction] Rewrite subgroups DoFn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 12:49:17 UTC, 2 replies.
- Re: [PR] Invalidate cached ContinuationIterable when its continuation fails [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 12:49:22 UTC, 2 replies.
- Re: [I] Java core tests fails on windows: io.TextIOReadTest.testInitialSplitAutoModeGz [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/11 21:56:37 UTC, 0 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 22:27:35 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 22:27:54 UTC, 1 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 22:28:05 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 22:28:46 UTC, 3 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/11 22:29:05 UTC, 1 replies.
- Re: [I] [Bug]: Python `ParquetIO` `_WriteBatches` DoFn silently corrupts data across windows in unbounded pipelines [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/12 02:20:26 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/12 06:35:28 UTC, 1 replies.
- [PR] Fix WriteToFiles not creating nested directories for file_naming paths [beam] - posted by "Akshaay1 (via GitHub)" <gi...@apache.org> on 2026/10/12 06:50:03 UTC, 0 replies.
- [PR] Fix Playground Frontend cloud build [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/12 11:26:41 UTC, 1 replies.
- [PR] [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/12 11:34:10 UTC, 8 replies.
- [I] [Task]: Clear per key watermark and timer state of the Spark 4 streaming stateful processor [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/12 11:34:14 UTC, 4 replies.
- [I] [Bug]: Tour of Beam Firebase Authentication fails with API key expired error [beam] - posted by "LibenHailu (via GitHub)" <gi...@apache.org> on 2026/10/12 11:59:59 UTC, 3 replies.
- [I] [Bug]: DaskRunner silently drops DoFn.finish_bundle outputs [beam] - posted by "Mola-maker (via GitHub)" <gi...@apache.org> on 2026/10/12 12:45:21 UTC, 2 replies.
- Re: [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 12:49:56 UTC, 3 replies.
- [PR] [Python] Preserve DaskRunner finish_bundle outputs [beam] - posted by "Mola-maker (via GitHub)" <gi...@apache.org> on 2026/10/12 12:56:28 UTC, 3 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.8.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:21:32 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.6 to 1.33.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:22:38 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.48.0 to 0.49.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:22:52 UTC, 1 replies.
- [PR] Bump github/codeql-action from 4.38.2 to 4.38.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:22:55 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.300.0 to 0.301.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:23:02 UTC, 1 replies.
- [PR] Bump golang.org/x/sync from 0.23.0 to 0.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:23:06 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.95.1 to 1.96.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 13:23:22 UTC, 1 replies.
- [I] [Feature Request]: Support AWS secrets manager [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/12 14:12:06 UTC, 0 replies.
- [PR] Secret manager 6 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/12 14:18:54 UTC, 0 replies.
- Re: [PR] [PubsubIO] Account for message metadata in bounded write batch size [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/10/12 14:22:37 UTC, 0 replies.
- Re: [I] Add CouchbaseIO [beam] - posted by "mateostefanski (via GitHub)" <gi...@apache.org> on 2026/10/12 14:46:38 UTC, 1 replies.
- Re: [PR] [Python] Add `AwsOptions` and deprecate `S3Options` [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 14:59:04 UTC, 2 replies.
- [PR] Fix OpenTelemetry dependency versions in generated Dataflow runner Maven POM [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 15:11:49 UTC, 4 replies.
- [PR] [Experimental] Update ML deps extras [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/12 16:12:36 UTC, 2 replies.
- Re: [PR] [Java] Fix BigQuery failed-row timestamp conversion [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/12 16:41:27 UTC, 0 replies.
- Re: [PR] [Claude] Capture behavior of the BigQueryWrapper during requests [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 17:08:04 UTC, 1 replies.
- [PR] [Python] Resolve AWS credentials from a secret manager via `--aws_credentials_secret_manager` [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/12 17:36:28 UTC, 1 replies.
- [I] [Feature Request]: Optimized GCS Direct Write for Dense Keys [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/10/12 17:57:06 UTC, 0 replies.
- Re: [PR] [Claude] Produce Beam-specific representation of BQ resources, rework compat shims [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 18:05:22 UTC, 3 replies.
- Re: [I] [Bug]: Flink drops watermark holds for records awaiting a checkpoint [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:13:40 UTC, 0 replies.
- [PR] Enforce read-only PostgreSQL permissions for kubeproxyuser_ro [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:22:06 UTC, 6 replies.
- [PR] Restrict BeamInfluxDB Grafana datasource to HTTP GET queries [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:23:03 UTC, 4 replies.
- [PR] Lock down provisioned Grafana dashboards as non-editable and non-deletable [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:23:49 UTC, 4 replies.
- [PR] Harden Grafana anonymous access, Explore, data proxy, and version disclosure settings [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:24:36 UTC, 4 replies.
- [PR] Apply beamgrafana-deploy.yaml manifest during Beam Metrics deploy task [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/12 18:25:24 UTC, 6 replies.
- [I] [Feature Request][RunInference] Support multi-model KeyedModelHandler with ModelManager [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/10/12 18:33:30 UTC, 3 replies.
- [PR] Clean up Python load test version configs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/12 20:27:54 UTC, 1 replies.
- Re: [PR] [Python] Keep `--s3_api_version` in `S3Options` and remove `--aws_api_version` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 21:13:38 UTC, 0 replies.
- Re: [PR] Fix slow SyntheticSource in Python3.11+, clean up Python load test version configs [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/12 21:18:06 UTC, 2 replies.
- [PR] Modifies Hugging Face model handlers to not use ML packages... [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/12 21:37:38 UTC, 5 replies.
- [PR] Add YAML tests for writing to Iceberg CDC sink [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/12 21:40:29 UTC, 9 replies.
- [PR] [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533) [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/10/13 00:03:31 UTC, 15 replies.
- [PR] [Go SDK] Replace deprecated reflect.PtrTo in schema test [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/10/13 00:32:25 UTC, 3 replies.
- [PR] switch blueprint to pipelines [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/13 00:50:09 UTC, 0 replies.
- [PR] add googleads version upgrade workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/13 01:09:56 UTC, 5 replies.
- Re: [PR] [Python] Make `--aws_*` options defaults and `--s3_*` options S3 overrides [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/13 01:53:42 UTC, 0 replies.
- Re: [PR] [yaml] switch blueprint to pipelines [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 01:56:58 UTC, 4 replies.
- [PR] [Python] Resolve AWS credentials through a secret manager (`--aws_credentials_secret_manager`) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/13 02:02:28 UTC, 9 replies.
- Re: [PR] Omit state commits in stateful Dofn [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2026/10/13 05:03:59 UTC, 6 replies.
- Re: [PR] [Python] Keep BigQuery load jobs distinct for table aliases [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 05:12:46 UTC, 2 replies.
- Re: [PR] [Python] Fail bundles on state write errors [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 05:49:39 UTC, 4 replies.
- Re: [I] [Bug]: Python Nexmark Query 1 is broken unsupported operand & float and int [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 06:36:51 UTC, 1 replies.
- Re: [I] ZeroDivisionError if source bundle smaller than 1mb [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 06:36:53 UTC, 1 replies.
- [PR] [Python] Keep Nexmark Query 1 bid prices as integers [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 06:37:10 UTC, 9 replies.
- [PR] [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 06:37:14 UTC, 5 replies.
- [PR] [Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/13 10:00:17 UTC, 8 replies.
- [PR] Bump apache-beam from 2.75.0 to 2.77.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 11:39:14 UTC, 0 replies.
- Re: [PR] Bump apache-beam from 2.75.0 to 2.76.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 11:39:23 UTC, 1 replies.
- Re: [PR] [Java][BigQueryIO] Fix BigQueryIO streaming insert silently dropping transient network errors during response body read [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 12:40:49 UTC, 2 replies.
- Re: [PR] [Iceberg compaction] Rewrite planner transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 12:59:16 UTC, 1 replies.
- Re: [PR] [Java] Avoid per-schema RowCoder class generation [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/13 13:51:15 UTC, 1 replies.
- [PR] [CI] Use Develocity cache node for the remote Gradle build cache [beam] - posted by "clayburn (via GitHub)" <gi...@apache.org> on 2026/10/13 14:15:30 UTC, 6 replies.
- Re: [I] [Task]: Rename dataflow runner v2 to dataflow portable runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/13 14:45:01 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support for Python 3.15 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/13 15:02:27 UTC, 0 replies.
- [PR] [OpenTelemetry] Spanner change streams otel configuration cleanup [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/13 15:31:57 UTC, 6 replies.
- Re: [PR] [Java] Fix GRPC channel leak [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/13 15:35:44 UTC, 5 replies.
- [PR] Catch alternate exception type in NumpyBatchConverter [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/13 15:40:51 UTC, 3 replies.
- [PR] Replace typing.ByteString with collections.abc.Buffer [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/13 15:42:38 UTC, 3 replies.
- [I] [Feature Request]: Honor --quota_project_id in Python GCS/Pub/Sub IO and the Java-backed BigQuery STORAGE_WRITE_API path [beam] - posted by "shahar1 (via GitHub)" <gi...@apache.org> on 2026/10/13 16:25:44 UTC, 4 replies.
- Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam] - posted by "shahar1 (via GitHub)" <gi...@apache.org> on 2026/10/13 16:36:09 UTC, 1 replies.
- [I] [Feature Request]: Upgrade Gradle wrapper to 9.x for JDK 25 support [beam] - posted by "CH-Abhinav (via GitHub)" <gi...@apache.org> on 2026/10/13 16:48:32 UTC, 1 replies.
- [I] [Feature Request]: Modernize legacy DoFn in BatchElementsExample to use parameter injection [beam] - posted by "CH-Abhinav (via GitHub)" <gi...@apache.org> on 2026/10/13 16:58:16 UTC, 2 replies.
- [PR] [Python] Add `AwsSecret` to the `Secret` utility [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/13 17:35:51 UTC, 5 replies.
- [PR] poll BigQuery matchers on missing tables [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/13 17:46:05 UTC, 7 replies.
- [PR] Modernize legacy DoFn in BatchElementsExample (#40557) [beam] - posted by "CH-Abhinav (via GitHub)" <gi...@apache.org> on 2026/10/13 17:54:37 UTC, 3 replies.
- Re: [PR] [Python] Add typed decision questions and model adapters [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/13 19:20:39 UTC, 2 replies.
- Re: [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/13 19:50:50 UTC, 0 replies.
- [PR] Add Gemini Enterprise Agent Platform code review workflow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/13 20:06:24 UTC, 10 replies.
- [I] [Bug]: Regex.all_matches fails for a regex without groups and drops nested or unmatched groups [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 20:47:44 UTC, 2 replies.
- [PR] [Python] Return every group from Regex.all_matches [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 20:47:55 UTC, 5 replies.
- [I] [Bug]: PeriodicImpulse and MatchContinuously default start_timestamp is the module import time [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 20:47:57 UTC, 2 replies.
- [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/13 20:48:07 UTC, 5 replies.
- [PR] Upgrade Google Ads to 47.0.0 (API v25) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/13 21:33:05 UTC, 3 replies.
- [PR] minor google ads version workflow changes [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/13 22:10:41 UTC, 2 replies.
- [PR] [Python] Don't override the Dataflow endpoint by default [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/14 03:28:16 UTC, 16 replies.
- [I] [Feature Request]: Support non-default Google Cloud universe domains (GOOGLE_CLOUD_UNIVERSE_DOMAIN) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/14 03:30:51 UTC, 0 replies.
- [I] [Bug]: DataFrame API drop_duplicates and duplicated fail on rows with NaN [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/14 07:03:37 UTC, 1 replies.
- [PR] [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/14 07:04:10 UTC, 7 replies.
- [I] [Bug]: DataFrame API Series.agg with a list drops the Series name for mean, std, var [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/14 07:38:45 UTC, 2 replies.
- [PR] [Python] Keep the Series name in DataFrame Series.agg with a list [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/10/14 07:39:04 UTC, 3 replies.
- [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/14 10:30:28 UTC, 7 replies.
- Re: [I] Support SetState in Dataflow runner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/10/14 12:41:07 UTC, 1 replies.
- Re: [I] Support MapState in DataflowRunner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/10/14 12:41:18 UTC, 1 replies.
- [PR] Update portability.md to remove Dataflow Runner v2 reference. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/10/14 12:56:07 UTC, 2 replies.
- Re: [PR] Merge ValidatesRunner tests into small number of Dataflow jobs, each job hosting multiple tests. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/10/14 14:08:45 UTC, 2 replies.
- [PR] Update FlareDB runner doc [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/10/14 14:24:04 UTC, 6 replies.
- [PR] Keep latest metrics image tags updated and set commit image tags after kubectl apply [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/14 14:24:35 UTC, 0 replies.
- [PR] Update Trivial Inference for Python 3.15 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/14 14:43:05 UTC, 6 replies.
- [PR] [OpenTelemetry] Resolve inline Secret placeholders in openTelemetryProperties [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/14 14:43:48 UTC, 10 replies.
- [I] [Feature Request]: Support Protobuf 7.x in Python SDK [beam] - posted by "sofiathoren (via GitHub)" <gi...@apache.org> on 2026/10/14 15:20:00 UTC, 0 replies.
- [PR] [Python] Support Protobuf 7.x [beam] - posted by "sofiathoren (via GitHub)" <gi...@apache.org> on 2026/10/14 15:21:17 UTC, 4 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.0 to 2.15.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/14 15:44:31 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.11 to 1.23.14 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/14 15:45:49 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.2 to 1.47.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/14 15:47:22 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.8 to 1.20.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/14 15:48:20 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.59.0 to 0.61.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/14 15:49:10 UTC, 2 replies.
- [PR] [yaml] - fix spanner configs and examples [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 16:50:15 UTC, 4 replies.
- [PR] Fix handling of cancelled tickets. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/14 17:21:56 UTC, 4 replies.
- [PR] add a draft gemini review check [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 18:02:33 UTC, 6 replies.
- [PR] update node to 24 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 18:28:53 UTC, 0 replies.
- Re: [PR] update node in workflows to 24 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 19:01:02 UTC, 3 replies.
- [PR] Bump minimum cryptography bounds beyond known severe CVEs [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/14 19:08:52 UTC, 3 replies.
- [PR] Add examples for AWS credentials from a secret manager [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/14 19:22:33 UTC, 7 replies.
- [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/10/14 19:56:58 UTC, 14 replies.
- [PR] simple change [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 20:39:55 UTC, 1 replies.
- Re: [PR] [test] - gemini draft review workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/14 20:47:39 UTC, 5 replies.
- [PR] Fix JmsIO finalize removal warning and clean up stale Java version logic [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/14 21:30:14 UTC, 3 replies.
- [PR] Remove a race with another file write that is not essential to test presence of duplicates. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/14 22:55:48 UTC, 8 replies.
- [PR] Correct pickling error check. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/14 23:38:28 UTC, 3 replies.
- [PR] Enable throttling logic. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/15 00:21:11 UTC, 2 replies.
- Re: [PR] Enable throttling logic in RemoteInference. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 00:42:35 UTC, 9 replies.
- [PR] [Python] Document the import-time default of PeriodicImpulse start_timestamp [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/15 00:50:36 UTC, 4 replies.
- [PR] Clarify known restriction for model updates via side inputs. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/15 01:02:22 UTC, 0 replies.
- [PR] update more nodes [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/15 01:23:36 UTC, 9 replies.
- Re: [PR] Clarify known restrictions for model updates via side inputs. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 01:44:13 UTC, 3 replies.
- [PR] Fix missing method delegations in RunInference wrapper ModelHandlers [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/15 02:35:39 UTC, 3 replies.
- [PR] [Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful batching [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/15 02:49:53 UTC, 3 replies.
- [PR] Bump github.com/moby/moby/client from 0.6.1 to 0.6.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 04:23:25 UTC, 2 replies.
- [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] - posted by "jbonofre (via GitHub)" <gi...@apache.org> on 2026/10/15 07:22:23 UTC, 2 replies.
- [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2026/10/15 07:30:51 UTC, 21 replies.
- [I] [Feature Request]: Flink runner: batch performance improvements [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:11:06 UTC, 1 replies.
- [PR] [Flink] Re-split and balance bounded source splits in batch [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:14:54 UTC, 4 replies.
- [PR] [Flink] Copy length-prefixed batch records and decode grouping inputs lazily [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:14:57 UTC, 5 replies.
- [PR] [Flink] Throttle Flink metric updates from source readers [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:14:58 UTC, 5 replies.
- [PR] [Flink] Add a dedicated operator for batch combines in the global window [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:15:02 UTC, 2 replies.
- [PR] [Flink] Reshuffle batch inputs round-robin from deterministic start channels [beam] - posted by "jto (via GitHub)" <gi...@apache.org> on 2026/10/15 10:15:04 UTC, 5 replies.
- Re: [I] [Feature Request]: beam.io.writetopubsub supporting ordering key [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 12:50:09 UTC, 0 replies.
- Re: [I] The PostCommit Python Arm job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/15 13:35:50 UTC, 0 replies.
- [PR] Add support for zoneinfo UTC timestamps [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/15 14:13:45 UTC, 4 replies.
- [PR] Default to parquet in AddFiles for extension less files. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/15 14:57:29 UTC, 5 replies.
- [PR] [yaml] move pipeline examples from blueprint to pipelines [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/15 15:19:35 UTC, 5 replies.
- [PR] [Spanner Change Streams] Add DEADLINE_EXCEEDED to default retryable codes in SpannerIO.ReadChangeStream [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/15 16:30:32 UTC, 2 replies.
- [PR] [yaml] fix documentation and tests for flags [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/15 16:35:23 UTC, 4 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 16:35:39 UTC, 0 replies.
- [I] The PostCommit Java PVR Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/15 16:35:40 UTC, 2 replies.
- Re: [I] Python typehints: support forward references [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/15 17:06:18 UTC, 1 replies.
- [PR] Trigger BQ CDC IT. Fix impl [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/15 17:19:52 UTC, 7 replies.
- Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/15 17:50:34 UTC, 2 replies.
- [PR] Allow ':' in secret option values and reject malformed parameters [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/15 17:52:24 UTC, 5 replies.
- [PR] Follow up fix fork comiple errors [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/15 19:22:54 UTC, 2 replies.
- [PR] Partially revert #40595 to fix compilation error [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/15 19:27:44 UTC, 3 replies.
- [PR] add WRITE_TRUNCATE_DATA write_disposition to the bigquery python sdk [beam] - posted by "GaryPWhite (via GitHub)" <gi...@apache.org> on 2026/10/15 23:59:32 UTC, 6 replies.
- [PR] Correctly skip read_gbq tests when apitools is unavailable [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/16 01:24:02 UTC, 1 replies.
- [PR] [Prism] Keep a stateful key in progress while a split primary holds it [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2026/10/16 01:43:47 UTC, 3 replies.
- [PR] [BEAM-19954] Resolve string annotations in callable type hints [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/16 02:10:07 UTC, 14 replies.
- Re: [PR] feat: Qdrant Search Handler [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/16 02:14:32 UTC, 1 replies.
- [PR] [Prism] Guard ClearOrderedListState against uninitialized state maps [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2026/10/16 02:27:13 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.301.0 to 0.302.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 04:25:30 UTC, 2 replies.
- Re: [PR] Fix Python unit tests broken by google-api-core arriving via cloud-sql-python-connector 1.23.0 [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 04:58:49 UTC, 1 replies.
- [I] [Feature Request]: Add a Qdrant search enrichment handler for ml.rag [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/16 06:34:54 UTC, 2 replies.
- [PR] [Python] Add Qdrant search enrichment handler [beam] - posted by "pangwangshu (via GitHub)" <gi...@apache.org> on 2026/10/16 06:38:02 UTC, 7 replies.
- [I] [Bug]: Quota retry filter masks non-JSON HTTP 403 errors [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/16 10:49:20 UTC, 2 replies.
- [PR] [Python] Preserve HTTP errors for non-JSON quota responses [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/10/16 10:55:14 UTC, 4 replies.
- [PR] Run portable ValidatesRunner tests one at a time [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/16 11:09:16 UTC, 9 replies.
- Re: [PR] [Spanner Change Streams] Match single-RPC deadline to total timeout in SpannerIO.ReadChangeStream [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/16 12:21:51 UTC, 2 replies.
- Re: [PR] Bound PGBKCVOperation precombine table by in-memory size (#39754) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 12:48:21 UTC, 0 replies.
- Re: [PR] fix: poll publish results from all producers in SolaceIO writer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 12:48:24 UTC, 2 replies.
- Re: [I] [Failing Test]: portable_runner_test in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 12:48:37 UTC, 4 replies.
- [PR] [yaml] - fix post commit yaml test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/16 13:47:40 UTC, 4 replies.
- [PR] Restore Java 11 support in setJavaVerOptions [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/16 15:29:45 UTC, 1 replies.
- [PR] [typescript] - fix typescript failures [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/16 16:25:38 UTC, 3 replies.
- [I] [Bug]: RunInference ModelManager NNLS model approximates different data points [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/16 16:57:14 UTC, 8 replies.
- [PR] [Dataflow Streaming] Speed up non-portable worker precommit tests [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/10/16 17:11:35 UTC, 1 replies.
- [I] [Bug]: [RunInference] WatchFilePattern may fail to correctly identify the most recent model [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/16 19:13:56 UTC, 1 replies.
- Re: [I] [Bug]: RunInference with automatic refresh using a global window side inputs takes too long to update sometimes [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/16 19:37:32 UTC, 1 replies.
- Re: [PR] [Python] Add examples for AWS credentials from a secret manager [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/16 19:50:36 UTC, 0 replies.
- [PR] Adds bytes read reporting for SDF. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/10/16 20:31:46 UTC, 9 replies.
- [PR] [Prism] Finalize bundles of DoFns fused after another transform [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2026/10/16 21:32:05 UTC, 4 replies.
- [PR] Update nlp_tensorflow_streaming.ipynb [beam] - posted by "ryanmcginnis (via GitHub)" <gi...@apache.org> on 2026/10/16 22:19:22 UTC, 3 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/16 22:24:42 UTC, 0 replies.
- [I] [Bug]: [RunInference] Pipelines using ModelHandlers with max_batch_by_weight fail at construction time [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/16 23:27:09 UTC, 0 replies.
- Re: [I] [Bug]: [RunInference] Pipelines using ModelHandlers with max_batch_weight fail at construction time [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/16 23:33:53 UTC, 13 replies.
- Re: [I] [Task]: Improve the schema support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/17 12:42:17 UTC, 0 replies.
- [I] [Failing Test]: Flink 1.20 portable DataSet ValidatesRunner tests hang [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/17 13:29:50 UTC, 4 replies.
- [PR] Only feed total memory readings to the ModelManager resource estimator [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/17 20:45:32 UTC, 8 replies.
- Re: [I] Non-transient non-serializable instance field in WatermarkHold [beam] - posted by "rakeshthinqq (via GitHub)" <gi...@apache.org> on 2026/10/18 06:56:29 UTC, 4 replies.
- Re: [I] [Bug]: Python Enrichment BigQuery handler does not expose `max_batch_duration_secs` to `BatchElements` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/18 12:42:46 UTC, 1 replies.
- [PR] [Python] Only give an unknown option a value that directly follows it [beam] - posted by "Thanatos9404 (via GitHub)" <gi...@apache.org> on 2026/10/18 17:41:03 UTC, 1 replies.
- [PR] Adds CouchbaseIO, a Java connector for Couchbase Server. Fixes #18381. [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/10/18 19:44:53 UTC, 0 replies.
- Re: [PR] [DoNotMerge] Adds CouchbaseIO, a Java connector for Couchbase Server. Fixes #18381 [DonNotMerge] [beam] - posted by "github-advanced-security[bot] (via GitHub)" <gi...@apache.org> on 2026/10/18 19:55:47 UTC, 0 replies.
- Re: [I] [Bug]: Go SDK registration panics on anonymous structs. [beam] - posted by "Thanatos9404 (via GitHub)" <gi...@apache.org> on 2026/10/18 20:30:33 UTC, 0 replies.
- [PR] [Go SDK] Fix generic registration of anonymous struct types [beam] - posted by "Thanatos9404 (via GitHub)" <gi...@apache.org> on 2026/10/18 20:31:10 UTC, 2 replies.
- Re: [I] [Feature Request]: Set quota project in `beam.io.ReadFromBigQuery` [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/19 03:09:25 UTC, 0 replies.
- [PR] Bump google.golang.org/api from 0.302.0 to 0.304.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 04:48:40 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.38.3 to 4.39.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 04:48:50 UTC, 2 replies.
- [PR] Bump zizmorcore/zizmor-action from 0.6.4 to 0.7.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 04:49:45 UTC, 2 replies.
- [PR] [IcebergIO] Support sorted writes and RANGE distribution mode [beam] - posted by "atognolag (via GitHub)" <gi...@apache.org> on 2026/10/19 09:52:43 UTC, 3 replies.
- Re: [PR] [IcebergIO] Support sorted writes and RANGE distribution mode (#38406) [beam] - posted by "atognolag (via GitHub)" <gi...@apache.org> on 2026/10/19 09:53:06 UTC, 0 replies.
- Re: [I] [Bug]: SolaceIO write transform does not output all publish results [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/19 10:14:03 UTC, 1 replies.
- Re: [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 12:50:57 UTC, 1 replies.
- Re: [I] [Feature Request]: Support for iceberg dynamic destination with varying schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 12:51:15 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 12:51:18 UTC, 3 replies.
- [PR] Update users.yml [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/19 13:30:25 UTC, 3 replies.
- [PR] Update api key for tour of beam [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/19 13:49:54 UTC, 4 replies.
- [PR] Fix postgres database for grafana [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/19 14:14:08 UTC, 1 replies.
- [PR] Document Beam Playground security model and result caching [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/19 15:42:17 UTC, 0 replies.
- [PR] [yaml] - add openai model handler [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/19 15:47:40 UTC, 1 replies.
- [PR] Process deletes before adds when committing OrderedList state updates. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/10/19 17:37:17 UTC, 4 replies.
- [I] The Community Metrics Prober job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:11 UTC, 2 replies.
- [I] The PerformanceTests SpannerIO Write 2GB Python Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:22 UTC, 1 replies.
- [I] The PreCommit SQL Java17 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:25 UTC, 5 replies.
- [I] The PerformanceTests SpannerIO Read 2GB Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:36 UTC, 1 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:38 UTC, 3 replies.
- [I] The Flaky test detection job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:47 UTC, 3 replies.
- [I] The Release Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:49 UTC, 2 replies.
- [I] The Publish Website job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 18:45:53 UTC, 2 replies.
- [PR] remove Beam SQL Data Catalog provider [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/19 18:52:31 UTC, 0 replies.
- [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 19:00:03 UTC, 3 replies.
- [I] [Bug]: [RunInference] When load_model_at_runtime=True, the first batch always ignores model side-input updates. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/19 19:07:58 UTC, 1 replies.
- [PR] Allow canceling SQL streaming pipeline [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/19 19:11:25 UTC, 5 replies.
- Re: [PR] Remove Beam SQL Data Catalog provider [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 19:25:48 UTC, 5 replies.
- [PR] Model updates [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/19 19:34:21 UTC, 5 replies.
- Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/19 20:05:41 UTC, 0 replies.
- Re: [PR] [Java] ParquetIO: resolve file records against the read schema [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/19 20:06:09 UTC, 0 replies.
- [PR] Fix Release NightlySnapshot after enabling errorprone for Java17+ build [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/19 20:20:05 UTC, 4 replies.
- [PR] Add retries and timeout to Grafana request in flaky test detection [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/19 21:33:38 UTC, 1 replies.
- [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 21:37:54 UTC, 2 replies.
- [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 21:37:58 UTC, 2 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/19 21:38:01 UTC, 1 replies.
- [PR] Upgrade google-api-client to 2.7.2 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/19 21:59:41 UTC, 4 replies.
- [PR] Scope RunInference model_identifier annotation and preserve ModelManager metric_tag across model updates [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/10/19 22:28:31 UTC, 4 replies.
- [PR] [Java] Honor GOOGLE_CLOUD_UNIVERSE_DOMAIN for the Dataflow endpoint [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 01:05:42 UTC, 6 replies.
- [I] [Bug]: Using MultiProcessShared handle can deadlock when always_proxy=True [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/20 01:21:46 UTC, 7 replies.
- [PR] [Python] Fix GCS client creation in non-default universes (TPC) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 01:37:02 UTC, 2 replies.
- [PR] [Python] Support custom BigQuery endpoints and universe domains [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 02:49:15 UTC, 7 replies.
- [PR] Fix bigquery_tools_test to mock gcp_bigquery library instead... [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/20 02:51:07 UTC, 3 replies.
- [PR] [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 03:12:00 UTC, 9 replies.
- Re: [PR] [Python] Fix GCS client creation in non-default universes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 03:18:11 UTC, 1 replies.
- [PR] [Iceberg] Merge on read fixes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/20 04:04:28 UTC, 2 replies.
- [PR] Bump distlib from 0.4.3 to 0.4.4 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 04:23:10 UTC, 2 replies.
- Re: [I] Type inference works incorrectly with tuple slices [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/20 05:52:36 UTC, 0 replies.
- [PR] [Python] Infer the right type for slices of fixed-size tuples [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/20 05:52:41 UTC, 3 replies.
- Re: [I] _MaterializedDoOutputsTuple doesn't support __getitem__ by integer values [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/20 05:52:42 UTC, 0 replies.
- [PR] [Python] Accept int tags on Partition results applied to a list [beam] - posted by "raams95 (via GitHub)" <gi...@apache.org> on 2026/10/20 05:52:48 UTC, 2 replies.
- [PR] [#40644][Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful and keyed RunInference batching [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/10/20 09:26:21 UTC, 4 replies.
- [PR] Fix SpannerIO PerformanceTests workflows [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/20 11:42:07 UTC, 6 replies.
- [PR] Fix IcebergIO Integration Tests on Dataflow workflows [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/20 11:50:32 UTC, 2 replies.
- Re: [I] [Task]: Implement BeamFileSystemClient [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 12:51:38 UTC, 0 replies.
- Re: [I] [Feature Request]: Support for efficient serialization of more built-in types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 12:51:39 UTC, 0 replies.
- Re: [I] [Task]: Remove hadoop-common pin from expansion service and Iceberg modules [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 12:51:41 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 12:51:47 UTC, 1 replies.
- [PR] Fix Release Nightly Snapshot job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/20 13:05:37 UTC, 4 replies.
- Re: [PR] Upgrade google-api-client to 2.7.2 and use bomupgrade to manage [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 13:36:45 UTC, 0 replies.
- [PR] Tpc 5 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 14:53:10 UTC, 0 replies.
- Re: [PR] [Go] Support non-default universes for GCS and Dataflow clients [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 15:07:19 UTC, 5 replies.
- Re: [PR] [RunInference] Honor model updates in also in the first batch. [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/20 15:15:13 UTC, 2 replies.
- [PR] Revert errant google-adk bump on master [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/20 15:52:39 UTC, 2 replies.
- [PR] Bump github.com/klauspost/compress from 1.15.9 to 1.18.7 in /playground/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/20 15:55:22 UTC, 2 replies.
- [PR] [Experimental] Update google-adk dependency range [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/20 15:59:56 UTC, 7 replies.
- [PR] Add an option to set the Dataflow container base repository (Python, Java, Go) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/20 16:06:12 UTC, 4 replies.
- [PR] AddFiles: Parse partition keys in filepath for requirement check [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/10/20 16:09:47 UTC, 7 replies.
- [PR] Update test case for numpy 2.4.6 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/20 16:12:44 UTC, 3 replies.
- [PR] Fix Publish Website workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/20 17:42:45 UTC, 4 replies.
- Re: [I] [Bug]: Row.toString throws for an ITERABLE field that is not backed by a List [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/20 18:01:26 UTC, 0 replies.
- [PR] Update xgboost dependency, execute in CI [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/20 19:34:31 UTC, 8 replies.
- [PR] Expand Beam SQL TPC-DS query support and add Python TPC-DS suite [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/20 20:32:36 UTC, 15 replies.
- [PR] Update Python container image requirements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/20 20:55:23 UTC, 1 replies.
- [PR] [release-2.77.0-postrelease] Update Python container image requirements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/20 20:55:40 UTC, 0 replies.
- [I] [Feature Request]: Allow non-identifier column names in Python Row [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/20 21:39:36 UTC, 4 replies.
- Re: [PR] [Java][BigQueryIO] Honor allowMissingRequiredFields when building Storage Write API messages [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/20 23:51:34 UTC, 3 replies.
- [PR] Support Environment Sensitive Staging [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/10/21 02:52:53 UTC, 8 replies.
- [PR] test: allow users to set custom Neo4j config [beam] - posted by "fbiville (via GitHub)" <gi...@apache.org> on 2026/10/21 11:03:26 UTC, 2 replies.
- [I] [Feature Request]: Expose the full Debezium source metadata (pos, row, ts_ms, ...) in DebeziumIO JSON output [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/21 12:08:28 UTC, 3 replies.
- Re: [I] [Feature Request]: Ability to register translators with Flink Runners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/21 12:50:40 UTC, 0 replies.
- Re: [I] [Feature Request]: Validate YAML transforms with a schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/21 12:50:42 UTC, 0 replies.
- Re: [I] [Bug]: Examples loading twice in ToB [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/21 12:50:45 UTC, 0 replies.
- [PR] [DebeziumIO] Expose the full Debezium source block in SourceRecordJson metadata [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/21 12:53:53 UTC, 3 replies.
- [PR] [#36841] Spark 4 streaming: windowed GroupByKey and Combine via transformWithState [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/21 12:57:42 UTC, 5 replies.
- Re: [PR] Update Numpy and Pandas Deps [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/10/21 15:35:42 UTC, 5 replies.
- [I] [Task]: Remove datatables dependency in Beam 2.79.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/21 15:37:31 UTC, 0 replies.
- Re: [PR] Fix Publish Beam Metrics [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/21 15:43:34 UTC, 1 replies.
- [PR] Fix prober community metrics [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/21 16:35:12 UTC, 3 replies.
- Re: [PR] Handle multi-key bundles in side-input runner [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/21 17:39:54 UTC, 0 replies.
- Re: [PR] Add BigQueryIO support for clone table creation [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/21 17:41:51 UTC, 1 replies.
- [PR] Upgrade allowed version of pillow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/10/21 17:57:54 UTC, 2 replies.
- [I] [Feature Request]: Support pandas 3+ in the dataframes API [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/21 18:20:55 UTC, 0 replies.
- [PR] Update pytorch dependencies [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/21 18:27:11 UTC, 8 replies.
- [PR] Stable code identifier pickling [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2026/10/21 18:39:57 UTC, 0 replies.
- [I] [Task]: Migrate Java SDK GcsUtil from gcsio to the java-storage client [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/21 18:49:38 UTC, 0 replies.
- [PR] Use GcsUtil V2 by default [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/21 18:52:44 UTC, 0 replies.
- [PR] Preserve ModelManager metric_tag across RunInference side-input model updates [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/10/21 21:20:01 UTC, 5 replies.
- Re: [PR] [Java] Use GcsUtil V2 by default [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/10/21 22:25:11 UTC, 9 replies.
- Re: [PR] Scope RunInference model_identifier annotation to BeamML_RunInference [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/21 22:49:50 UTC, 7 replies.
- [I] [Feature Request]: Attach RunInference model_identifier annotation only to the inference ParDo when with_exception_handling(threshold<1) is used [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/10/21 22:57:30 UTC, 0 replies.
- [PR] Fixes some bugs in StateFetchingIterators. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/10/22 00:24:26 UTC, 2 replies.
- [PR] add pr size label [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/22 01:52:23 UTC, 6 replies.
- Re: [PR] add pr size label workflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 02:26:39 UTC, 11 replies.
- [PR] [RunInference] Validate model handler batching arguments [beam] - posted by "alisha-1000 (via GitHub)" <gi...@apache.org> on 2026/10/22 04:18:11 UTC, 6 replies.
- Re: [PR] [DebeziumIO] Add opt-in full metadata (op and Debezium source fields) to readAsJson [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/22 07:39:05 UTC, 1 replies.
- [PR] drop transformers 428 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/22 08:35:30 UTC, 5 replies.
- [I] [Bug]: Portable Java runners deadlock when one bundle's output exceeds ~1 GB (regression in 2.77 from #38407) [beam] - posted by "PabloPauling (via GitHub)" <gi...@apache.org> on 2026/10/22 08:36:10 UTC, 0 replies.
- [PR] [Java fn-execution] Drain bundle output before waiting for the ProcessBundleResponse [beam] - posted by "PabloPauling (via GitHub)" <gi...@apache.org> on 2026/10/22 08:37:23 UTC, 4 replies.
- [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 10:41:51 UTC, 3 replies.
- [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 10:51:52 UTC, 3 replies.
- [PR] Bump aiohttp from 3.14.3 to 3.14.4 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 11:02:50 UTC, 3 replies.
- [PR] Fix IcebergIO Managed Integration Tests on Dataflow workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/10/22 12:33:39 UTC, 5 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow V2 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 12:50:15 UTC, 0 replies.
- Re: [I] FakeJobsService tries to base64 decode a plain QueryString resulting in an error. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 12:50:22 UTC, 0 replies.
- Re: [I] [Bug]: StrUtf8Coder in Python can't deserialize what's encoded with Java StringUtf8Coder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 12:50:26 UTC, 0 replies.
- [PR] rename TestRecord [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/10/22 12:54:21 UTC, 4 replies.
- Re: [PR] [Iceberg CDC sink] Integration tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/22 14:37:36 UTC, 2 replies.
- [PR] [Go] Avoid importing gcpopts in gcsx and dataflowlib to prevent flag collisions [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/22 14:59:14 UTC, 6 replies.
- [I] [Bug]: Go SDK pipeline options define global flags with generic names, causing flag redefinition panics [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/22 14:59:29 UTC, 1 replies.
- [PR] Temporarily skip Iceberg cdc tests for managed service [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/22 16:51:25 UTC, 6 replies.
- [I] [Task]: Un-skip Iceberg CDC tests when Managed service gets updated to 2.77 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/22 19:21:51 UTC, 0 replies.
- Re: [PR] Add Prism integration tests for Delta IO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/22 19:35:59 UTC, 1 replies.
- [PR] [go] - update codeql go workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/10/22 20:34:54 UTC, 3 replies.
- [I] The PreCommit Java Solace IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 21:39:26 UTC, 1 replies.
- [PR] Bump pillow from 12.3.0 to 13.0.0 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 21:39:34 UTC, 3 replies.
- [I] The Local environment tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 21:39:35 UTC, 0 replies.
- [PR] Bump opentelemetry-api from 1.44.0 to 1.45.1 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/22 21:39:39 UTC, 4 replies.
- [PR] [Python] Add PTransform.with_annotations() for per-transform annotations [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/10/22 22:38:59 UTC, 0 replies.
- Re: [PR] [IcebergIO] Use GroupByKey for bounded inputs to avoid OOM [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/22 23:47:10 UTC, 1 replies.
- Re: [I] [Feature Request]: Honor `allowMissingRequiredFields` when building Storage Write API messages from TableRow [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/22 23:49:37 UTC, 0 replies.
- [PR] Fixes some bugs in WindmillMap and WindmillSet. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/10/22 23:57:57 UTC, 2 replies.
- Re: [PR] feat: add configurable bigtable retries [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/10/23 00:09:04 UTC, 0 replies.
- [PR] [Solace] Fix flaky SolaceIO integration tests [beam] - posted by "schizophrenicmaniac (via GitHub)" <gi...@apache.org> on 2026/10/23 00:19:16 UTC, 4 replies.
- [PR] TPC-DS suite follow ups [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/10/23 00:33:40 UTC, 6 replies.
- Re: [PR] [Java] Propagate downstream errors from BigQuery Storage API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/10/23 04:09:41 UTC, 0 replies.
- [PR] Bump google.golang.org/api from 0.304.0 to 0.305.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/10/23 04:23:24 UTC, 4 replies.
- Re: [I] [Feature Request]: Implement least-privilege access for GKE workload hosting Beam metrics. [beam] - posted by "alisha-1000 (via GitHub)" <gi...@apache.org> on 2026/10/23 07:21:50 UTC, 0 replies.
- [PR] [DebeziumIO] Add CHANGES.md entry for opt-in full metadata [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/10/23 08:22:36 UTC, 1 replies.
- Re: [I] [Feature Request]: Create Apache Beam PostgreSQL I/O Connector with streaming support [beam] - posted by "alisha-1000 (via GitHub)" <gi...@apache.org> on 2026/10/23 11:31:22 UTC, 0 replies.
- Re: [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] - posted by "alisha-1000 (via GitHub)" <gi...@apache.org> on 2026/10/23 12:09:53 UTC, 0 replies.
- Re: [I] [Bug]: UNNEST ARRAY with a nested ROW (described below) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/10/23 12:47:56 UTC, 0 replies.
- [PR] [Model] Add V2 standard coders for WindowedValue and Timer with ElementMetadata support [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/10/23 13:19:22 UTC, 2 replies.
- [PR] Update transformers bounds and tests [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/10/23 13:41:55 UTC, 0 replies.