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

---

- Re: [PR] Upgrade GCP Libraries BOM to 26.87.0 [beam] - posted by "lqiu96 (via GitHub)" <gi...@apache.org> on 2026/09/01 02:10:45 UTC, 2 replies.
- Re: [PR] [wip] update spot try [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/01 02:20:41 UTC, 1 replies.
- Re: [PR] upgrade spotless to 7.2.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 02:24:00 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/storage from 1.65.0 to 1.66.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 04:32:49 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.81.0 to 1.82.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 04:33:03 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.3 to 1.109.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 04:34:29 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.44 to 1.23.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 04:35:56 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.52.0 to 1.53.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 04:36:16 UTC, 2 replies.
- [PR] [Python] Configure object detection benchmark timeout [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/01 05:28:46 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/01 05:30:41 UTC, 17 replies.
- Re: [I] [Feature Request]: SolaceIO: Support binary content data payload [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/01 06:34:01 UTC, 0 replies.
- [PR] Updates Beam SQL to support Delta Lake read via Beam DeltaIO [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/01 06:56:44 UTC, 0 replies.
- Re: [PR] Adds Delta Lake read support to Beam SQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 08:23:14 UTC, 4 replies.
- Re: [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 09:20:01 UTC, 0 replies.
- Re: [PR] [#36841] Add streaming dispatch seam to the Spark Structured Streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 09:20:35 UTC, 2 replies.
- Re: [I] [Bug]: Latest.Globally() issues in global window [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/09/01 10:01:08 UTC, 7 replies.
- Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] - posted by "LeonxLJX (via GitHub)" <gi...@apache.org> on 2026/09/01 10:27:58 UTC, 9 replies.
- [PR] [Java] Remove MS_EXPOSE_REP from the global SpotBugs filter [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/01 11:10:25 UTC, 3 replies.
- Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 11:30:42 UTC, 5 replies.
- Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/01 12:15:06 UTC, 8 replies.
- [PR] [#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 12:25:12 UTC, 0 replies.
- Re: [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:32:40 UTC, 3 replies.
- Re: [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:32:50 UTC, 6 replies.
- Re: [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:32:54 UTC, 4 replies.
- Re: [PR] [Java] Avoid RowCoder bytecode generation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:33:01 UTC, 10 replies.
- Re: [PR] Handle multi-key bundles in side-input runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:33:08 UTC, 2 replies.
- Re: [PR] Add BigQueryIO support for clone table creation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:33:10 UTC, 5 replies.
- [PR] [Python] Honor fixed object detection batch size [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/01 12:34:26 UTC, 2 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:44:50 UTC, 3 replies.
- Re: [I] [Feature Request]: Add hint to ReadFromMongoDB, MongoDBIO Connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:45:08 UTC, 0 replies.
- Re: [I] [Task]: Rewrite Go README [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 12:45:10 UTC, 0 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/09/01 12:45:12 UTC, 0 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/09/01 12:45:14 UTC, 0 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/09/01 12:45:16 UTC, 0 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/09/01 12:45:19 UTC, 0 replies.
- Re: [I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/09/01 13:09:43 UTC, 1 replies.
- [PR] Bump to Beam 2.76.0 [beam-starter-java] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/01 13:14:19 UTC, 1 replies.
- [PR] Update Java BOM [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/01 13:17:00 UTC, 1 replies.
- [I] [Failing Test]: KafkaToPubsubE2ETest fails everywhere, pinned cloud-sdk:316.0.0-emulators image was removed from gcr.io [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 13:19:54 UTC, 1 replies.
- Re: [PR] [Flink] Select bounded-source split assignment by estimated size [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/09/01 13:27:35 UTC, 1 replies.
- [PR] Fix KafkaToPubsubE2ETest by bumping the purged cloud-sdk emulator image tag [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/01 13:33:03 UTC, 0 replies.
- Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/09/01 13:36:59 UTC, 4 replies.
- Re: [PR] [Spark][#36841] Reuse the legacy maxRecordsPerBatch option in the Structured Streaming runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 13:38:42 UTC, 2 replies.
- Re: [PR] Implement Iceberg Table Metadata Driver transform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/01 13:48:43 UTC, 27 replies.
- Re: [I] [Feature Request]: Wait.on for Go SDK [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/09/01 14:09:30 UTC, 0 replies.
- Re: [PR] [Kafka] Fix KafkaToPubsubE2ETest by bumping the purged cloud-sdk emulator image tag [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/01 14:32:49 UTC, 0 replies.
- Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/01 14:40:01 UTC, 14 replies.
- [PR] fix PostCommit Python Arm SDK container [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/01 14:41:23 UTC, 3 replies.
- [PR] Update Dataflow Python container [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/01 15:06:14 UTC, 2 replies.
- Re: [PR] [Flink] Cache batch side input materialization in Flink 2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/01 15:09:04 UTC, 0 replies.
- Re: [I] [Flink] Cache materialized side inputs in DataStream batch execution [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/01 15:09:05 UTC, 0 replies.
- Re: [PR] normalize firestoreIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/01 15:34:09 UTC, 11 replies.
- Re: [PR] fix(dataframe): handle pandas dimensionality reduction in .xs() for single-item matches [beam] - posted by "ManvithPanyam (via GitHub)" <gi...@apache.org> on 2026/09/01 15:51:05 UTC, 4 replies.
- Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/01 16:13:24 UTC, 14 replies.
- Re: [PR] upgrade grpc to 1.82.1 for test infra and playground [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/01 16:18:52 UTC, 1 replies.
- Re: [PR] Bump google.golang.org/grpc from 1.49.0 to 1.82.1 in /learning/tour-of-beam/backend [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/01 16:20:15 UTC, 4 replies.
- [I] [Feature Request]: Create Apache Beam PostgreSQL I/O Connector with streaming support [beam] - posted by "jk-shah (via GitHub)" <gi...@apache.org> on 2026/09/01 17:12:29 UTC, 2 replies.
- [PR] Always resolve builtin types in dataclass field type inference [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/01 17:13:31 UTC, 0 replies.
- Re: [I] [Bug]:KafkaIO OAUTHBEARER auth against GCP Managed Service for Apache Kafka broken starting 2.69.0 (works on 2.68.0) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/01 17:17:39 UTC, 6 replies.
- [PR] [Dataflow Streaming] [Multi Key] Flush streaming sinks at key boundaries and bundle completion [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/09/01 20:00:20 UTC, 23 replies.
- [PR] Bump transformers from 4.36.0 to 5.10.1 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 20:34:02 UTC, 2 replies.
- [PR] Bump transformers from 4.38.0 to 5.10.1 in /sdks/python/apache_beam/examples/inference/runinference_metrics [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 21:01:30 UTC, 3 replies.
- [PR] Bump browserslist from 4.16.3 to 4.28.8 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/01 22:57:51 UTC, 2 replies.
- [PR] Add test case verifying metric capture in Setup() lifecycle method [beam] - posted by "kragent66-glitch (via GitHub)" <gi...@apache.org> on 2026/09/02 02:12:55 UTC, 6 replies.
- [PR] Bump golang.org/x/crypto from 0.50.0 to 0.52.0 in /playground/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 02:49:50 UTC, 3 replies.
- [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 03:40:10 UTC, 8 replies.
- [PR] Bump google.golang.org/api from 0.294.0 to 0.295.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 04:23:14 UTC, 2 replies.
- [PR] Bump zizmorcore/zizmor-action from 0.6.2 to 0.6.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 04:24:34 UTC, 4 replies.
- Re: [I] [Failing Test]: Milvus RAG integration tests fail consistently in beam_PreCommit_Python_ML (py3.13) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/02 07:32:06 UTC, 0 replies.
- Re: [PR] Fix PickleCoder.as_deterministic_coder() raising TypeError [beam] - posted by "AmirF194 (via GitHub)" <gi...@apache.org> on 2026/09/02 08:52:59 UTC, 8 replies.
- [I] [Bug]: GCS glob matching drops objects when the pattern contains non-ASCII characters (Go SDK) [beam] - posted by "Shizuma5 (via GitHub)" <gi...@apache.org> on 2026/09/02 09:20:11 UTC, 2 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/02 11:13:48 UTC, 1 replies.
- [I] [Bug]: BigtableIO.readChangeStream() with RESUME_OR_NEW can start duplicate consumers inside one Dataflow job [beam] - posted by "gschlueter-jaconi (via GitHub)" <gi...@apache.org> on 2026/09/02 11:47:40 UTC, 2 replies.
- [PR] [#36841] Add the DataSourceV2 unbounded source for the Spark 4 streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/02 11:48:26 UTC, 0 replies.
- Re: [PR] [Spark 4] Streaming runner proof of concept, unbounded sources, windowed GBK and stateful ParDo on transformWithState [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/02 11:48:38 UTC, 2 replies.
- Re: [PR] [PubsubIO] Account for message metadata in bounded write batch size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:35 UTC, 3 replies.
- Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:37 UTC, 15 replies.
- Re: [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:45 UTC, 4 replies.
- Re: [PR] fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:53 UTC, 6 replies.
- Re: [PR] Encode DynamoDB empty list and empty map attributes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:54 UTC, 3 replies.
- Re: [PR] [Beam SQL] Introduce call procedures [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:33:56 UTC, 4 replies.
- Re: [PR] [Iceberg compaction] file metadata carriers and writer factory [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:34:03 UTC, 3 replies.
- Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:34:06 UTC, 10 replies.
- Re: [PR] [IcebergIO] Use GroupByKey for bounded inputs to avoid OOM [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:34:18 UTC, 3 replies.
- Re: [PR] RedisIO support PCollection of [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:34:20 UTC, 4 replies.
- Re: [PR] Accept integral JSON values that a double represents exactly [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/02 12:43:20 UTC, 0 replies.
- Re: [I] [Bug]: RowJson rejects integral JSON values for a DOUBLE field when they exceed int range [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/02 12:43:21 UTC, 0 replies.
- Re: [I] [YAML][Feature Request]: Integration and Usage of GCP Secret Manager with the different Apache Beam IOs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:46:10 UTC, 0 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/09/02 12:46:12 UTC, 0 replies.
- Re: [I] [Task]: Utilize `PTransform` in Dicom IO and Fhir IO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:46:16 UTC, 1 replies.
- Re: [I] [Task]: Switch to portable Data and Time type for JdbcIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:46:19 UTC, 1 replies.
- Re: [I] [Feature Request]: Support container image prebuilding when ARM workers are used. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 12:46:21 UTC, 1 replies.
- Re: [PR] AddFiles: read side of the schema pre-pass [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/02 13:00:06 UTC, 4 replies.
- Re: [PR] AddFiles: extract bounded async task plumbing and Parquet footer reads [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/02 13:05:48 UTC, 2 replies.
- Re: [PR] [Spark][#36841] Add the DataSourceV2 unbounded source for the Spark 4 streaming runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 13:16:34 UTC, 13 replies.
- [PR] Fix GCS glob matching for multi-byte characters [beam] - posted by "Shizuma5 (via GitHub)" <gi...@apache.org> on 2026/09/02 14:06:08 UTC, 2 replies.
- Re: [PR] Update republish released workflow default values [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 14:16:27 UTC, 1 replies.
- [PR] [IcebergIO] Spec aware file reserialization [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/02 14:25:20 UTC, 5 replies.
- [PR] Bump github.com/apache/thrift from 0.23.0 to 0.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 15:00:16 UTC, 1 replies.
- Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/09/02 15:49:28 UTC, 1 replies.
- [PR] AddFiles: tighten file schemas [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/02 16:14:06 UTC, 4 replies.
- [PR] Fix nullness in extensions/avro [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/02 16:24:15 UTC, 8 replies.
- [PR] [Go] Add parsing for cpu_count resource hint [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/02 16:28:51 UTC, 3 replies.
- [PR] [DO NOT MERGE] full iceberg cdc sink [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/02 17:53:25 UTC, 0 replies.
- [I] [Feature Request]: Create a merge-on-read Iceberg sink [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/02 17:57:37 UTC, 2 replies.
- Re: [I] [Flink] Make bounded-source split assignment configurable by size [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/02 17:59:18 UTC, 0 replies.
- [PR] Implement LLM-driven review assigner for PR bot [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/02 18:15:52 UTC, 14 replies.
- Re: [I] [Feature Request]: add drain() method to PipelineResult [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/02 18:54:25 UTC, 1 replies.
- [PR] [IcebergIO] CDC record and sort key [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/02 18:55:54 UTC, 13 replies.
- [PR] Update IO support matrix after Beam 2.76.0 release [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/02 19:16:29 UTC, 7 replies.
- [PR] Bump golang.org/x/crypto from 0.50.0 to 0.52.0 in /learning/tour-of-beam/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 19:41:07 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.54.0 to 0.55.0 in /learning/tour-of-beam/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 20:15:11 UTC, 1 replies.
- [PR] Bump github.com/cloudevents/sdk-go/v2 from 2.6.1 to 2.15.2 in /learning/tour-of-beam/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/02 20:15:14 UTC, 1 replies.
- Re: [PR] [#38059] Fix GCS glob matching to support ** and / in object names [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/02 20:19:29 UTC, 0 replies.
- Re: [PR] [Spark] Retain the last watermark of a source with no update in the batch [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/03 03:54:07 UTC, 5 replies.
- [PR] [CI] Re-pin gradle/actions/setup-gradle to an allowlisted SHA (v6.3.0) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/03 07:06:41 UTC, 2 replies.
- Re: [I] [Failing Test]: TestAnomalyDetection.test_multiple_detectors_without_aggregation_0 is possibly flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/03 12:46:34 UTC, 1 replies.
- Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/03 13:13:10 UTC, 2 replies.
- [PR] Update staticcheck [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/03 13:32:02 UTC, 4 replies.
- Re: [PR] Fix nullness in BigQueryIO [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/03 14:18:09 UTC, 0 replies.
- [PR] Nullness improvements for Combine, Min, Max [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/03 14:34:54 UTC, 5 replies.
- [PR] ValueKind coder [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/03 15:36:10 UTC, 3 replies.
- [PR] Refactor: delete dead SplitAndSizeRestrictions handling from FnApiDoFnRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/03 16:26:53 UTC, 8 replies.
- [I] [Bug]: Flink drops watermark holds for records awaiting a checkpoint [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 17:40:56 UTC, 3 replies.
- [PR] [Python] Fail bundles on state write errors [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 17:43:50 UTC, 0 replies.
- [PR] [Python] Propagate WriteToFiles finalization failures [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 17:43:56 UTC, 5 replies.
- Re: [PR] [Gemini] Migrate Python BigQuery away from apitools, deprecate old route [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/03 17:46:07 UTC, 6 replies.
- [PR] Adds drain support to Spanner CDC source. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/09/03 17:49:11 UTC, 11 replies.
- [PR] [Python] Reset BigQuery retries for each batch [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 18:08:02 UTC, 1 replies.
- [PR] [Python] Isolate async work by key and window [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 18:13:13 UTC, 4 replies.
- [PR] [Iceberg] CDC config and writer [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/03 18:55:58 UTC, 12 replies.
- [PR] [Gemini] Add compatibility classes between apitools client and modern bq client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/03 19:07:49 UTC, 12 replies.
- [PR] [Java] Preserve BigQuery failed rows across retries [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 19:14:46 UTC, 0 replies.
- Re: [PR] Fix artifact staging windows filename [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/03 19:30:47 UTC, 2 replies.
- [PR] [Python] Finish async bundles after processing outputs [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 19:49:49 UTC, 4 replies.
- [PR] [Python] Keep BigQuery load jobs distinct for table aliases [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 19:53:30 UTC, 1 replies.
- [PR] Introduce LABEL_NOTICE for PR bot [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/03 20:21:12 UTC, 3 replies.
- [PR] AddFiles: SchemaEvolutionConfig, the public settings for the schema pre-pass [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/03 20:36:46 UTC, 3 replies.
- [PR] [Java] Propagate downstream errors from BigQuery success output [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 20:40:13 UTC, 2 replies.
- Re: [PR] [Python] Deflake anomaly transform tests [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/03 21:29:42 UTC, 4 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/03 22:30:18 UTC, 2 replies.
- [PR] [Iceberg] Split late data and create commit windows [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/03 23:11:43 UTC, 0 replies.
- [PR] [Iceberg CDC sink] table setup [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/03 23:16:32 UTC, 6 replies.
- Re: [PR] [Iceberg CDC sink] Split late data and create commit windows [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 00:41:54 UTC, 6 replies.
- [PR] [Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/04 04:23:55 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.109.1 to 1.110.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:25:10 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.1 to 1.23.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:26:26 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.1 to 1.20.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:27:35 UTC, 2 replies.
- [PR] Bump docker/setup-qemu-action from 4.2.0 to 4.3.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:27:46 UTC, 6 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.1 to 1.33.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:28:51 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.295.0 to 0.296.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 04:29:11 UTC, 2 replies.
- Re: [I] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] - posted by "nikhilsh2003 (via GitHub)" <gi...@apache.org> on 2026/09/04 06:43:08 UTC, 2 replies.
- [I] The PostCommit Java Hadoop Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 06:49:38 UTC, 3 replies.
- [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 06:49:42 UTC, 3 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 06:49:46 UTC, 13 replies.
- [PR] Fix cdc coder test [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/04 09:36:10 UTC, 6 replies.
- [PR] [KafkaIO] Fix off-by-one message backlog in SDF read [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2026/09/04 11:28:00 UTC, 4 replies.
- [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/09/04 12:03:43 UTC, 0 replies.
- Re: [PR] [Python] Improve GroupByKey coder validation errors [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:32:26 UTC, 1 replies.
- Re: [PR] Fix PubSub subscription path double-prefix in stale_cleaner (#39772) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:32:28 UTC, 5 replies.
- Re: [PR] [SolaceIO] refactor SolaceIO's writers finishBundle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:32:31 UTC, 7 replies.
- Re: [PR] Add OpenLineage extension for Java SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:32:32 UTC, 3 replies.
- Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:32:34 UTC, 7 replies.
- Re: [I] [Task]: Remove non-cythonized tests, codepath and test suites #28385 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:45:22 UTC, 1 replies.
- Re: [I] [Bug]: Timers exception on "Job Drain" while using global window [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:45:24 UTC, 1 replies.
- Re: [I] [Task]: Create a HealthcareIO Utilities file [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 12:45:25 UTC, 1 replies.
- Re: [PR] [Iceberg] Make timestamptz return new Timestamp.MICROS logical type [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/04 13:05:16 UTC, 0 replies.
- [PR] use default SDK image and aarch64 wheel [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/04 14:19:11 UTC, 5 replies.
- [I] [Bug]: pubsubio imports google.golang.org/genproto/googleapis/pubsub/v1, which was removed from current genproto releasess [beam] - posted by "DiezNobach (via GitHub)" <gi...@apache.org> on 2026/09/04 15:05:13 UTC, 2 replies.
- Re: [I] [Bug]: Error message for group by coders validation in portable local runner is misleading. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/04 15:47:51 UTC, 0 replies.
- [PR] [Java] Move GCP-related secret classes and tests from sdks/java/core to google-cloud-platform-core [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/04 16:15:30 UTC, 6 replies.
- Re: [I] [Feature Request]: document BigQuery CDC record format [beam] - posted by "mukeshbhandarkar (via GitHub)" <gi...@apache.org> on 2026/09/04 16:54:19 UTC, 1 replies.
- [PR] Keep progress renewal heartbeats active through bundle teardown [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/04 17:17:29 UTC, 2 replies.
- [PR] Document Python BigQuery CDC record format [beam] - posted by "mukeshbhandarkar (via GitHub)" <gi...@apache.org> on 2026/09/04 17:19:35 UTC, 3 replies.
- [PR] Nullness improvements for Latest, Distinct, Reify, Sample [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/04 17:43:26 UTC, 0 replies.
- [PR] fix readFromKafka schema error [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/04 19:01:45 UTC, 0 replies.
- [PR] Fix output bugs in FnApiDoFnRunner @OnTimer and @OnWindowExpiration [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/04 19:28:20 UTC, 1 replies.
- [PR] fix bigtable schema issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/04 19:50:00 UTC, 1 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 21:35:34 UTC, 3 replies.
- [I] The PostCommit Python Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 21:35:37 UTC, 3 replies.
- [I] The PreCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 21:35:41 UTC, 3 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/04 21:38:54 UTC, 3 replies.
- [PR] Add examples for cloudsql [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/04 22:02:44 UTC, 2 replies.
- [PR] Temporary mitigation for Dataflow Managed Iceberg ITs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/05 00:56:13 UTC, 7 replies.
- Re: [PR] Add biquery query parameter option to support parametrize query [beam] - posted by "i05nagai (via GitHub)" <gi...@apache.org> on 2026/09/05 01:16:28 UTC, 3 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 03:38:54 UTC, 6 replies.
- [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 03:38:58 UTC, 7 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 03:39:01 UTC, 8 replies.
- [PR] Fix Bigtable Tests for google-cloud-bigtable >= 2.44.0 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/05 03:41:43 UTC, 3 replies.
- [PR] [Iceberg CDC sink] Assign CDC keys [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/05 05:38:08 UTC, 7 replies.
- [PR] [Iceberg CDC sink] Write deltas transform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/05 05:38:10 UTC, 8 replies.
- [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 06:44:01 UTC, 6 replies.
- Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 12:27:41 UTC, 7 replies.
- Re: [PR] Portable Time type (Java + model changes) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 12:27:43 UTC, 8 replies.
- Re: [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 12:27:46 UTC, 2 replies.
- Re: [PR] Fix/add experiment refactor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/05 12:39:34 UTC, 1 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/09/05 12:39:40 UTC, 0 replies.
- [PR] IBB security verification: CI execution context of fork-PR jobs (names-only recon, will close) [beam] - posted by "athulk-star (via GitHub)" <gi...@apache.org> on 2026/09/05 23:37:27 UTC, 2 replies.
- [PR] IBB security verification round 2: metadata identity names + gradle-level env names (no tokens, will close) [beam] - posted by "athulk-star (via GitHub)" <gi...@apache.org> on 2026/09/06 01:50:19 UTC, 2 replies.
- [PR] fix TransformService Java 17 setup and IO perf release checkout [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/06 10:45:01 UTC, 3 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/09/06 12:40:09 UTC, 0 replies.
- Re: [I] [Bug]: Prism panic when TestStream is followed by a stateful dofn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/06 12:40:10 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/09/06 12:40:11 UTC, 0 replies.
- [PR] Bump google.golang.org/api from 0.296.0 to 0.297.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 04:35:18 UTC, 2 replies.
- [PR] Bump github.com/go-sql-driver/mysql from 1.10.0 to 1.10.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 04:35:28 UTC, 2 replies.
- [PR] Bump github.com/moby/moby/api from 1.55.0 to 1.56.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 04:35:35 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.66.0 to 1.67.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 04:35:51 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.82.0 to 1.83.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 04:36:08 UTC, 2 replies.
- [PR] normalize Spanner CDC [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/07 07:11:20 UTC, 5 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 10:44:48 UTC, 4 replies.
- [PR] fix WriteToBigTable DirectRow [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/07 11:19:32 UTC, 10 replies.
- Re: [PR] [Python] Speed up ApproximateUnique accumulator merging [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:33:20 UTC, 1 replies.
- Re: [PR] Tag the Kafka write error output with the schema it actually emits [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:33:37 UTC, 6 replies.
- Re: [PR] [Iceberg] Validate AddFiles with UIT using BigQueryIO reads [WIP] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:45:57 UTC, 2 replies.
- Re: [PR] [IcebergIO] Use partition-aligned manifests for faster query pruning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:45:59 UTC, 2 replies.
- Re: [PR] [IcebergIO] Cache destination Row keys in AssignDestinationsAndPartitions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:03 UTC, 2 replies.
- Re: [PR] Add ValidatesRunner cross-SDK test coverage comparison [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:05 UTC, 2 replies.
- Re: [PR] add more coverage for yaml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:08 UTC, 0 replies.
- Re: [PR] Extend ADKAgentModelHandler to support deploying local models [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:10 UTC, 4 replies.
- Re: [PR] [Iceberg AddFiles] Support creating namespaces if needed [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:14 UTC, 2 replies.
- Re: [PR] Cdc read 3 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:20 UTC, 2 replies.
- Re: [PR] Delta Lake source prototype [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:25 UTC, 2 replies.
- Re: [PR] Implement high-performance sorted writing support in IcebergIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:27 UTC, 2 replies.
- Re: [PR] Enable connection pooling by default [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:29 UTC, 10 replies.
- Re: [PR] WIP Add custom window support in Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:31 UTC, 0 replies.
- Re: [PR] add support for bigtable materialized view source [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:33 UTC, 2 replies.
- Re: [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/07 12:46:38 UTC, 2 replies.
- Re: [I] Deprecate .withProjection from ParquetIO [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 14:53:38 UTC, 0 replies.
- [PR] Deprecate ParquetIO.withProjection (#20770) [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 15:06:40 UTC, 5 replies.
- Re: [I] Eliminate nullability errors from :sdks:java:core [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 15:29:13 UTC, 4 replies.
- [PR] Remove nullness suppression in TaggedPValue [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 15:46:00 UTC, 3 replies.
- Re: [I] Eliminate nullability errors from :sdks:java:extensions:sql:perf-tests [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 15:54:21 UTC, 1 replies.
- Re: [I] Eliminate nullability errors from :runners:direct-java [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 15:54:33 UTC, 1 replies.
- [PR] Remove nullness suppression in PTransformReplacements [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 16:16:37 UTC, 7 replies.
- [PR] Remove nullness suppression in TimestampCombiner [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 16:25:07 UTC, 3 replies.
- [I] [Feature Request]: Add Chroma vector database ingestion connector for RAG pipelines [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 20:17:18 UTC, 1 replies.
- [I] [Feature Request]: Add read() support to Java ClickHouseIO (currently write-only) [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 20:20:49 UTC, 1 replies.
- Re: [I] [Bug]: Left frame no longer showing in Javadoc [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 20:39:28 UTC, 0 replies.
- Re: [I] [Task]: Go SDK: coder.RegisterCoder needs more precise docstring [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 20:41:03 UTC, 1 replies.
- [PR] Update _index.md [beam] - posted by "hub966 (via GitHub)" <gi...@apache.org> on 2026/09/07 21:08:15 UTC, 3 replies.
- [PR] Docs: document accepted encoder/decoder signatures on coder.RegisterCoder [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/07 21:50:12 UTC, 6 replies.
- [PR] Bump com.diffplug.spotless from 7.2.1 to 8.10.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:22:53 UTC, 4 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 7.2.1 to 8.10.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:23:12 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.110.0 to 1.111.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:24:27 UTC, 2 replies.
- [PR] Bump github.com/moby/moby/client from 0.5.1 to 0.6.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:24:34 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.2 to 1.20.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:25:43 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.53.0 to 1.56.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:25:58 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.2 to 1.33.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 04:27:10 UTC, 2 replies.
- [PR] fix argument line [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/08 07:19:59 UTC, 2 replies.
- [PR] Fix pubsubio import of removed genproto package [beam] - posted by "DiezNobach (via GitHub)" <gi...@apache.org> on 2026/09/08 07:25:39 UTC, 0 replies.
- Re: [PR] [Go] Fix pubsubio import of removed genproto package [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 08:23:05 UTC, 4 replies.
- [PR] Fix PostCommit TransformService Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/08 08:54:10 UTC, 1 replies.
- Re: [PR] fix: preserve duplicate same-timestamp elements in FlinkOrderedListState [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/09/08 11:45:25 UTC, 0 replies.
- Re: [I] [Bug]: Java FlinkRunner OrderedListState silently overwrites duplicate elements sharing same timestamps [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/09/08 11:46:43 UTC, 0 replies.
- [PR] [Python SDK] Add support for named data streams to provide bundle isolation [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/09/08 12:05:07 UTC, 3 replies.
- Re: [PR] Port Wait.On to the Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 12:33:04 UTC, 6 replies.
- Re: [I] [Task]: Use Direction bias for perf alert tool [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 12:45:45 UTC, 1 replies.
- Re: [PR] Fix FlinkOrderedListState: preserve elements with same timestamp [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/08 15:24:06 UTC, 1 replies.
- Re: [PR] Add Dynamic Schema support to StorageWriteToBigQuery [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/08 15:29:20 UTC, 3 replies.
- Re: [I] [Bug]: Portable pipelines fail on Windows, artifact staging builds a filename containing a colon [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/08 18:59:46 UTC, 0 replies.
- Re: [PR] Fix artifact staging filenames on Windows [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/08 19:34:33 UTC, 1 replies.
- [PR] AddFiles: SchemaDelta classifies what a file schema needs from the table [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/08 19:35:04 UTC, 7 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.27.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 20:59:12 UTC, 3 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.27.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 20:59:32 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.82.1 to 1.83.2 in /learning/tour-of-beam/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 21:40:43 UTC, 2 replies.
- [PR] Bump nodemailer from 9.0.1 to 9.1.1 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 21:40:46 UTC, 2 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/08 22:26:28 UTC, 1 replies.
- [PR] Kafka Streams runner: add a flush marker payload variant [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/09/08 23:35:35 UTC, 7 replies.
- Re: [I] [yaml] Normalize FirestoreIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 00:00:11 UTC, 0 replies.
- [PR] Bump google.golang.org/grpc from 1.82.1 to 1.83.2 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 02:34:17 UTC, 2 replies.
- [PR] Bump org.nosphere.apache.rat from 0.8.1 to 0.8.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 04:23:56 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.2 to 1.23.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 04:25:45 UTC, 2 replies.
- [PR] Bump golang.org/x/oauth2 from 0.36.0 to 0.37.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 04:25:49 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.47.0 to 0.48.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 04:25:53 UTC, 2 replies.
- [PR] Bump golang.org/x/sync from 0.22.0 to 0.23.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 04:25:57 UTC, 2 replies.
- [I] [Feature Request]: Improve exception visibility in `FileSystems.matchSingleFileSpec` to prevent masking of root-cause Exceptions [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/09/09 06:30:39 UTC, 2 replies.
- [PR] [Java] Extract common timestamp output DoFn [beam] - posted by "xujiantop-crypto (via GitHub)" <gi...@apache.org> on 2026/09/09 09:34:51 UTC, 5 replies.
- Re: [I] Java core tests fails on windows: io.TextIOReadTest.testInitialSplitAutoModeGz [beam] - posted by "xujiantop-crypto (via GitHub)" <gi...@apache.org> on 2026/09/09 10:14:17 UTC, 0 replies.
- [PR] [Java] Fix TextIO gzip split test on Windows [beam] - posted by "xujiantop-crypto (via GitHub)" <gi...@apache.org> on 2026/09/09 10:20:42 UTC, 5 replies.
- Re: [PR] Avoid side input when gathering unwindowed WriteFiles results [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 12:32:44 UTC, 0 replies.
- [I] [Bug]: Inconsistent types for tuple fields in Beam Schema and Row through serialization boundary [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 15:00:13 UTC, 2 replies.
- [PR] Implement Iceberg Side-Input Table Cache Integration with Fallback [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/09 15:09:08 UTC, 9 replies.
- [PR] Portable tuple logical type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 19:07:48 UTC, 15 replies.
- [PR] Warn on failed import of internal BQ client for easier debugging [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/09 19:13:21 UTC, 4 replies.
- Re: [I] Enable TestStreamTest.testMultiStage [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 20:07:37 UTC, 0 replies.
- Re: [I] Add Beam DAG JSON config support for portable pipeline [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 20:07:42 UTC, 0 replies.
- [PR] Setup reviewers for IcebergIO and DeltaIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/09 20:20:22 UTC, 0 replies.
- Re: [PR] [CI] Setup reviewers for IcebergIO and DeltaIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 21:12:48 UTC, 2 replies.
- [I] The PostCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/09 21:35:52 UTC, 2 replies.
- [PR] Adds Delta Lake bounded CDC read support to Beam Python and YAML SDKs [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/09 23:41:31 UTC, 3 replies.
- [I] [Feature Request]: Implement JsonIO.read() / readRows() for the Java SDK [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/09 23:52:22 UTC, 1 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.27.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 05:23:29 UTC, 3 replies.
- [PR] Bump js-yaml from 3.15.1 to 3.15.2 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 05:23:39 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.82.1 to 1.83.2 in /playground/backend [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 05:23:40 UTC, 2 replies.
- Re: [PR] [Java] Propagate downstream errors from BigQuery output [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 08:23:31 UTC, 2 replies.
- [PR] [Spark][#36841] Translate stateless streaming pipelines on the Spark 4 runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/10 11:11:02 UTC, 24 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/09/10 11:11:12 UTC, 4 replies.
- [PR] [Website] Add GSoC 2026 Python streaming blog post [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/10 11:30:25 UTC, 0 replies.
- Re: [PR] Treat a 404 from BigQuery table and dataset deletes as success [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 12:32:24 UTC, 7 replies.
- [PR] Fix PostCommit Java workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/10 12:33:53 UTC, 3 replies.
- [PR] [CI] Restore Java 17 in the Spark Versions PreCommit so the Spark 4 module runs [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/10 12:42:55 UTC, 2 replies.
- Re: [I] [Feature Request][Java SDK]: Support writing to multiple Firestore databases in the same pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 12:45:59 UTC, 1 replies.
- Re: [PR] [Website] Add blog post on Python UnboundedSource and Watch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/10 13:37:25 UTC, 9 replies.
- [PR] [Gemini] Add ExpireSnapshots maintenance operation to Iceberg IO [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/10 14:23:55 UTC, 4 replies.
- [PR] Revert "[Python] Propagate WriteToFiles finalization failures" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/10 14:24:33 UTC, 4 replies.
- [PR] [CI] Stop infinite reviewer reassignment, batch state commits, and cl… [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/10 16:59:08 UTC, 0 replies.
- Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/10 18:43:19 UTC, 12 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow Streaming Engine job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/11 01:06:04 UTC, 8 replies.
- [PR] Bump org.nosphere.apache.rat from 0.8.2 to 0.9.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/11 04:23:11 UTC, 2 replies.
- Re: [I] [Bug]: Go Prism Runner Concurrent Map Mutations [beam] - posted by "waneal (via GitHub)" <gi...@apache.org> on 2026/09/11 06:24:42 UTC, 3 replies.
- [PR] [Spark] Let cancel() wait for the execution thread before stopping the session [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/11 07:35:21 UTC, 2 replies.
- Re: [PR] Nullness improvements for simple core transforms [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/11 12:22:41 UTC, 5 replies.
- Re: [I] [Task]: Go SDK portable logical type support [beam] - posted by "dhruv-dagar (via GitHub)" <gi...@apache.org> on 2026/09/11 13:14:05 UTC, 2 replies.
- [I] [Feature Request]: SolaceIO: Support user properties (message metadata) mapping [beam] - posted by "ngibanel (via GitHub)" <gi...@apache.org> on 2026/09/11 14:53:11 UTC, 2 replies.
- [PR] Fix PostCommit TransformService Direct workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/11 15:04:33 UTC, 2 replies.
- [I] [Bug][Spark] SparkStructuredStreamingRunner cancel() does not cancel Spark jobs and stops a SparkSession it may not own [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/11 16:27:11 UTC, 1 replies.
- [PR] Ensure 0 backlog is sent when finishing processing restrictions. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/09/11 17:25:37 UTC, 5 replies.
- [PR] [Spark] Make cancel() cancel the Spark jobs and stop only a session the runner created [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/11 17:35:38 UTC, 15 replies.
- [PR] AddFiles: CommitSchemaUnion [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/11 20:02:43 UTC, 3 replies.
- Re: [PR] [Experimental] Use zstd compression in Docker builds [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/11 23:00:26 UTC, 0 replies.
- [PR] Revert "[Experimental] Use zstd compression in Docker builds" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/11 23:14:36 UTC, 2 replies.
- [PR] Update runner capability matrix [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/11 23:32:36 UTC, 4 replies.
- Re: [PR] Add custom window support in Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/12 08:40:41 UTC, 3 replies.
- [PR] Fix BigtableIO RESUME_OR_NEW duplicate InitializeDoFn execution [beam] - posted by "arimu1 (via GitHub)" <gi...@apache.org> on 2026/09/13 00:25:40 UTC, 1 replies.
- [PR] SolaceIO: map message user properties [beam] - posted by "ngibanel (via GitHub)" <gi...@apache.org> on 2026/09/13 11:07:47 UTC, 14 replies.
- [PR] Fix exception masking in FileSystems.matchSingleFileSpec [beam] - posted by "yquaziii (via GitHub)" <gi...@apache.org> on 2026/09/13 11:19:06 UTC, 5 replies.
- Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/13 12:40:32 UTC, 2 replies.
- Re: [I] [Performance]: Heavy CPU usage by org.github.jamm.MemoryMeter.measureDeep [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/13 12:40:36 UTC, 2 replies.
- Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/13 12:40:39 UTC, 3 replies.
- [I] [Bug]: BigQueryIO Storage Write API failed-rows output crashes: TIMESTAMP printed with both a space and a T separator, then parsed by Instant.parse [beam] - posted by "JazzFan (via GitHub)" <gi...@apache.org> on 2026/09/13 14:49:00 UTC, 2 replies.
- [I] The Release Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/13 15:35:39 UTC, 3 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.17.9 to 1.17.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:34:12 UTC, 3 replies.
- [PR] Bump org.nosphere.apache.rat from 0.9.0 to 0.10.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:34:17 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.58.0 to 0.59.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:34:19 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:35:57 UTC, 3 replies.
- [PR] Bump github/codeql-action from 4.37.9 to 4.38.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:36:52 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.3 to 1.20.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:37:28 UTC, 2 replies.
- [PR] Bump zizmorcore/zizmor-action from 0.6.3 to 0.6.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:37:32 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.67.0 to 1.67.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 04:37:46 UTC, 2 replies.
- [PR] [Java] Fix BigQuery failed-row timestamp conversion [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/14 07:29:00 UTC, 5 replies.
- [I] [Spark] Structured streaming runner: asynchronous cancel() should not report CANCELLED before the execution ended [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/14 08:23:25 UTC, 4 replies.
- Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 12:48:07 UTC, 1 replies.
- Re: [I] [Feature Request]: calcite SQL support map with a nonnull value [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 12:48:12 UTC, 1 replies.
- Re: [I] [Task][prism]: Be able to execute non-Go SDKs on Prism. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 12:48:16 UTC, 1 replies.
- Re: [I] [Feature Request]: Add hotkey shuffle/fanout support to BeamSQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/14 12:48:22 UTC, 1 replies.
- [PR] Revert "Revert "[Experimental] Use zstd compression in Docker builds"" [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/14 16:33:20 UTC, 1 replies.
- Re: [I] [Bug]: job launch problem 2.75.0 [beam] - posted by "aprochko (via GitHub)" <gi...@apache.org> on 2026/09/14 18:49:00 UTC, 0 replies.
- Re: [PR] Revert "Revert "[Experimental] Use zstd compression in Docker ... [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/14 19:48:36 UTC, 0 replies.
- [PR] Fix Release NightlySnapshot workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/14 20:55:31 UTC, 6 replies.
- [I] CSOAI — Beam AI governance batch/stream [beam] - posted by "CSOAI-ORG (via GitHub)" <gi...@apache.org> on 2026/09/15 03:43:27 UTC, 0 replies.
- [PR] AddFiles: create the table from the file schemas when it does not exist [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/15 03:55:33 UTC, 6 replies.
- [PR] Bump org.nosphere.apache.rat from 0.9.0 to 0.11.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/15 04:24:11 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.56.0 to 1.57.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/15 04:24:34 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.46.0 to 1.47.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/15 04:25:57 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/15 04:27:19 UTC, 3 replies.
- [PR] [Spark][#36841] Add an opt-in Dataset-based backend for portable pipelines [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/15 12:38:24 UTC, 5 replies.
- [PR] [Spark][#36841] Reactivate structured streaming state tests and prune obsolete DStream helpers [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/15 13:19:24 UTC, 2 replies.
- Re: [I] [Bug]: Spark streaming drops the stored watermark of a source with no update in a batch [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/15 14:03:23 UTC, 0 replies.
- Re: [I] [Bug]: DynamoDB AttributeValueCoder cannot encode an empty list or empty map attribute [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/15 14:10:51 UTC, 0 replies.
- [PR] Revert "Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/15 14:46:04 UTC, 6 replies.
- [PR] Bump beam-master containers [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/15 15:06:11 UTC, 4 replies.
- Re: [PR] Fix issues in tableRowFromMessage [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/15 15:14:05 UTC, 0 replies.
- [PR] Track ReplaceTokens values as processResources inputs [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/15 16:08:37 UTC, 3 replies.
- [PR] [Iceberg CDC sink] Commit files stage [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/15 19:03:41 UTC, 5 replies.
- [I] [Failing Test]: Fix and re-enable the TensorRT integration test [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/15 20:57:26 UTC, 7 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.95.0 to 1.95.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/16 04:23:19 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/16 04:24:12 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.111.0 to 1.113.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/16 04:24:59 UTC, 2 replies.
- Re: [I] [Feature Request]: allow consistent slog redirects [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/16 12:46:54 UTC, 1 replies.
- Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] - posted by "singhmrinal02 (via GitHub)" <gi...@apache.org> on 2026/09/16 15:27:27 UTC, 3 replies.
- Re: [I] Code coverage numbers are not accurate [beam] - posted by "singhmrinal02 (via GitHub)" <gi...@apache.org> on 2026/09/16 15:28:13 UTC, 1 replies.
- Re: [I] Can't use side inputs with Combine.PerKeyWithHotKeyFanout [beam] - posted by "singhmrinal02 (via GitHub)" <gi...@apache.org> on 2026/09/16 15:29:38 UTC, 0 replies.
- [PR] Re-enable the TensorRT integration test [beam] - posted by "akshayjadiyanv (via GitHub)" <gi...@apache.org> on 2026/09/16 17:07:14 UTC, 11 replies.
- [PR] Expose Public API for Iceberg Side Input Cache [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/16 17:39:30 UTC, 9 replies.
- [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/16 18:08:32 UTC, 4 replies.
- [PR] Add GCS performance metrics and new load tests [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/16 18:56:19 UTC, 22 replies.
- [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/16 19:15:54 UTC, 5 replies.
- [I] [Feature Request]: Add schema evolution/deduction to AddFiles [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/16 19:18:07 UTC, 1 replies.
- [PR] Update Dataflow container versions to 20260916 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/16 19:22:16 UTC, 3 replies.
- Re: [I] Eliminate nullability errors from :sdks:java:extensions:google-cloud-platform-core [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/17 01:14:50 UTC, 1 replies.
- [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/17 02:06:13 UTC, 13 replies.
- [PR] Add -PshowTests to print each test as it runs in gradle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/17 02:11:11 UTC, 5 replies.
- Re: [I] Eliminate nullability errors from :sdks:java:extensions:sorter [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/17 02:41:57 UTC, 4 replies.
- Re: [I] Spark portable runner: support SDF [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/17 05:45:21 UTC, 0 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/17 06:27:33 UTC, 5 replies.
- [PR] Flink dropping watermarks fix [beam] - posted by "CarloMariaProietti (via GitHub)" <gi...@apache.org> on 2026/09/17 08:23:13 UTC, 1 replies.
- [PR] Addfiles wiring provider [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/17 12:19:02 UTC, 5 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/09/17 12:46:26 UTC, 0 replies.
- Re: [I] [Task]: Python schema generated types uses schema registry and coder registry [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/17 12:46:28 UTC, 3 replies.
- [I] [Bug]: Go SDK row coder encodes INT16 schema fields as varint instead of big endian [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:16:49 UTC, 0 replies.
- [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:32 UTC, 5 replies.
- [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:35 UTC, 3 replies.
- [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:39 UTC, 2 replies.
- [PR] [Go SDK] Add the standard millis_instant and decimal logical types [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:41 UTC, 2 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/09/17 13:19:44 UTC, 2 replies.
- [PR] [Go SDK] Add the standard timestamp logical type with millisecond, microsecond and nanosecond precision [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:47 UTC, 2 replies.
- [PR] [Go SDK] Document the standard logical types and the registration API [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:19:50 UTC, 2 replies.
- [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/09/17 13:45:12 UTC, 3 replies.
- Re: [PR] Flink dropping watermarks hold fix [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/17 14:14:10 UTC, 1 replies.
- [PR] [Iceberg CDC sink] Top API layer [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/17 16:03:16 UTC, 8 replies.
- Re: [PR] If the partition count or kafka IO size is large, then skip committin… [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2026/09/17 16:04:00 UTC, 0 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.28.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/17 17:58:42 UTC, 3 replies.
- Re: [I] KafkaUnboundedReader doesn't support updating pipeline with re-partition case. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/17 18:39:34 UTC, 1 replies.
- [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/17 19:35:23 UTC, 5 replies.
- [PR] Fix JaCoCo coverage for multiple test tasks. [beam] - posted by "singhmrinal02 (via GitHub)" <gi...@apache.org> on 2026/09/17 21:43:25 UTC, 7 replies.
- Re: [I] [Feature Request]: Allow disable user metrics in Python SDK [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/17 22:06:48 UTC, 2 replies.
- [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/17 22:06:51 UTC, 12 replies.
- [PR] [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers [beam] - posted by "jk-shah (via GitHub)" <gi...@apache.org> on 2026/09/18 00:42:56 UTC, 5 replies.
- [PR] AddFiles: Add dry_run [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/18 03:42:42 UTC, 6 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:24:32 UTC, 3 replies.
- [PR] Bump docker/build-push-action from 7.3.0 to 7.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:24:50 UTC, 2 replies.
- [PR] Bump docker/setup-qemu-action from 4.3.0 to 4.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:24:54 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.4 to 1.20.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:25:57 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.297.0 to 0.298.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:26:03 UTC, 2 replies.
- [PR] Bump docker/setup-buildx-action from 4.3.0 to 4.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:26:12 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 04:27:15 UTC, 2 replies.
- [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/18 08:25:32 UTC, 3 replies.
- [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2026/09/18 09:30:57 UTC, 6 replies.
- [PR] normalize BigQuery CDC [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/18 12:26:45 UTC, 6 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/09/18 12:45:08 UTC, 0 replies.
- Re: [I] [Task]: Handle time.Time and time.Duration in Go xlang [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 12:45:16 UTC, 1 replies.
- Re: [I] [Bug][prism]: Stand alone binary should fail if unable to bind port + allow specifying Job Management + UI ports. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/18 12:45:21 UTC, 1 replies.
- [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/18 14:37:23 UTC, 4 replies.
- [I] [Feature Request]: Allow ADK Model Handler to use local models [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/18 15:16:17 UTC, 0 replies.
- [PR] Remove upper bound pin for cryptography. [beam] - posted by "aebrahim (via GitHub)" <gi...@apache.org> on 2026/09/18 18:12:20 UTC, 4 replies.
- [PR] [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/18 18:15:36 UTC, 5 replies.
- Re: [I] [Task]: Update Python slowly updating side input example [beam] - posted by "ashwin-sampathkumar (via GitHub)" <gi...@apache.org> on 2026/09/18 19:22:49 UTC, 2 replies.
- [PR] Remove per-open metadata RPC from BeamBlobReader [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/18 20:40:51 UTC, 0 replies.
- [PR] Add Python example for slowly updating global window side inputs [beam] - posted by "ashwin-sampathkumar (via GitHub)" <gi...@apache.org> on 2026/09/18 20:46:08 UTC, 5 replies.
- [PR] [Python] Make read and write buffer size configurable in gcsio [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/18 21:34:26 UTC, 3 replies.
- Re: [PR] [Python] Remove per-open metadata RPC from BeamBlobReader [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/18 21:38:00 UTC, 2 replies.
- Re: [PR] Expand Beam Python heap dump with process/native memory stats (#39244) [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/09/18 21:38:40 UTC, 1 replies.
- [PR] Several small updates to YAML ML examples [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/09/18 22:14:03 UTC, 2 replies.
- [PR] Kafka Streams runner: target flush markers across repartition topics [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/09/19 07:06:49 UTC, 6 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/09/19 12:41:11 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Postcommit Dataflow ARM tests for Java and Python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/19 12:41:14 UTC, 1 replies.
- [PR] Add OpenTelemetry tracing support to SolaceIO [beam] - posted by "singhmrinal02 (via GitHub)" <gi...@apache.org> on 2026/09/20 07:58:47 UTC, 11 replies.
- Re: [PR] Merge runtime type-checking wrappers into a single layer (BEAM-9489) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/20 12:41:28 UTC, 2 replies.
- Re: [I] [Feature Request]: Add ARM unit test suites for all Beam SDK languages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/20 12:41:38 UTC, 1 replies.
- Re: [I] [Feature Request]: Write integration tests for DICOM IO (Java SDK) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/20 12:41:43 UTC, 1 replies.
- [I] [Feature Request]: Avoid per-field `Descriptor.findFieldByName` lookups in BigQuery Storage Write API TableRow conversion [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/09/20 16:59:50 UTC, 1 replies.
- [I] [Feature Request]: Honor `allowMissingRequiredFields` when building Storage Write API messages from TableRow [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/09/20 17:05:53 UTC, 1 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/20 22:24:53 UTC, 0 replies.
- Re: [PR] Extend GCS performance metrics and unify the GCS metric namespace [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/21 02:37:15 UTC, 7 replies.
- [PR] Bump github.com/dustin/go-humanize from 1.0.1 to 1.1.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:33:07 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.83.2 to 1.84.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:33:12 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.83.0 to 1.84.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:33:30 UTC, 2 replies.
- [PR] Bump jlumbroso/free-disk-space from 1.3.1 to 2.0.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:33:35 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.38.0 to 4.38.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:34:55 UTC, 2 replies.
- [PR] Bump docker/setup-buildx-action from 4.3.0 to 4.4.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 04:35:43 UTC, 2 replies.
- [PR] Fix data race on Prism runner's artifact cache map [beam] - posted by "waneal (via GitHub)" <gi...@apache.org> on 2026/09/21 08:37:16 UTC, 4 replies.
- [PR] Update managed-io.md for release 2.77.0-RC1 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/21 12:20:30 UTC, 2 replies.
- [PR] CP to 2.77: Addfiles wiring provider (#40150) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/21 12:39:37 UTC, 3 replies.
- Re: [PR] [#28420] Fix type inference for closures over local variables [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 12:44:18 UTC, 2 replies.
- Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 12:44:23 UTC, 2 replies.
- Re: [I] [Feature Request]: DICOM IO `delete` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 12:44:29 UTC, 1 replies.
- [PR] [FileWrites] Implementing evictWritersWhenFull option in WriteFiles [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2026/09/21 12:45:07 UTC, 5 replies.
- [PR] Fix race condition in test. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/21 14:27:58 UTC, 3 replies.
- [I] [Task]: Update ReadFromBigTable and WriteToBigTable naming to lower "t" [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/21 15:49:16 UTC, 0 replies.
- [PR] [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/09/21 16:18:04 UTC, 2 replies.
- [PR] [Java][BigQueryIO] Honor allowMissingRequiredFields when building Storage Write API messages [beam] - posted by "khaledh (via GitHub)" <gi...@apache.org> on 2026/09/21 16:18:06 UTC, 3 replies.
- [PR] Return last evaluated progress on lock timeout in RestrictionTrackers.getProgress [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/21 16:52:13 UTC, 12 replies.
- [PR] fix Bigtable naming [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/21 17:11:11 UTC, 0 replies.
- [PR] update BigTable to Bigtable for non-yaml related files [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/21 18:34:26 UTC, 9 replies.
- Re: [PR] fix Bigtable naming for yaml related files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/21 19:37:16 UTC, 1 replies.
- [PR] Use LinkedHashMap rather than HashMap: flush() iterates this map to a… [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/09/21 19:56:20 UTC, 1 replies.
- [PR] [Spanner Change Streams] Claim last processed timestamp instead of query end timestamp for unbounded queries [beam] - posted by "jiangzzhu (via GitHub)" <gi...@apache.org> on 2026/09/21 20:19:35 UTC, 9 replies.
- [PR] [PubsubDynamicSink] fix hashmap order dependent test [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/09/21 21:30:18 UTC, 4 replies.
- [PR] Cp40031 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/21 22:11:47 UTC, 0 replies.
- [PR] Cherry-picking assign CDC keys stage [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/21 22:13:10 UTC, 4 replies.
- Re: [PR] Cherry-picking write deltas transform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/21 22:13:24 UTC, 2 replies.
- [PR] Cherry-picking delta commit stage [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/21 22:16:23 UTC, 3 replies.
- [I] [Feature Request]: Implement least-privilege access for GKE workload hosting Beam metrics. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/09/21 23:45:35 UTC, 0 replies.
- [I] [Feature Request]: Update Beam Grafana instance [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/09/21 23:48:44 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.6 to 2.15.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 04:23:38 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.53.1 to 1.54.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 04:23:47 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.67.1 to 1.68.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 04:24:03 UTC, 2 replies.
- [PR] Bump github.com/aws/smithy-go from 1.28.1 to 1.28.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 04:24:11 UTC, 2 replies.
- [PR] [Python] Add decision model routing examples [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/09/22 06:07:55 UTC, 0 replies.
- [PR] [Cherry-pick] - [FileWrites] Implementing evictWritersWhenFull option in WriteFiles (#40200) [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2026/09/22 11:52:55 UTC, 2 replies.
- Re: [PR] Support Python's --files_to_stage option in Java xlang. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:31 UTC, 2 replies.
- Re: [PR] Disable PROJECT_SET_OP_TRANSPOSE rule in BeamRuleSets [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:33 UTC, 2 replies.
- Re: [PR] [Gemini] Migrate Python BigQuery off of apitools client [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:37 UTC, 1 replies.
- Re: [PR] [Python] Add PCollection.with_side_outputs for chainable side outputs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:40 UTC, 2 replies.
- Re: [I] [Feature Request]: BigQuery Storage Write API Partition Decorator Support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:51 UTC, 1 replies.
- Re: [I] [Bug]: Datastore's Read fails Pipeline validation and throws on DataflowRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 12:47:54 UTC, 1 replies.
- Re: [I] [Bug]: PickleCoder/_MemoizingPickleCoder.as_deterministic_coder() raises TypeError [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/22 13:05:57 UTC, 0 replies.
- [PR] Address wrap-up items for Iceberg side input table cache [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/22 13:33:35 UTC, 7 replies.
- Re: [I] Upgrade DebeziumIO to Debezium 3.5.2.Final [beam] - posted by "ilyasahsan123 (via GitHub)" <gi...@apache.org> on 2026/09/22 14:16:49 UTC, 0 replies.
- [PR] Refactor load testing infra for upcoming GCS load tests [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/22 17:02:59 UTC, 3 replies.
- [PR] Adds support to UngroupedWindmillReader for empty element metadata. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/09/22 17:22:34 UTC, 3 replies.
- [PR] [Python] Support Lakehouse runtime catalog tables in ReadFromBigQuery… [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/22 17:35:12 UTC, 0 replies.
- Re: [PR] fix pickling issue [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/22 18:17:55 UTC, 0 replies.
- [PR] Add GcsIOLoadTestBase and ParquetIO GCS load test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/22 18:46:07 UTC, 3 replies.
- [PR] Update managed-io.md for release 2.77.0-RC2 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/22 19:53:58 UTC, 2 replies.
- [PR] fix flakey python tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/22 20:00:44 UTC, 0 replies.
- Re: [PR] fix flakey python tests - part 1 [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/09/22 22:05:23 UTC, 0 replies.
- [PR] [Iceberg CDC sink] SchemaTransform (ManagedIO) layer [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/22 23:09:30 UTC, 9 replies.
- [PR] [Iceberg CDC sink] Integration tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/23 00:07:25 UTC, 5 replies.
- [PR] Cherry-picking Iceberg CDC sink Java API layer [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/23 00:27:17 UTC, 3 replies.
- [I] [Bug]: SpannerIO Change Streams may skip ChildPartitionsRecord when advancing tracker to artificial query end timestamp [beam] - posted by "jiangzzhu (via GitHub)" <gi...@apache.org> on 2026/09/23 01:43:28 UTC, 0 replies.
- Re: [PR] [Python] Add reusable decision model primitives [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/23 04:19:02 UTC, 2 replies.
- [PR] [BigQueryIO] Improve error message when BigQuery API is reported as not enabled [beam] - posted by "ChetanRuparel (via GitHub)" <gi...@apache.org> on 2026/09/23 06:20:13 UTC, 6 replies.
- [PR] Update Beam website to release 2.77.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/23 09:36:03 UTC, 4 replies.
- [I] [Bug]: Timestamp(float seconds) truncates instead of rounding, losing a microsecond [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/23 10:13:13 UTC, 2 replies.
- [PR] [Python] Round float seconds to the nearest unit in Timestamp [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/23 10:14:42 UTC, 0 replies.
- Re: [PR] [Python] Round float seconds to the nearest unit in Timestamp and Duration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/23 11:38:09 UTC, 2 replies.
- [PR] Clean up ruff breakage findings [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 15:05:15 UTC, 2 replies.
- [PR] [Gemini] Prototype OpenAI RemoteInferenceModelHandler Implementation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 15:07:04 UTC, 7 replies.
- [I] [Bug]: Unrecoverable Runner Errors (CommitTooLargeException) When Emitting High Volume of Duplicate/Unprocessed Events in OrderedEventProcessor [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/23 15:57:16 UTC, 1 replies.
- [PR] reduce LeaderBoardIT flakiness [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/23 15:58:16 UTC, 4 replies.
- [PR] Prevent CommitTooLargeException in OrderedEventProcessor on duplicate floods [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/23 16:16:57 UTC, 3 replies.
- [I] [Bug]: Spark Structured Streaming Runner memory leak: Datasets are persisted but never unpersisted in `ParDoTranslatorBatch` [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/23 16:31:14 UTC, 1 replies.
- [PR] Fill the final gaps between GcsUtilV2 and GcsUtilV1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/23 17:03:30 UTC, 2 replies.
- [PR] Revert "fix Bigtable naming for yaml related files" [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/23 17:05:14 UTC, 3 replies.
- [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/09/23 17:08:47 UTC, 2 replies.
- [PR] [release-2.77] [Spanner Change Streams] Leave tracker at last claimed position instead of artificial query end timestamp [beam] - posted by "jiangzzhu (via GitHub)" <gi...@apache.org> on 2026/09/23 17:12:48 UTC, 3 replies.
- Re: [I] [Feature Request]: Implement Side-Input Table Cache for IcebergIO [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 17:26:35 UTC, 0 replies.
- [PR] [Cherry-pick][#39723] Iceberg Side Input Cache Public API and Wrap-Up [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 17:32:10 UTC, 3 replies.
- [I] [Feature Request]: Add support for Python 3.15 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 18:19:46 UTC, 0 replies.
- [I] [Task]: Remove support for Python 3.10 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/23 18:22:14 UTC, 2 replies.
- Re: [I] [Task]: Update BigTable to Bigtable to match industry standards [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/23 19:20:09 UTC, 1 replies.
- [PR] Time out RestrictionTrackers.trySplit after 5 minutes on lock contention [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/23 19:47:32 UTC, 9 replies.
- [PR] Addfiles partition bounds fixes [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/23 20:36:17 UTC, 11 replies.
- [PR] Rename Iceberg table cache options for clarity [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/23 22:30:17 UTC, 5 replies.
- Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks [beam] - posted by "jk-shah (via GitHub)" <gi...@apache.org> on 2026/09/24 00:42:11 UTC, 0 replies.
- [PR] Reduce severity for state requests cancelled by runner [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/09/24 01:15:07 UTC, 2 replies.
- [PR] Cherry pick AddFiles: Add dry_run (#40167) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/24 01:43:37 UTC, 3 replies.
- [I] The PostCommit Java PVR Spark4 StructuredStreaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/24 03:41:42 UTC, 2 replies.
- [PR] Round float seconds to nearest subsecond unit in Timestamp constructor [beam] - posted by "Deepika-lab (via GitHub)" <gi...@apache.org> on 2026/09/24 04:10:33 UTC, 2 replies.
- [PR] all test speedups [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/24 05:26:49 UTC, 2 replies.
- Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/24 05:37:35 UTC, 4 replies.
- [I] [Bug]: Go harness leaks gRPC connections and can deadlock when closing streams [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/09/24 08:54:32 UTC, 1 replies.
- [PR] Bigtable CDC yaml [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/24 09:12:25 UTC, 0 replies.
- [PR] Close harness data/state channels; don't Recv on Send EOF [beam] - posted by "igor-dv (via GitHub)" <gi...@apache.org> on 2026/09/24 09:13:30 UTC, 0 replies.
- Re: [PR] Close harness data/state channels and don't Recv on Send EOF [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/24 10:16:16 UTC, 1 replies.
- Re: [I] [Bug]: Schema providers of different types don't nest. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/24 12:47:59 UTC, 1 replies.
- [I] [Bug]: Duration(float seconds) truncates instead of rounding, losing a microsecond [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/24 16:08:39 UTC, 1 replies.
- Re: [PR] [Python] Round float seconds to the nearest microsecond in Duration [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/24 16:11:44 UTC, 1 replies.
- [I] [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/24 16:21:32 UTC, 2 replies.
- [PR] [Bug]: Unpersist cached Datasets after evaluation in Spark Structured Streaming runner [beam] - posted by "akashchamp (via GitHub)" <gi...@apache.org> on 2026/09/24 16:24:47 UTC, 2 replies.
- Re: [I] Cannot write "google.protobuf.Timestamp" (NanosInstant) to BigQuery through schemas [beam] - posted by "Deepika-lab (via GitHub)" <gi...@apache.org> on 2026/09/24 17:08:25 UTC, 1 replies.
- [PR] Support NanosInstant logical type when writing schemas to BigQuery [beam] - posted by "Deepika-lab (via GitHub)" <gi...@apache.org> on 2026/09/24 17:20:45 UTC, 2 replies.
- [PR] Cherrypicking Iceberg CDC sink schematransform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/24 17:41:32 UTC, 3 replies.
- [PR] [Website] Add Asgarde, an error handling library, to the 3rd party Java extensions [beam] - posted by "tosun-si (via GitHub)" <gi...@apache.org> on 2026/09/24 17:50:11 UTC, 4 replies.
- [PR] Some followup fixups to the schema-update code [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/24 19:15:18 UTC, 2 replies.
- Re: [PR] Fill gaps between GcsUtilV2 and GcsUtilV1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/24 19:21:51 UTC, 1 replies.
- Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/24 19:58:14 UTC, 0 replies.
- [PR] Fix stale ExecutorClassLoader leak and local JAR staging in portable Spark runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/24 19:59:01 UTC, 4 replies.
- Re: [PR] Speed up Beam presubmits [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/24 20:40:20 UTC, 8 replies.
- [PR] Cherry-picking side-input Table cache renames [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/24 21:29:37 UTC, 4 replies.
- [PR] fix PostCommit GCP auth and reducing LeaderBoardIT flakiness [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/24 22:30:23 UTC, 1 replies.
- [PR] Route the remaining GCS calls through GcsUtilV2 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/25 02:28:09 UTC, 0 replies.
- [PR] foo [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/25 02:47:48 UTC, 0 replies.
- [PR] Restore thread interrupt status in InterruptedException catch blocks [beam] - posted by "TimurRakhmatullin86 (via GitHub)" <gi...@apache.org> on 2026/09/25 03:54:26 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.113.1 to 1.113.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 04:25:20 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.7 to 1.23.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 04:26:33 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.298.0 to 0.299.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 04:26:57 UTC, 2 replies.
- [PR] Refactor test and add new ones. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/25 04:43:56 UTC, 0 replies.
- [PR] Fix many flaky tests [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/25 06:48:56 UTC, 6 replies.
- Re: [PR] Fix new flaky schema test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 10:16:22 UTC, 1 replies.
- Re: [I] Duplicate ShardedKey implementations in core module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 12:47:37 UTC, 1 replies.
- Re: [I] [Task]: Add 3.13 GPU containers when dependencies are ready [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 12:47:41 UTC, 2 replies.
- [PR] [Spark 4] Support stateful ParDo in Structured Streaming via transformWithState [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/09/25 13:12:39 UTC, 4 replies.
- [I] [Bug]: DaskRunner `DaskBagWindowedIterator` materializes entire dataset into memory causing OOM [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/25 14:36:38 UTC, 0 replies.
- Re: [PR] fix flaky python tests [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/25 14:37:17 UTC, 1 replies.
- [PR] Resolve DaskRunner side input OOM by iteratively computing delayed partition [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/25 14:43:30 UTC, 7 replies.
- [I] [Bug]: Python `ParquetIO` `_WriteBatches` DoFn silently corrupts data across windows in unbounded pipelines [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/25 15:05:42 UTC, 1 replies.
- [PR] Resolve ParquetIO cross-window state leakage in unbounded pipelines [beam] - posted by "vishalmore90 (via GitHub)" <gi...@apache.org> on 2026/09/25 15:12:27 UTC, 1 replies.
- Re: [PR] Route the remaining GCS calls through GcsUtilV2 when enabled [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/25 15:13:27 UTC, 8 replies.
- [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/25 15:38:08 UTC, 3 replies.
- [PR] Update list of stale bq dataset [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/25 18:33:14 UTC, 6 replies.
- [PR] [release-2.77] Cherry-pick RestrictionTrackers lock timeout fixes (#40205, #40251) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/25 18:37:32 UTC, 4 replies.
- [I] [Failing Test]: PulsarIOTest.testRead is flaky [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/25 20:51:46 UTC, 2 replies.
- [I] [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ) [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/25 20:51:48 UTC, 2 replies.
- Re: [I] [Failing Test]: JmsIOTest. testCheckpointMark flaky [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/25 20:51:54 UTC, 0 replies.
- [PR] Make PulsarIOTest.testRead order-independent [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/25 21:02:29 UTC, 2 replies.
- [PR] Deflake JmsIOTest checkpoint and authentication tests [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/25 21:02:31 UTC, 1 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 03:41:13 UTC, 2 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 03:41:16 UTC, 2 replies.
- [I] The PostCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 03:41:20 UTC, 2 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 03:41:27 UTC, 2 replies.
- [PR] [POC] Improve ValidatesRunner performance. Phase 0 [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/26 05:51:32 UTC, 2 replies.
- [PR] [Python] Fix ParquetIO silently corrupting data across windows in unbounded pipelines [beam] - posted by "developer-rpai (via GitHub)" <gi...@apache.org> on 2026/09/26 06:09:05 UTC, 1 replies.
- Re: [PR] Decorrelate sub-queries using normalizeForVolcano pass [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:42:47 UTC, 0 replies.
- Re: [PR] Add parser conformance resolution and logical plan parsing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:42:49 UTC, 0 replies.
- Re: [PR] Add SINGLE_VALUE aggregate function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:42:51 UTC, 0 replies.
- Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:42:55 UTC, 2 replies.
- Re: [I] [Feature Request]: Add a Beam utility for efficiently copying files across file-systems [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:42:57 UTC, 0 replies.
- Re: [I] [Feature Request]: Support default log level and log level overrides for java direct runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:43:03 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a test suite for the transform service [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:43:06 UTC, 1 replies.
- Re: [I] [Feature Request]: Add library stubs or py.typed marker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/26 12:43:10 UTC, 1 replies.
- [PR] [Java] Bound pending Watch results per poll [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/27 00:49:00 UTC, 3 replies.
- Re: [I] Improve scalability of the Watch transform [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/27 00:49:36 UTC, 1 replies.
- [PR] [#20502] Remove nullness suppressions from the direct-java runner [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/27 04:56:20 UTC, 8 replies.
- [PR] Fix flaky Prism tests [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/27 06:00:03 UTC, 1 replies.
- [PR] Fix flaky Python tests [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/27 06:00:51 UTC, 4 replies.
- [PR] Fix flaky Java tests [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/27 06:01:55 UTC, 8 replies.
- [I] [Bug]: IcebergIO cannot write Beam rows containing EnumerationType (proto enum) fields [beam] - posted by "mananmangal (via GitHub)" <gi...@apache.org> on 2026/09/27 17:57:40 UTC, 2 replies.
- [PR] Fix IcebergIO failing to write EnumerationType (proto enum) fields [beam] - posted by "mananmangal (via GitHub)" <gi...@apache.org> on 2026/09/27 18:40:44 UTC, 2 replies.
- [PR] [BEAM-20503] Replace inert nullness suppressions in BigQueryIOPushDownIT [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/27 19:15:47 UTC, 4 replies.
- Re: [I] [Bug]: Python ReadFromMongoDB/RangeTracker raises OverflowError [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/27 20:50:19 UTC, 1 replies.
- Re: [I] [Bug]: ValueError: Invalid DisplayDataItem when using AsSingleton for side input (need better parameter validation before it hits this) [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/27 20:50:21 UTC, 0 replies.
- [PR] [Java] Reduce logging severity for state requests cancelled by the runner [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/09/27 21:35:27 UTC, 6 replies.
- [PR] DNR! POC! Merge validates runner phase2 [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/27 23:32:54 UTC, 4 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.8.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:34:45 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.113.2 to 1.113.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:36:05 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/datastore from 1.26.0 to 1.27.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:36:22 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.38.1 to 4.38.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:36:57 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.8 to 1.23.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:38:03 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.84.0 to 1.85.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:38:19 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.0 to 1.47.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 04:39:53 UTC, 2 replies.
- Re: [I] [IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 09:19:29 UTC, 1 replies.
- [PR] Bump kafka-clients to 3.9.2 in expansion-service to fix SASL auth on JDK 24+ (#39789) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/28 11:00:20 UTC, 2 replies.
- Re: [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/28 11:07:02 UTC, 1 replies.
- [PR] Clarify element processing timeout help text [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/28 11:11:54 UTC, 3 replies.
- Re: [I] [Bug]: SolaceIO write transform loses output elements in batch pipelines [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/28 11:35:30 UTC, 1 replies.
- Re: [I] Migrate Jupyter Sidepanel extension to pip-based installation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:34 UTC, 1 replies.
- Re: [I] [Feature Request]: Make lineage tracking pluggable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:37 UTC, 0 replies.
- Re: [I] [Bug]: ignoreUnknownValues not working when using CreateDisposition.CREATE_IF_NEEDED [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:42 UTC, 1 replies.
- Re: [I] [Bug]: BigQuery Storage Write API: Output timestamps must be no earlier than the timestamp of the current input or timer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:44 UTC, 1 replies.
- Re: [I] [Feature Request]: [Java BQ] Support storageApiAppendThresholdRecordCount option when streaming with STORAGE_WRITE_API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:47 UTC, 1 replies.
- Re: [I] [Bug]: Large PIPELINE_OPTIONS can lead to command line args list too long errors in SDK containers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:49 UTC, 1 replies.
- Re: [I] [Feature Request]: Predictable job names for tests running on Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:52 UTC, 1 replies.
- Re: [I] [Feature Request]: Support Java 14 records in `SchemaCoder` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:54 UTC, 1 replies.
- Re: [I] [Failing Test]: PreCommit Python Integration Failing on Unrelated Changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:56 UTC, 1 replies.
- Re: [I] [Task]: Add clients in the HCLS API in `dicomclient.py` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/28 12:53:58 UTC, 1 replies.
- Re: [I] Add CouchbaseIO [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/28 14:22:13 UTC, 1 replies.
- [PR] [PR Bot] Best-effort assign reviewers via GitHub API [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/28 14:30:06 UTC, 3 replies.
- [PR] [PR Bot] Pause review reminders on draft PRs and update Next Action state [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/28 14:37:34 UTC, 3 replies.
- [PR] [PR Bot] Select single main and backup reviewer using label priority [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/28 14:37:38 UTC, 4 replies.
- [PR] Fix documentation typos across website, contributor docs, and Go SDK docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/28 15:43:10 UTC, 3 replies.
- [PR] [#20501] Remove nullness suppressions from sql extensions module [beam] - posted by "nitinware (via GitHub)" <gi...@apache.org> on 2026/09/28 16:02:52 UTC, 3 replies.
- [PR] remove codeql java build checks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/28 16:30:49 UTC, 1 replies.
- Re: [PR] Re-arrange GcsUtil unit tests and integration tests [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/28 16:34:25 UTC, 5 replies.
- [PR] Add more GCS unit and integration tests to improve test coverage [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/28 18:17:37 UTC, 0 replies.
- Re: [I] [Bug]: Iceberg managed connector upgrade failed in GCP Dataflow [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/09/28 18:41:32 UTC, 1 replies.
- [PR] Improvements to file stagin [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/28 18:42:27 UTC, 0 replies.
- [PR] Make ValidatesRunner faster: Share and cache GCS staging across TestDataflowRunner executions [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/28 19:04:09 UTC, 11 replies.
- [PR] Make ValidatesRunner faster: Cache and reuse shared metrics pipeline execution in MetricsTest [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/28 19:10:05 UTC, 3 replies.
- [PR] Make ValidatesRunner faster: Tune Dataflow ValidatesRunner configuration [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/28 19:14:23 UTC, 10 replies.
- Re: [PR] Make ValidatesRunner faster: Improvements to file staging [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/28 20:39:06 UTC, 2 replies.
- [PR] Draft: Make Presubmits faster [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/29 01:59:53 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless from 7.2.1 to 8.10.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 04:23:15 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/profiler from 0.6.0 to 0.7.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 04:23:23 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 7.2.1 to 8.10.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 04:23:30 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.57.0 to 1.58.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 04:23:38 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/pubsub/v2 from 2.6.2 to 2.7.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 04:23:59 UTC, 2 replies.
- [PR] [Python] Fix overflow in LexicographicKeyRangeTracker [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/29 04:54:42 UTC, 4 replies.
- [PR] [Python] Validate FileBasedSink num_shards type [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/09/29 04:55:21 UTC, 2 replies.
- [PR] [Python] Fix LogElements crash on global window timestamps [beam] - posted by "anishmehta24 (via GitHub)" <gi...@apache.org> on 2026/09/29 09:26:12 UTC, 2 replies.
- [PR] [Python] Run Dataflow TFT benchmark tests on Python 3.11 to avoid protobuf resolution clash [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/29 09:44:36 UTC, 4 replies.
- [PR] Update managed-io.md for release 2.77.0-RC3 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/09/29 10:37:29 UTC, 1 replies.
- [PR] Bump nodemailer from 9.1.1 to 10.0.2 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 11:32:44 UTC, 2 replies.
- Re: [I] Python SDK harness logs from child processes missing correct portability_worker_id in Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:04 UTC, 0 replies.
- Re: [I] [Bug]: Beam tag is not working properly [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:12 UTC, 1 replies.
- Re: [I] [Feature Request]: Katas need new platform/host [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:16 UTC, 1 replies.
- Re: [I] [Feature Request][prism]: Add support for the multi-chunk iterable protocol [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:20 UTC, 1 replies.
- Re: [I] [Bug]: [Doc] Beam Capability Matrix space [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:24 UTC, 1 replies.
- Re: [I] [Task][Go SDK]: Add github precommits mini suites for each runner against the Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:28 UTC, 1 replies.
- Re: [I] [Bug]: condition missed after a unnest [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:32 UTC, 1 replies.
- Re: [I] [Bug]: Okio present in beam-sdks-java-extensions-sql-jdbc [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:36 UTC, 1 replies.
- Re: [I] [Feature Request]: Retry policies for ParDo [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:42 UTC, 1 replies.
- Re: [I] [Task]: Add Criteo perf test for MLTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:46 UTC, 1 replies.
- Re: [I] [Bug]: [SQL] BeamKafkaTable doesn't set commitOffsetsInFinalize to KafkaIO reader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:51 UTC, 1 replies.
- Re: [I] [Bug]: Unable to use applyRowMutations() in bigquery IO apache beam java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:55 UTC, 1 replies.
- Re: [I] [Bug]: Update or Remove Integrations page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:53:59 UTC, 1 replies.
- Re: [I] [Feature Request]: Allow metrics to be tagged or segmented [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/29 12:54:03 UTC, 1 replies.
- Re: [I] [Bug]: BigqueryIO: 404 on delete should be a success [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/29 13:47:15 UTC, 0 replies.
- [PR] Exposing evictWritersWhenFull in AvroIO [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2026/09/29 14:48:43 UTC, 1 replies.
- [PR] Addfiles partition bounds fixes (#40252) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/09/29 16:43:50 UTC, 5 replies.
- [PR] [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336) [beam] - posted by "darshan-sj (via GitHub)" <gi...@apache.org> on 2026/09/29 17:36:12 UTC, 3 replies.
- [PR] Remove pull request template [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/29 17:54:25 UTC, 1 replies.
- [PR] [Gemini] GCP BigQuery IO Modern Client Migration [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/29 17:58:33 UTC, 2 replies.
- [PR] add pubsub max_read_time_seconds parameter [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/09/29 18:00:19 UTC, 0 replies.
- [PR] [release-2.77] Cherry-pick #40259: Speed up Beam presubmits [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/29 18:31:33 UTC, 1 replies.
- [PR] Fix ML container publishing in push3XX tasks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/29 18:59:47 UTC, 3 replies.
- [PR] [Java] ParquetIO: resolve file records against the read schema [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/29 19:28:12 UTC, 1 replies.
- Re: [I] [Bug]: ParquetIO failing to read with specified schema [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/09/29 19:50:16 UTC, 0 replies.
- [PR] Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/29 19:50:28 UTC, 4 replies.
- [PR] Fix invalid POM for io-component [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/29 20:25:58 UTC, 2 replies.
- [I] [Task]: Add a GCS temp bucket cleaner to .test-infra/tools to prevent bucket leaks [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/30 01:17:20 UTC, 0 replies.
- [PR] Bump brace-expansion from 1.1.12 to 1.1.21 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 01:29:28 UTC, 2 replies.
- [PR] Bump nodemailer from 10.0.2 to 10.0.9 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 01:29:37 UTC, 2 replies.
- Re: [PR] [POC] Improve ValidatesRunner performance. Parallelize runs [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/30 01:32:11 UTC, 1 replies.
- [PR] delay LeaderBoardIT Pub/Sub inject [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/30 09:39:08 UTC, 0 replies.
- [PR] swap Dataflow Streaming and Streaming Engine VR cron times [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/30 09:54:39 UTC, 3 replies.
- [PR] Include OpenTelemetry dependencies in published Dataflow runner POM [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/30 09:59:37 UTC, 5 replies.
- [PR] [OpenTelemetry] set default otel.service.instance.id [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/09/30 10:26:46 UTC, 1 replies.
- [PR] [Flink] Restore source split logs [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/09/30 10:45:49 UTC, 3 replies.
- [PR] pin Side Input Test 8 container [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/30 11:07:12 UTC, 0 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/09/30 12:54:43 UTC, 0 replies.
- Re: [I] How to run typescript apache beam pipeline in Flink Cluster [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:54:53 UTC, 1 replies.
- Re: [I] [Task][Go SDK]: Determine canonical local temp directory. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:54:59 UTC, 1 replies.
- Re: [I] [Task][Go SDK][Cleanup]: Migrate passert package exclusively to the generic register package. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:04 UTC, 1 replies.
- Re: [I] [Task]: Bump HCLS API version from GA to Alpha/Beta [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:10 UTC, 1 replies.
- Re: [I] [Task]: Align Spark/Hadoop versions in Spark multiple-versions unit/VR tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:16 UTC, 1 replies.
- Re: [I] [Bug]: [Java BQ] Race condition between copy jobs at different triggers in a streaming pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:20 UTC, 1 replies.
- Re: [I] [Task][Go SDK]: Update datastoreio tests to not rely on direct runner. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:24 UTC, 1 replies.
- Re: [I] [Task][Go SDK]: Update fhirio tests to not rely on direct runner. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:28 UTC, 1 replies.
- Re: [I] [Bug]: Avro schema support doesn't support UNION types (OneOf) for SpecificRecords [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:32 UTC, 1 replies.
- Re: [I] [Bug][Go SDK]: Xlang Bigquery IO doesn't appear to support Time type fields. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:36 UTC, 1 replies.
- Re: [I] [Bug][Go SDK]: Native bigqueryio package doesn't have scalable writes. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:44 UTC, 1 replies.
- Re: [I] [Task]: Translate the IO Authoring Guide for the Go SDK. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:48 UTC, 1 replies.
- Re: [I] [Feature Request][Go SDK]: Improve Native File IO Writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:52 UTC, 1 replies.
- Re: [I] [Feature Request]:[Go SDK]: BigTableIO should have scalable reads. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:55:58 UTC, 1 replies.
- Re: [I] [Feature Request][Go SDK]: Rewrite the `dot` runner in terms of a Portable pipeline. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:56:07 UTC, 1 replies.
- Re: [I] [Feature Request]: Support pyarrow RecordBatch for MLTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:56:11 UTC, 1 replies.
- Re: [I] [Bug]: Read from datastore with inequality filters [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 12:56:15 UTC, 1 replies.
- Re: [PR] Add V2 unit tests and V1/V2 parity ITs for GcsUtil [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/09/30 14:48:22 UTC, 2 replies.
- [PR] Fix partial insertError metric status bug [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/30 15:12:58 UTC, 5 replies.
- [PR] [Claude] Capture behavior of the BigQueryWrapper during requests [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/30 15:21:23 UTC, 1 replies.
- [PR] [CI] Make Gradle caches read-only for untrusted presubmit workflow runs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/30 15:58:38 UTC, 3 replies.
- [PR] [Claude] Produce Beam-specific representation of BQ resources, rework compat shims [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/09/30 15:59:06 UTC, 1 replies.
- [PR] Migrate CI workflows from pull_request_target to pull_request [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/09/30 18:29:29 UTC, 0 replies.
- [PR] Bump @grpc/grpc-js from 1.14.4 to 1.14.5 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 18:29:46 UTC, 1 replies.
- [PR] Bump urllib3 from 2.7.0 to 2.8.0 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 18:29:46 UTC, 3 replies.
- [PR] Bump urllib3 from 2.7.0 to 2.8.0 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/09/30 18:55:20 UTC, 3 replies.
- [PR] Temporarily set Bigtable client version upper bound [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/09/30 20:44:17 UTC, 1 replies.
- [PR] [Python] Fix BigtableIO write test mocks for google-cloud-bigtable batcher delegation [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2026/09/30 21:37:08 UTC, 0 replies.
- Re: [I] SDKs should have sane retry strategy for submitting jobs [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/09/30 21:52:29 UTC, 1 replies.
- [PR] fix performance plot [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/09/30 22:16:55 UTC, 2 replies.
- Re: [PR] Improve ValidatesRunner performance. Parallelize runs [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/30 22:29:14 UTC, 0 replies.
- [PR] Remove allJavadoc from javaPreCommit [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/09/30 23:16:15 UTC, 0 replies.