github@beam.apache.org, 2026-08

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

- Re: [PR] [Docs] Add local Flink cluster guide for Python, update Flink version references [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/01 00:08:37 UTC, 0 replies.
- Re: [PR] Update SDK container tags [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 00:45:44 UTC, 1 replies.
- Re: [PR] [Prism] Schedule consumers of a self checkpointing source [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 00:45:50 UTC, 19 replies.
- [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/08/01 05:27:20 UTC, 15 replies.
- Re: [PR] Add Sample.Any to the Python SDK to match Java's Sample.any [beam] - posted by "SreeramaYeshwanthGowd (via GitHub)" <gi...@apache.org> on 2026/08/01 05:31:01 UTC, 5 replies.
- [PR] Bump pyasn1 from 0.6.3 to 0.6.4 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 07:53:34 UTC, 5 replies.
- Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/08/01 09:31:01 UTC, 1 replies.
- [I] The PostCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 10:10:15 UTC, 3 replies.
- [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 10:10:19 UTC, 5 replies.
- [I] The PreCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 10:10:24 UTC, 3 replies.
- Re: [PR] Add OpenLineage extension for Java SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 12:31:11 UTC, 5 replies.
- Re: [PR] Added flag for overriding artifact hostname [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 12:49:40 UTC, 2 replies.
- Re: [I] [Feature Request]: Provide a user-facing api to stage and download large file dependencies onto Beam SDK workers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 12:49:59 UTC, 2 replies.
- [PR] [GSoC 2026] Kafka Streams runner: bound a bundle by element count [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/01 15:30:38 UTC, 9 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/01 18:49:37 UTC, 5 replies.
- Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/02 02:50:52 UTC, 2 replies.
- [PR] [Docs] Add CHANGES entries for Python UnboundedSource and Watch [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/02 03:40:51 UTC, 3 replies.
- [PR] [Docs] Add a contributor guide for running Python on a local Flink cluster [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/02 03:43:44 UTC, 6 replies.
- Re: [PR] [Docs] Update Flink version references on the Flink runner page [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/02 03:45:05 UTC, 3 replies.
- Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/02 06:37:10 UTC, 6 replies.
- Re: [PR] Feat: new cleaning rule to orphaned subscriptions [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2026/08/02 08:15:39 UTC, 2 replies.
- Re: [I] [Feature Request]: Add Support for ClickHouse Cluster in `ClickHouseResourceManager` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/02 12:49:51 UTC, 1 replies.
- Re: [I] [Bug]: NullPointerException in KafkaSourceDescriptor during Dataflow job updates in beam-python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/02 12:49:56 UTC, 1 replies.
- Re: [PR] [Spark] Support splittable DoFn self-checkpointing in portable batch [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/08/02 15:03:48 UTC, 4 replies.
- [PR] fix(dataframe): claim remaining restriction range on empty/header-only CSV reads [beam] - posted by "ManvithPanyam (via GitHub)" <gi...@apache.org> on 2026/08/02 16:39:32 UTC, 6 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/02 22:29:06 UTC, 1 replies.
- [PR] Support array-valued schema options in Python [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/03 02:25:36 UTC, 3 replies.
- Re: [I] Potential sensitive files found in repository [beam] - posted by "Dharshika-11 (via GitHub)" <gi...@apache.org> on 2026/08/03 04:19:22 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.3 to 2.14.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 04:29:51 UTC, 4 replies.
- [PR] Bump google.golang.org/grpc from 1.82.1 to 1.83.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 04:29:57 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.37.3 to 4.37.4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 04:31:45 UTC, 2 replies.
- Re: [PR] Support core dump analysis with pystack and gdb. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/03 11:15:39 UTC, 2 replies.
- [PR] Fix Row.toString NPE on a null nested inside an array, map or row [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/03 11:33:07 UTC, 4 replies.
- Re: [PR] [DebeziumIO] Upgrade to Debezium 3.5.2.Final [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/08/03 11:50:49 UTC, 2 replies.
- [I] [Bug]: SolaceIO write transform does not output all publish results [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2026/08/03 12:18:42 UTC, 0 replies.
- [I] [Bug]: SolaceIO write transform loses output elements in batch pipelines [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2026/08/03 12:27:30 UTC, 2 replies.
- [PR] [OpenTelemetry] Redistribute - trace propagation [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/03 12:42:57 UTC, 7 replies.
- Re: [PR] Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/03 12:53:58 UTC, 5 replies.
- Re: [PR] Add biquery query parameter option to support parametrize query [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:13:53 UTC, 1 replies.
- Re: [PR] Add query_output_schema to ReadFromBigQuery for BEAM_ROW + query support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:13:58 UTC, 1 replies.
- Re: [PR] Allow strongly-consistent schema updates in BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:14:06 UTC, 4 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/08/03 13:28:33 UTC, 0 replies.
- Re: [I] [Bug]: Beam Yaml Jinja option may conflict with well known Pipeline option [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:28:38 UTC, 3 replies.
- Re: [I] [Feature Request]: Add pipeline options for diskProvisionedIops and diskProvisionedThroughputMipbs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:28:40 UTC, 1 replies.
- Re: [I] [Task]: Java SDK, make BigTableIO compatible with BigTable library 2.71.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:28:41 UTC, 1 replies.
- Re: [I] Bug: apache_beam.io.gcp.pubsublite.ReadFromPubSubLite not working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 13:28:57 UTC, 1 replies.
- Re: [PR] Fix dataframe CSV tests on Windows [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/03 14:22:36 UTC, 0 replies.
- Re: [I] Fix csv reading tests on Windows [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/03 14:22:38 UTC, 0 replies.
- [PR] Fix internal test failure after #39487 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/03 14:28:29 UTC, 5 replies.
- [PR] add Timestamp.MICROS for iceberg timestamptz [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/03 14:32:38 UTC, 8 replies.
- [PR] Update activemq to 5.19.3 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/03 14:47:17 UTC, 1 replies.
- Re: [I] [Bug]: Cross-language schema decoding fails for ARRAY schema options [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/03 16:37:57 UTC, 0 replies.
- [PR] Adds a new CoderTranslator for Java SchemaCoders. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/08/03 16:42:43 UTC, 15 replies.
- Re: [PR] remove gsutil usage [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 17:06:46 UTC, 7 replies.
- [PR] Option unfication [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/08/03 17:13:28 UTC, 2 replies.
- Re: [PR] Update activemq to 5.19.5 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 17:16:43 UTC, 1 replies.
- [PR] Update Python SDK container tag [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/03 17:39:45 UTC, 2 replies.
- [PR] initial [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/03 18:18:52 UTC, 1 replies.
- Re: [I] [Feature Request]: Specify output_type in ReadFromBigQuery Beam YAML transform [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/03 19:05:36 UTC, 0 replies.
- Re: [PR] [Go SDK] Add GroupIntoBatches transform (#19868) [beam] - posted by "vgough (via GitHub)" <gi...@apache.org> on 2026/08/03 19:13:36 UTC, 5 replies.
- Re: [PR] Support lakehouse PCNT format in BigQueryIO storage read. [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 19:17:49 UTC, 11 replies.
- Re: [I] Support for custom Python UnboundedSource [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/03 19:43:40 UTC, 0 replies.
- Re: [PR] [Python] Bound Watch state with a timestamp cursor [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/03 20:17:17 UTC, 0 replies.
- Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/03 20:21:32 UTC, 7 replies.
- [PR] Bump aiohttp from 3.14.1 to 3.14.3 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/03 21:06:32 UTC, 3 replies.
- Re: [PR] [Iceberg CDC] Add Changelog readers and update resolver [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/03 21:32:51 UTC, 4 replies.
- Re: [PR] [Iceberg] Make timestamptz return new Timestamp.MICROS logical type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/03 21:42:09 UTC, 0 replies.
- Re: [I] The Unmanaged Service Accounts Keys Audit job is flaky [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/03 21:43:08 UTC, 0 replies.
- [PR] Adds the Delta Lake CDC read transforms to the Managed I/O API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/03 21:44:25 UTC, 11 replies.
- Re: [PR] Part 1: Log systemName in DataflowWorkUnitClient, Commit, and core worker states [beam] - posted by "rwiggles (via GitHub)" <gi...@apache.org> on 2026/08/03 22:44:50 UTC, 1 replies.
- [PR] [Iceberg CDC] Finish wiring CDC source together and add external API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/04 00:38:11 UTC, 16 replies.
- Re: [PR] Potential fix for environment variable built from user-controlled sources [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/04 03:23:42 UTC, 0 replies.
- [PR] Bump cryptography from 48.0.1 to 50.0.0 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 03:26:03 UTC, 3 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.7.0 to 2.8.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:22:57 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.32 to 1.19.33 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:24:24 UTC, 3 replies.
- [PR] Bump zizmorcore/zizmor-action from 0.6.1 to 0.6.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:24:35 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.37 to 1.22.38 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:25:38 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.33 to 1.32.34 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:26:52 UTC, 3 replies.
- [PR] Bump github.com/aws/smithy-go from 1.27.5 to 1.27.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:26:59 UTC, 4 replies.
- [PR] Fix OpenTelemetry dependencies in published POMs [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/04 04:27:01 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.106.2 to 1.106.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 04:28:18 UTC, 3 replies.
- Re: [PR] [OpenTelemetry] Create span in spanner CDC to start new trace when otel is enabled. [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/04 09:07:25 UTC, 0 replies.
- [PR] [GSoC 2026] Kafka Streams runner: CombineTest coverage and two review follow-ups [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/04 09:27:09 UTC, 5 replies.
- [PR] [GSoC 2026] Kafka Streams runner: read unbounded sources [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/04 11:28:27 UTC, 11 replies.
- [PR] [SolaceIO] refactor SolaceIO's writers finishBunlde [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/04 12:37:51 UTC, 1 replies.
- Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:33 UTC, 2 replies.
- Re: [PR] Avoid side input when gathering unwindowed WriteFiles results [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:34 UTC, 4 replies.
- Re: [PR] Portable VoidCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:37 UTC, 8 replies.
- Re: [PR] feat: add configurable bigtable retries [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:44 UTC, 6 replies.
- Re: [PR] SolaceIO - fix for data loss during scaling/rebalancing (#36991) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:52 UTC, 14 replies.
- Re: [PR] datastore: Same key in mutation batch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:53 UTC, 7 replies.
- Re: [PR] RedisIO support PCollection of [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 12:49:58 UTC, 5 replies.
- Re: [I] IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command (e.g. `pip install `) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 13:10:13 UTC, 1 replies.
- Re: [I] Spanner is hanging when DCP is enabled [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 13:10:17 UTC, 1 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/08/04 13:10:38 UTC, 0 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/08/04 13:10:40 UTC, 0 replies.
- Re: [I] [Task]: Create a HealthcareIO Utilities file [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 13:10:42 UTC, 0 replies.
- [I] [Bug]: Profiler instrumentation ignores profiler-related options on portable runners [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/08/04 13:33:39 UTC, 2 replies.
- Re: [PR] Add helpers to interact with pipeline options in boot entrypoints [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 13:46:52 UTC, 18 replies.
- Re: [PR] Deflake JmsIO tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/04 14:00:32 UTC, 2 replies.
- [PR] Fix Dataflow ValueProvider serialization [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/04 14:14:59 UTC, 6 replies.
- Re: [PR] [SolaceIO] refactor SolaceIO's writers finishBundle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 14:18:34 UTC, 11 replies.
- [PR] Create temporary dataset with a 24 hour ttl. [beam] - posted by "aebrahim (via GitHub)" <gi...@apache.org> on 2026/08/04 17:43:56 UTC, 1 replies.
- Re: [I] [Bug]: WriteToBigQuery FILE_LOADS method should support writing schema'd PCollections. [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/08/04 17:53:09 UTC, 1 replies.
- [PR] add aws hadoop to DeltaIO [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/04 19:08:43 UTC, 18 replies.
- Re: [PR] [Python] Create temporary dataset with a 24 hour ttl. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/04 20:06:25 UTC, 7 replies.
- [PR] [OpenTelemetry] changes.md [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/04 20:39:09 UTC, 6 replies.
- [PR] [Java] Avoid RowCoder bytecode generation [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/04 21:36:15 UTC, 9 replies.
- [I] [Task]: Investigate native ARM runners for Python aarch64 wheels [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/05 02:19:06 UTC, 1 replies.
- [PR] [examples] Atomically publish subprocess executables [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/05 02:22:52 UTC, 2 replies.
- [PR] [BigQueryIO] Parallelize schema update integration tests [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/05 02:28:55 UTC, 3 replies.
- Re: [I] Multiple batch joins on the same key results in multiple shuffles [beam] - posted by "AsmitBhardwaj (via GitHub)" <gi...@apache.org> on 2026/08/05 03:12:26 UTC, 1 replies.
- [PR] Support sharded coder for Prism runner cross-lang [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/05 03:28:04 UTC, 3 replies.
- [I] Upgrade vendored grpc to remove vulnerabilities coming from netty [beam] - posted by "milindl (via GitHub)" <gi...@apache.org> on 2026/08/05 05:47:59 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support for reading bounded CDC data [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/05 06:42:23 UTC, 0 replies.
- [PR] [OpenTelemetry] Enable OpenTelemetry stitching with Logs for Dataflow worker [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/05 08:44:00 UTC, 15 replies.
- [I] Kafka Streams runner: read a source's splits in parallel [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:05:38 UTC, 0 replies.
- [PR] [GSoC 2026] Kafka Streams runner: user documentation, marked experimental [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:07:25 UTC, 10 replies.
- [I] Kafka Streams runner: side inputs [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:12 UTC, 0 replies.
- [I] Kafka Streams runner: stateful ParDo and user timers [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:14 UTC, 0 replies.
- [I] Kafka Streams runner: merging windows and custom WindowFns [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:16 UTC, 0 replies.
- [I] Kafka Streams runner: splittable DoFn [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:17 UTC, 2 replies.
- [I] Kafka Streams runner: TestStream [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:18 UTC, 0 replies.
- [I] Kafka Streams runner: bundles are not bounded by time [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:21 UTC, 1 replies.
- [I] Kafka Streams runner: finalize unbounded source checkpoints [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:22 UTC, 0 replies.
- [I] Kafka Streams runner: committed metrics [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/05 10:42:23 UTC, 0 replies.
- Re: [PR] Added schema_update_options to Python BigQuery writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 12:46:05 UTC, 6 replies.
- Re: [I] [Bug]: BigQuery connector sets insane high maxRetryJobs for unbounded collections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 13:06:22 UTC, 1 replies.
- Re: [I] [Bug]: BigQuery connector ignores maxRetryJobs for bounded collections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 13:06:24 UTC, 1 replies.
- Re: [I] Python SDK 2.75 Flex Template: RuntimeValueProvider is being stringified [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/05 13:58:29 UTC, 1 replies.
- [PR] [python] Add Secret management module in apache_beam.utils.secret [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/05 16:34:18 UTC, 25 replies.
- [PR] fix PostCommit Python Dependency [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/05 17:00:51 UTC, 2 replies.
- Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/05 17:08:23 UTC, 3 replies.
- [PR] Fix Golang Zip Slip Vulnerability [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/05 17:44:06 UTC, 3 replies.
- [I] [Failing Test]: Flake in apache_beam.io.textio_test.TextSinkTest testMethod=test_write_pipeline_footer [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/08/05 18:17:12 UTC, 1 replies.
- Re: [I] The PostCommit Python Dependency job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/05 18:52:01 UTC, 3 replies.
- [PR] Add google-api-python-client to Python 3.14 container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/05 19:31:28 UTC, 6 replies.
- Re: [I] [Task]: Implement a full Iceberg CDC incremental source [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/05 19:51:29 UTC, 0 replies.
- [PR] Bump cryptography from 48.0.1 to 50.0.0 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 19:55:36 UTC, 2 replies.
- [PR] Bump aiohttp from 3.14.1 to 3.14.3 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 19:56:01 UTC, 2 replies.
- [PR] Bump aiohttp from 3.14.1 to 3.14.3 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/05 19:56:10 UTC, 2 replies.
- [PR] Updates CHANGES.md to include Delta Lake CDC [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/05 20:07:55 UTC, 2 replies.
- Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/05 20:14:53 UTC, 2 replies.
- [PR] (IcebergIO) bugfix: wire writeProperties through table create request, not DataWriteBuilder [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2026/08/05 20:39:31 UTC, 10 replies.
- Re: [PR] Add unit tests to Go harness package (issue #21386) [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/05 20:45:20 UTC, 0 replies.
- [PR] Make primary channel failover timeout configurable [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/08/05 21:35:11 UTC, 15 replies.
- [PR] Log systemname 2 cache [beam] - posted by "rwiggles (via GitHub)" <gi...@apache.org> on 2026/08/05 22:16:50 UTC, 4 replies.
- Re: [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/08/05 22:35:20 UTC, 2 replies.
- [PR] [Dataflow Streaming] Remove finalizeCommits from processWork [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/05 23:46:07 UTC, 4 replies.
- [PR] [wip] add closing step [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/06 03:19:53 UTC, 0 replies.
- [PR] Enable Apache Iceberg REST Metrics Reporting for Lakehouse [beam] - posted by "feefs (via GitHub)" <gi...@apache.org> on 2026/08/06 03:50:54 UTC, 5 replies.
- [PR] Bump github/codeql-action from 4.37.4 to 4.37.5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 04:25:57 UTC, 2 replies.
- [PR] [Dataflow Streaming] Remove redundant onKeyTransition call [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/06 05:25:01 UTC, 3 replies.
- Re: [PR] [Dataflow Streaming] [Multi Key] Drop failed work in BoundedQueueExecutor::pollWork [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/06 05:25:50 UTC, 6 replies.
- Re: [I] Account Keys Compliance Issue Detected [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/06 06:43:34 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/08/06 06:58:51 UTC, 7 replies.
- [I] The PreCommit Python Docker job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 07:41:00 UTC, 3 replies.
- [I] The PreCommit Portable Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 07:41:11 UTC, 2 replies.
- [PR] normalize io.gcp.DicomSearch [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/06 11:48:30 UTC, 10 replies.
- Re: [PR] Fix PeriodicImpulse/PeriodicSequence watermark regression (#39026) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 12:47:15 UTC, 6 replies.
- Re: [PR] Fail fast in artifact staging when storing an artifact fails [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 12:47:16 UTC, 8 replies.
- Re: [PR] [FnApi Java] Close named data stream multiplexers once no bundle is u… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 12:47:22 UTC, 1 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/08/06 13:05:37 UTC, 0 replies.
- Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/06 13:53:28 UTC, 0 replies.
- [PR] [wip] test pr close [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/06 14:15:08 UTC, 3 replies.
- [PR] Fix mobile gaming release validation background process cleanup for Java 21 compatibility [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/06 14:32:18 UTC, 14 replies.
- Re: [PR] Add Dynamic Schema support to StorageWriteToBigQuery [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/06 15:19:10 UTC, 4 replies.
- [PR] Fix Python 3.14 Container Build, Streamline Installation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/06 15:20:21 UTC, 1 replies.
- [PR] Add mention of Managed Iceberg read breakage [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/06 16:35:35 UTC, 3 replies.
- [PR] add another jdbc yaml pipeline and other fixes [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/06 18:16:51 UTC, 1 replies.
- [PR] Auto-infer BigQuery schema from schema'd PCollections for FILE_LOADS [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/08/06 18:23:48 UTC, 5 replies.
- [PR] Fix GRPC channel leak [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/06 19:30:40 UTC, 1 replies.
- [I] [yaml] Normalize FirestoreIO [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2026/08/06 19:56:37 UTC, 0 replies.
- [I] [yaml] Normalize KinesisIO [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2026/08/06 19:56:44 UTC, 1 replies.
- [I] [yaml] Normalize SnowflakeIO [beam] - posted by "Polber (via GitHub)" <gi...@apache.org> on 2026/08/06 19:57:01 UTC, 1 replies.
- [PR] fix: wait for pending ACK callbacks in SolaceIO write finishBundle to prevent batch pipeline data loss [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/06 20:27:22 UTC, 4 replies.
- [PR] Log the System name in more places instead of the computationId [beam] - posted by "rwiggles (via GitHub)" <gi...@apache.org> on 2026/08/06 21:25:06 UTC, 7 replies.
- [PR] [Dataflow Streaming] Mark worker as unhealthy in presence of stuck commits [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/06 22:15:20 UTC, 5 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 23:01:30 UTC, 3 replies.
- [I] The pr-bot-new-prs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/06 23:44:34 UTC, 3 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 00:13:25 UTC, 1 replies.
- [PR] [Python] Deflake TextIO footer test [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/07 02:20:49 UTC, 3 replies.
- [PR] [Python] Deflake anomaly transform tests [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/07 04:09:04 UTC, 0 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 04:19:17 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.38 to 1.22.39 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 04:24:53 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.106.3 to 1.106.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 04:26:15 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.37.5 to 4.37.6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 04:26:35 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.51.0 to 1.52.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 04:26:36 UTC, 2 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 06:54:38 UTC, 2 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 06:54:41 UTC, 3 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 06:54:45 UTC, 5 replies.
- [PR] [draft] adk example [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/07 09:08:14 UTC, 0 replies.
- [PR] fix iceberg CDC test [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/07 10:37:11 UTC, 4 replies.
- [PR] Bump h2 from 4.3.0 to 4.4.1 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 11:12:03 UTC, 2 replies.
- [PR] Bump h2 from 4.3.0 to 4.4.1 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 11:12:03 UTC, 3 replies.
- [PR] Bump js-yaml from 3.15.0 to 3.15.1 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 11:12:15 UTC, 3 replies.
- Re: [PR] Add Delta Lake to Iceberg Yaml blueprint IT [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 12:24:53 UTC, 3 replies.
- [PR] Add ml and interactive extras to quickstart-py doc [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 13:52:50 UTC, 2 replies.
- [PR] [GSoC 2026] Kafka Streams runner: Python wrapper that starts its own job server [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/07 13:58:01 UTC, 3 replies.
- Re: [PR] add closing dependabot step [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 14:28:59 UTC, 1 replies.
- [PR] [Cherrypick] fix iceberg CDC test - #39675 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/07 15:06:06 UTC, 3 replies.
- Re: [I] Row.toString() method is throwing NullPointerException while processing a nullable map [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 15:10:34 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/07 15:48:58 UTC, 3 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/08/07 16:03:36 UTC, 1 replies.
- [PR] Fix runner compatibility matrix glitch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 16:55:05 UTC, 3 replies.
- Re: [PR] [Python] Refactor MatchContinuously onto the Watch transform [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 18:07:33 UTC, 18 replies.
- [PR] fix ensurepip bundled pip cleanup for Python 3.12+ containers [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/07 21:04:26 UTC, 3 replies.
- Re: [PR] [GSoC 2026] Fixing the github action Unmanaged Service Account Keys [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/07 21:29:23 UTC, 6 replies.
- [I] [Feature Request]: Support portable logical type for Beam SQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 22:18:30 UTC, 0 replies.
- [I] [Task]: Go SDK portable logical type support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 22:19:30 UTC, 3 replies.
- Re: [I] [Feature Request]: Add a native Logging transform to Java SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/07 22:20:42 UTC, 1 replies.
- [PR] [GSoC 2026] Implement TestPubsubContext for Python GCP Integration Tests [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/07 22:54:59 UTC, 5 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/08 09:45:55 UTC, 3 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/08/08 12:16:59 UTC, 3 replies.
- Re: [PR] Handle multi-key bundles in side-input runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/08 12:17:01 UTC, 3 replies.
- Re: [PR] Add BigQueryIO support for clone table creation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/08 12:17:03 UTC, 3 replies.
- Re: [I] [Task]: Use Direction bias for perf alert tool [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/08 12:47:30 UTC, 0 replies.
- [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/08 12:47:32 UTC, 3 replies.
- [PR] fix: drain all producer queues in SolaceIO publishResults, not just the current bundle's producer [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/09 02:23:08 UTC, 1 replies.
- [PR] Bump keras from 3.12.3 to 3.15.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/09 11:53:29 UTC, 3 replies.
- [PR] Fix Windows paths for Dataflow job files [beam] - posted by "aryansk (via GitHub)" <gi...@apache.org> on 2026/08/09 22:42:20 UTC, 0 replies.
- [PR] Document required Go SDK initialization [beam] - posted by "aryansk (via GitHub)" <gi...@apache.org> on 2026/08/09 22:47:29 UTC, 0 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.7.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:34:48 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.33 to 1.19.34 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:35:54 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.34 to 1.32.35 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:37:10 UTC, 2 replies.
- [PR] Bump dorny/paths-filter from 4.0.1 to 4.0.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:37:46 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.106.4 to 1.107.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:38:26 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.39 to 1.22.41 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:39:51 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.291.0 to 0.292.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 04:39:59 UTC, 3 replies.
- Re: [I] No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)? [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/10 11:39:36 UTC, 0 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/08/10 12:49:12 UTC, 0 replies.
- Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/10 13:34:08 UTC, 0 replies.
- [PR] CP: Fix mobile gaming release validation background process cleanup (#39658) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/10 13:43:21 UTC, 3 replies.
- [PR] Attempt to revert gcs connector to 2.2.26 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/10 14:24:14 UTC, 3 replies.
- [PR] [Cherrypick] fix ensurepip bundled pip cleanup for Python 3.12+ containers [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/10 14:57:46 UTC, 1 replies.
- [PR] [GSoC 2026] Kafka Streams runner: terminate a bounded pipeline when it is drained [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/10 15:50:10 UTC, 4 replies.
- [PR] Update managed-io.md for release 2.76.0-RC1 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/10 16:06:39 UTC, 2 replies.
- [PR] [DO NOT MERGE] compaction wip [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 16:46:56 UTC, 0 replies.
- [PR] Update base_image_requirements_manual.txt [beam] - posted by "apanich (via GitHub)" <gi...@apache.org> on 2026/08/10 16:54:57 UTC, 5 replies.
- Re: [PR] (IcebergIO) document writeProperties param more clearly [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 17:21:30 UTC, 2 replies.
- Re: [PR] [WIP] Iceberg CDC streaming source [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 18:06:34 UTC, 0 replies.
- Re: [PR] [WIP] remaining iceberg cdc changes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 18:06:36 UTC, 0 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/10 18:48:44 UTC, 2 replies.
- [PR] [IcebergIO] Serialize using json partition [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 19:00:19 UTC, 5 replies.
- Re: [I] [Feature Request]: Add DataFile compaction in Iceberg [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 22:23:32 UTC, 0 replies.
- [PR] [Iceberg compaction] file metadata carriers and writer factory [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 22:24:04 UTC, 5 replies.
- [PR] [Iceberg compaction] Rewrite configuration and Planning transform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/10 22:49:59 UTC, 3 replies.
- [PR] Fix Dataflow job file validation on Windows [beam] - posted by "ulofiai (via GitHub)" <gi...@apache.org> on 2026/08/11 00:10:11 UTC, 3 replies.
- [I] The Build python source distribution and wheels job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/11 00:49:44 UTC, 2 replies.
- Re: [I] [Bug]: RequestResponseIO: Call wraps retryable exceptions in UserCodeExecutionException, preventing retry/backoff [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/11 00:51:12 UTC, 0 replies.
- [I] [Task][prism]: Separate management logs from pipeline logs, with rolling log files [beam] - posted by "moawnallah (via GitHub)" <gi...@apache.org> on 2026/08/11 01:49:09 UTC, 1 replies.
- [I] [Bug]: HBaseIO skips connection cleanup when an earlier close() throws, permanently corrupting the shared-connection refcount [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/11 02:12:38 UTC, 3 replies.
- [PR] fix: run all HBaseIO cleanup steps even if an earlier close() throws [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/11 02:20:18 UTC, 4 replies.
- [PR] Release HBaseIO resources even when an earlier close() throws [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/11 02:31:00 UTC, 9 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/08/11 04:01:53 UTC, 2 replies.
- [PR] Fixes to delta CDC read [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/11 06:29:19 UTC, 3 replies.
- [PR] Bump grpcio-tools to 1.81.1 for Python 3.14 build [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/11 08:17:52 UTC, 2 replies.
- [PR] Fix Python Tests job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/11 08:34:52 UTC, 1 replies.
- [PR] [Cherrypick] Fix Python Tests job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/11 08:40:07 UTC, 1 replies.
- [PR] Update managed-io.md for release 2.76.0-RC2 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/11 10:07:35 UTC, 3 replies.
- Re: [I] [Task]: Merge Flink runner translations ? [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/11 12:48:53 UTC, 1 replies.
- [PR] Update Beam website to release 2.76.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/11 12:53:50 UTC, 8 replies.
- Re: [I] [yaml] Normalize io.gcp.DicomSearch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/11 13:08:30 UTC, 0 replies.
- [PR] Cp39645 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/11 14:07:33 UTC, 4 replies.
- [PR] Add min==max check to ensure bucket transform correctness in AddFiles [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/11 14:29:39 UTC, 6 replies.
- [PR] bump FnAPI container to beam-master-20260811 [beam] - posted by "ashwin-sampathkumar (via GitHub)" <gi...@apache.org> on 2026/08/11 14:53:37 UTC, 2 replies.
- [PR] Python timestamp fixes. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/11 15:32:44 UTC, 1 replies.
- [I] [Feature Request]: Implement Side-Input Table Cache for IcebergIO [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/11 16:45:10 UTC, 0 replies.
- [PR] [#39723] Implement model for Iceberg side input cache [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/11 18:05:54 UTC, 10 replies.
- [PR] [Iceberg compaction] Rewrite subgroups DoFn [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/11 20:26:35 UTC, 1 replies.
- [PR] [Iceberg compaction] Add committer DoFn [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/11 20:47:36 UTC, 1 replies.
- [PR] [Beam SQL] Introduce call procedures [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/11 21:28:46 UTC, 5 replies.
- [PR] [GSoC 2026] Active cleanup of orphaned subscriptions for the taxirides topic [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/11 22:54:55 UTC, 3 replies.
- [PR] fix: poll publish results from all producers in SolaceIO writer [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/11 23:01:02 UTC, 3 replies.
- [I] [Bug]: DynamoDB AttributeValueCoder cannot encode an empty list or empty map attribute [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/12 03:02:38 UTC, 0 replies.
- [PR] Encode DynamoDB empty list and empty map attributes [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/12 03:03:02 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.79.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/12 04:23:36 UTC, 3 replies.
- [PR] Bump github.com/aws/smithy-go from 1.27.6 to 1.27.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/12 04:23:42 UTC, 3 replies.
- [PR] fix: allow empty DynamoDB list and map in AttributeValueCoder [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/12 06:22:42 UTC, 1 replies.
- Re: [I] [Feature Request]: Remove dependency of KafkaIO withDynamicRead on beam_fn_api [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/12 06:58:39 UTC, 1 replies.
- [PR] [KafkaIO] Remove beam_fn_api requirement for dynamic reads [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/12 07:08:56 UTC, 4 replies.
- [PR] [GSoC 2026] Kafka Streams runner: portable ValidatesRunner suite for Python [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/12 11:32:03 UTC, 2 replies.
- Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/12 12:48:57 UTC, 2 replies.
- [PR] [Dataflow Streaming] Reduce contention on CommitQueue [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/12 15:07:51 UTC, 8 replies.
- [PR] Implement Vertex AI Model Monitoring v2 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/12 15:56:13 UTC, 12 replies.
- Re: [I] [Bug][Go]: Metrics incremented in Setup methods are not recalled. [beam] - posted by "zfaustk (via GitHub)" <gi...@apache.org> on 2026/08/12 20:39:28 UTC, 4 replies.
- Re: [I] PipelineOptions getters can produce null even if not annotated Nullable when no Default is specified [beam] - posted by "ronitsriv (via GitHub)" <gi...@apache.org> on 2026/08/12 20:49:40 UTC, 0 replies.
- [PR] [IcebergIO] add test for column default values [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/12 21:37:17 UTC, 4 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails consistently (io expansion-service shadowJar not found) [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/13 02:50:17 UTC, 1 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.43.0 to 0.44.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/13 04:23:19 UTC, 2 replies.
- [PR] Add per-destination GCS CMEK support to FileIO [beam] - posted by "weihanj (via GitHub)" <gi...@apache.org> on 2026/08/13 05:00:53 UTC, 2 replies.
- [PR] SnowflakeIO yaml [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/13 11:25:36 UTC, 19 replies.
- [I] [Bug]: RowJson rejects integral JSON values for a DOUBLE field when they exceed int range [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/13 12:11:36 UTC, 0 replies.
- [PR] Accept integral JSON values that a double represents exactly [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/13 12:12:02 UTC, 10 replies.
- Re: [I] [Failing Test]: beam_Playground_CI_Nightly failed at 2.70.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/13 12:49:13 UTC, 1 replies.
- Re: [I] [Feature Request]: Support more latency, throughput, and resource usage metrics in the benchmark framework [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/13 12:49:17 UTC, 1 replies.
- [PR] [GSoC 2026] Kafka Streams runner: measure how long work takes to move between instances [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/13 13:03:53 UTC, 3 replies.
- [PR] [Java] Bound the Watch deduplication state with a timestamp cursor [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/13 14:14:19 UTC, 8 replies.
- Re: [PR] [Iceberg compaction] Rewrite planner transform [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2026/08/13 17:04:31 UTC, 2 replies.
- Re: [PR] Log Fused Stage Name Instead of computation id in more places [beam] - posted by "rwiggles (via GitHub)" <gi...@apache.org> on 2026/08/13 23:43:57 UTC, 0 replies.
- Re: [PR] [Dataflow Streaming] Commit size validation for multi key commits [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/08/14 02:43:44 UTC, 12 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.0 to 1.107.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/14 04:24:30 UTC, 3 replies.
- [PR] [GSoC 2026] Kafka Streams runner: separate source poll size from bundle size, expose the session timeout [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/14 09:06:15 UTC, 1 replies.
- [I] [Bug]: Row.toString throws for an ITERABLE field that is not backed by a List [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/14 12:20:50 UTC, 0 replies.
- [PR] Render ARRAY and ITERABLE fields that are not backed by a List [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/14 12:21:19 UTC, 9 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/08/14 12:48:43 UTC, 0 replies.
- Re: [I] [Feature Request]: Print data type of SQL plan [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/14 12:48:46 UTC, 1 replies.
- Re: [I] [Bug]: Artifact materialization can cause a race when multiple callers materialize the same artifact in the same destination. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/14 12:48:48 UTC, 1 replies.
- Re: [I] [Bug]: [Beam Release Automation] Cut release branch workflow doesn't correctly kick off snapshot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/14 12:48:50 UTC, 1 replies.
- [I] [Bug]: SQL AVG rounds to 10 significant digits, flipping the sign on large BIGINT values [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/14 13:17:14 UTC, 0 replies.
- [PR] [GSoC 2026] Kafka Streams runner: an application for measuring instances coming and going [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/14 14:27:29 UTC, 6 replies.
- Re: [PR] [OpenTelemetry] Context propagation for Runner v1 and SimpleDoFnRunner [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/14 14:39:11 UTC, 0 replies.
- Re: [PR] [OpenTelemetry] Add open telemetry dependency to dataflow pipeline runner [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/14 14:39:16 UTC, 0 replies.
- Re: [PR] [OpenTelemetry] Add tracing support to GCP Spanner IO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/14 14:39:26 UTC, 0 replies.
- Re: [PR] [OpenTelemetry] Add tracing support to KafkaIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/14 14:39:36 UTC, 0 replies.
- Re: [PR] [OpenTelemetry] Add tracing support to GCP PubsubIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/08/14 14:39:49 UTC, 0 replies.
- [PR] Fix go GBK load test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/14 16:02:09 UTC, 4 replies.
- [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/14 16:04:18 UTC, 1 replies.
- [I] [Feature Request]: Bound PGBKCVOperation precombine table by in-memory size, not key count [beam] - posted by "nchint (via GitHub)" <gi...@apache.org> on 2026/08/14 17:14:29 UTC, 0 replies.
- [I] [Bug]: Bigtable Python SDK upgrade [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2026/08/14 17:36:50 UTC, 2 replies.
- [PR] Bump cryptography from 48.0.1 to 50.0.0 in Python SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/14 17:46:18 UTC, 7 replies.
- [PR] [GSoC 2026] Requesting permissions for the TestPubSubContext cleanup handler tests [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/14 23:23:07 UTC, 3 replies.
- [PR] Adds support for deading at a given Delta Lake version or timestamp [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/15 00:38:14 UTC, 1 replies.
- Re: [I] [Feature Request]: Define an expansion service jar for Delta Lake [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/15 03:29:03 UTC, 1 replies.
- Re: [I] [Task]: Setup a GCS based delta lake repo for integration testing [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/15 03:30:29 UTC, 1 replies.
- Re: [I] [Task]: Add support for Managed IO (Beam changes) [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/15 03:31:44 UTC, 1 replies.
- [I] The PreCommit Java Debezium IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/15 03:46:25 UTC, 3 replies.
- [PR] Tag the TFRecord write error output with the schema it actually emits [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/15 09:21:40 UTC, 5 replies.
- [PR] Tag the Kafka write error output with the schema it actually emits [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/15 09:57:42 UTC, 5 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/08/15 12:46:35 UTC, 0 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/08/15 12:46:37 UTC, 0 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/08/15 12:46:38 UTC, 0 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/15 12:46:47 UTC, 8 replies.
- [PR] [GSoC 2026] Kafka Streams runner: bound a source poll in time, not only in elements [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/15 14:58:55 UTC, 4 replies.
- [PR] [GSoC 2026] Kafka Streams runner: put the runner behind an opt-in build flag [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/15 14:59:38 UTC, 3 replies.
- [PR] normalize KinesisIO [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/15 17:03:53 UTC, 7 replies.
- Re: [I] [Task]: Also remove META-INF for excluded transitive dependencies in Beam vendored dependencies [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/16 03:59:03 UTC, 0 replies.
- Re: [I] [Task]: Add prism-based integration tests [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/16 04:36:36 UTC, 0 replies.
- [PR] Add Prism integration tests for Delta IO [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/16 04:37:46 UTC, 6 replies.
- [PR] fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/16 09:37:04 UTC, 3 replies.
- [PR] [GSoC 2026] Kafka Streams runner: ask for primitive reads in the Java wrapper [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/16 09:58:07 UTC, 2 replies.
- Re: [I] [Feature Request]: allow consistent slog redirects [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/16 12:46:29 UTC, 0 replies.
- Re: [I] [Task]: Deprecate Python native SpannerIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/16 12:46:32 UTC, 2 replies.
- Re: [I] [Bug]: workflow with a matrix triggered by a phrase show false positive result [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/16 12:46:36 UTC, 1 replies.
- [PR] Bound PGBKCVOperation precombine table by in-memory size (#39754) [beam] - posted by "Dharshika-11 (via GitHub)" <gi...@apache.org> on 2026/08/16 15:41:56 UTC, 1 replies.
- Re: [I] [Task]: Support standard portable coder 'beam:coder:schema:v1' in all SDKs [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/16 18:27:33 UTC, 0 replies.
- Re: [I] [Bug]: Error message for group by coders validation in portable local runner is misleading. [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/16 20:55:10 UTC, 1 replies.
- [I] [Feature Request]: [beam] - posted by "kolban-google (via GitHub)" <gi...@apache.org> on 2026/08/16 22:07:41 UTC, 0 replies.
- [PR] [GSoC 2026] Fix: Remove invalid external ML6 identities to unblock Terraform IAM deployment [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/16 22:42:46 UTC, 3 replies.
- Re: [PR] Implement BeamFileSystemClient for Delta Lake connector [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/16 23:10:00 UTC, 1 replies.
- [PR] [WIP][GSoC 2026] Merge the Kafka Streams runner into master [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/16 23:20:35 UTC, 4 replies.
- [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 03:47:44 UTC, 3 replies.
- [I] The Clean Up GCP Resources job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 03:47:59 UTC, 1 replies.
- [PR] Update wheel requirement from >=0.36.0 to >=0.48.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 04:33:31 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.35 to 1.32.36 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 04:35:07 UTC, 2 replies.
- [PR] Bump github/codeql-action from 4.37.6 to 4.37.7 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 04:35:17 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.79.0 to 1.80.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 04:37:29 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.291.0 to 0.293.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 04:37:41 UTC, 2 replies.
- [PR] Fix PubSub subscription path double-prefix in stale_cleaner (#39772) [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/17 04:45:21 UTC, 4 replies.
- [I] [Feature Request]: Support stateful ParDo, timers and @RequiresTimeSortedInput in the Spark Structured Streaming batch runner [beam] - posted by "f-loris (via GitHub)" <gi...@apache.org> on 2026/08/17 08:28:24 UTC, 2 replies.
- [I] [Bug]: Transient connection error on worker fails all subsequent work items in CassandraIO read [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/08/17 08:51:34 UTC, 4 replies.
- [PR] [GSoC 2026] Kafka Streams runner: shorten comments, and fix the license header and Python formatting [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/17 08:59:21 UTC, 1 replies.
- [I] [Bug]: Java FlinkRunner OrderedListState silently overwrites duplicate elements sharing same timestamps [beam] - posted by "vemuriraghu (via GitHub)" <gi...@apache.org> on 2026/08/17 09:15:26 UTC, 1 replies.
- [PR] fix: preserve duplicate same-timestamp elements in FlinkOrderedListState [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/17 09:26:53 UTC, 1 replies.
- [PR] Build Kafka Streams runner during javaPreCommit (#18479) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/08/17 09:54:07 UTC, 4 replies.
- [PR] [WIP] Merge Kafka Streams Runner skeleton [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/08/17 10:08:10 UTC, 1 replies.
- [PR] [GSoC 2026] Kafka Streams runner: update the CHANGES.md entry [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/17 10:20:58 UTC, 1 replies.
- [PR] [DO NOT MERGE] Feat/18479 kafka streams runner skeleton master merged [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/08/17 11:59:01 UTC, 2 replies.
- [PR] Fix stale broken cluster connection in CassandraIO [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/08/17 12:02:46 UTC, 2 replies.
- Re: [PR] [IcebergIO] Let hash distribution mode spill over if file gets too large [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 12:46:53 UTC, 2 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/08/17 12:46:56 UTC, 0 replies.
- Re: [I] [Feature Request]: Simplify schema fetching in ClickHouseIO by leveraging Java Client v2's built-in getTableSchema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 12:47:01 UTC, 1 replies.
- Re: [I] [Task]: Migrate from SourceFunction API to Source API for Flink runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 12:47:06 UTC, 1 replies.
- Re: [I] [Bug]: grpc: error while marshaling: string field contains invalid UTF-8 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 12:47:11 UTC, 1 replies.
- Re: [I] [Bug]: Unpin spanner client version until the version from libraries-bom catches up [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 12:47:15 UTC, 1 replies.
- [I] [Bug]: [beam] - posted by "c-broggy (via GitHub)" <gi...@apache.org> on 2026/08/17 13:09:41 UTC, 0 replies.
- [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/17 15:20:27 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 "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/17 15:23:27 UTC, 0 replies.
- [PR] Merge master into feat/18479-kafka-streams-runner-skeleton [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/17 15:54:39 UTC, 3 replies.
- [PR] bigtable: Set Apache Beam user agent for Python BigtableIO write client [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2026/08/17 16:39:43 UTC, 2 replies.
- Re: [PR] fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 17:10:06 UTC, 2 replies.
- [PR] [runners-spark] Support stateful ParDo in the Structured Streaming batch runner [beam] - posted by "f-loris (via GitHub)" <gi...@apache.org> on 2026/08/17 19:26:55 UTC, 8 replies.
- [PR] Fix Duplicated Subscription Path in stale_cleaner.py [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/17 20:24:04 UTC, 0 replies.
- Re: [I] The PostCommit Java ValidatesRunner ULR job is flaky [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/17 20:54:04 UTC, 1 replies.
- Re: [PR] [GSoC 2026] Fix Duplicated Subscription Path in stale_cleaner.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/17 21:09:08 UTC, 1 replies.
- [PR] Fix FlinkOrderedListState: preserve elements with same timestamp [beam] - posted by "waterWang (via GitHub)" <gi...@apache.org> on 2026/08/17 21:56:52 UTC, 1 replies.
- [PR] Updates Dataflow Python container [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/08/18 04:14:30 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.5 to 1.43.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 04:24:52 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.52.0 to 1.53.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 04:24:56 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.1 to 1.107.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 04:26:07 UTC, 2 replies.
- [PR] [Python] Improve GroupByKey coder validation errors [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/08/18 04:26:37 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.36 to 1.32.37 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 04:27:19 UTC, 2 replies.
- [PR] Bump golang.org/x/net from 0.57.0 to 0.58.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 04:27:25 UTC, 2 replies.
- [PR] Fix stale broken cluster connection in CassandraIO (#39788) [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/08/18 09:45:29 UTC, 13 replies.
- Re: [I] [Feature Request]: Make SerializableConfiguration cacheable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 12:47:10 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/08/18 12:47:24 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/08/18 12:47:26 UTC, 0 replies.
- [PR] Portable Time type (Java + model changes) [beam] - posted by "PDGGK (via GitHub)" <gi...@apache.org> on 2026/08/18 14:09:03 UTC, 7 replies.
- [PR] Update SKILLs based on review practice [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/18 14:58:27 UTC, 6 replies.
- [PR] Support secret manager for jdbcio in python, java and yaml [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/18 18:01:38 UTC, 0 replies.
- [PR] Remove nullness suppression in trigger implementation [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/18 18:46:32 UTC, 4 replies.
- Re: [PR] [GSoC-273] Fixing the github action Unmanaged Service Account Keys [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2026/08/18 18:56:18 UTC, 2 replies.
- Re: [PR] Refactor Java Secret classes to align with Python SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/18 19:15:58 UTC, 13 replies.
- [PR] [IcebergIO] Ensure compliance with table encryption [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/08/18 19:20:09 UTC, 2 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.26.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 20:45:30 UTC, 3 replies.
- [PR] Bump github.com/moby/go-archive from 0.2.0 to 0.3.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/18 21:26:20 UTC, 2 replies.
- Re: [I] [Bug]: Watermark age for `PeriodicImpulse` regression in v2.74.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/18 21:37:33 UTC, 1 replies.
- [PR] [GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/19 02:28:49 UTC, 8 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/19 04:24:26 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.4 to 2.14.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/19 04:24:36 UTC, 2 replies.
- [PR] Bump google.golang.org/protobuf from 1.36.11 to 1.36.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/19 04:24:45 UTC, 2 replies.
- [PR] Bump ClassGraph from 4.8.162 to 4.8.192 [beam] - posted by "kellen (via GitHub)" <gi...@apache.org> on 2026/08/19 08:34:06 UTC, 4 replies.
- Re: [PR] [Prism] Add more logging to debug [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/19 09:28:42 UTC, 0 replies.
- [PR] Fix race condition in getSession() [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/08/19 09:56:58 UTC, 1 replies.
- [PR] Set getSession to synchronized to avoid race conditions [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2026/08/19 10:23:29 UTC, 2 replies.
- Re: [I] [Bug]: Eliminate field sorting in Beam schema-aware transforms which can result in compatibility issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/19 12:47:13 UTC, 1 replies.
- Re: [I] [Feature Request]: Upgrade to Iceberg >1.7.0 and support timestamp nano types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/19 12:47:17 UTC, 1 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/08/19 12:47:28 UTC, 0 replies.
- [PR] JmsIO yaml [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/19 14:12:37 UTC, 8 replies.
- [PR] [#18194] Include all per-module JaCoCo execution data in jacocoTestReport [beam] - posted by "ulofiai (via GitHub)" <gi...@apache.org> on 2026/08/19 14:50:11 UTC, 5 replies.
- [PR] bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing [beam] - posted by "mutianf (via GitHub)" <gi...@apache.org> on 2026/08/19 16:15:48 UTC, 2 replies.
- Re: [PR] [GSoC-273] Implement TestPubsubContext for Python GCP Integration Tests [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2026/08/19 16:45:48 UTC, 1 replies.
- [I] [Bug]: Spanner Change Streams reading have potential data loss when the dataflow worker has high CPU utilization [beam] - posted by "jiangzzhu (via GitHub)" <gi...@apache.org> on 2026/08/19 18:08:45 UTC, 3 replies.
- [I] [Bug]: Spark streaming drops the stored watermark of a source with no update in a batch [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/20 02:20:33 UTC, 2 replies.
- [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/08/20 02:21:28 UTC, 3 replies.
- [I] [Bug]: Spark streaming fires processing-time timers in reverse timestamp order [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/20 02:21:44 UTC, 2 replies.
- [PR] [Spark] Fire processing-time timers in timestamp order [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/20 02:22:25 UTC, 6 replies.
- [PR] [GSoC-273] Feat: Integrate TestPubsubContext to prevent Pub/Sub resource leaks and expand stale cleaner scope [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/20 03:53:37 UTC, 11 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/20 04:23:02 UTC, 4 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/20 04:23:28 UTC, 3 replies.
- [PR] Bump docker/setup-buildx-action from 4.2.0 to 4.3.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/20 04:25:43 UTC, 3 replies.
- [PR] [KafkaIO] Use consumer position and lag to estimate end offsets in KafkaUnboundedReader [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/08/20 08:33:38 UTC, 2 replies.
- Re: [I] [Task]: Update GitHub Actions Self-Hosted Runners to Ubuntu 24.04 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/20 12:47:23 UTC, 1 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/08/20 12:47:45 UTC, 0 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/08/20 12:47:48 UTC, 0 replies.
- [PR] [CP] bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing (#39820) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/20 13:46:59 UTC, 3 replies.
- [PR] Make primary channel failover timeout configurable (#39646) [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/08/20 16:03:33 UTC, 2 replies.
- [PR] Update managed-io.md for release 2.76.0-RC3 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/20 17:57:01 UTC, 2 replies.
- [PR] Support Secret Manager in JdbcIO for Java, Python and YAML [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/20 19:27:59 UTC, 8 replies.
- Re: [PR] Adds support for reading at a given Delta Lake version or timestamp [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/20 20:51:41 UTC, 5 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/08/20 21:41:50 UTC, 2 replies.
- [PR] AddFiles: regenerate name mapping, read footers once, error helper [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/20 22:58:11 UTC, 3 replies.
- [PR] Update google-cloud-bigtable [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/21 06:24:49 UTC, 2 replies.
- [PR] Cherrypick #39837: Update google-cloud-bigtable version [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/21 12:34:35 UTC, 1 replies.
- Re: [I] [Task]: Build a cleaner for assets in the GCP test environment [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/21 12:47:14 UTC, 1 replies.
- Re: [I] [Feature Request]: DICOM IO `delete` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/21 12:47:29 UTC, 0 replies.
- Re: [I] [Feature request] Consider installing the same artifact in Beam Python RC Docker containers as is being published to PyPi [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/21 12:47:31 UTC, 1 replies.
- Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/21 13:05:55 UTC, 1 replies.
- [PR] Update managed-io.md for release 2.76.0-RC4 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/21 13:13:02 UTC, 2 replies.
- [I] [Feature Request]: ClickHouseIO: Add Decimal(P, S) support for fixed-point columns [beam] - posted by "tomnewton (via GitHub)" <gi...@apache.org> on 2026/08/21 13:30:46 UTC, 3 replies.
- Re: [I] [Prism] Watermark deadlock when unbounded source is initially empty [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/21 14:24:20 UTC, 0 replies.
- [I] [Bug]: KafkaWriteSchemaTransformProvider write messages to route to a single partition [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/21 15:36:37 UTC, 1 replies.
- [I] [Bug]: Bigtable segment truncation creates invalid range when open end key is startKey + null byte [beam] - posted by "aa-dit-yuh (via GitHub)" <gi...@apache.org> on 2026/08/21 17:26:36 UTC, 1 replies.
- [PR] [Bigtable] Fix Bigtable segment truncation when open end key is startKey + null byte (#39842) [beam] - posted by "aa-dit-yuh (via GitHub)" <gi...@apache.org> on 2026/08/21 17:28:04 UTC, 4 replies.
- [PR] Fix KafkaIO wrtie SchemaTransform parallelism [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/21 17:55:22 UTC, 2 replies.
- [PR] fix pickling issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/21 18:42:28 UTC, 1 replies.
- [PR] ClickHouseIO: Add Decimal(P, S) support for fixed-point columns [beam] - posted by "tomnewton (via GitHub)" <gi...@apache.org> on 2026/08/21 20:30:07 UTC, 2 replies.
- [PR] [GSoC 2026] Kafka Streams runner: say what the Python side is, and is not [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/22 12:03:26 UTC, 1 replies.
- Re: [I] [Feature Request]: Rewrite pytest markers to avoid including ML test suites into a catch-all postcommit suite. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/22 12:46:31 UTC, 1 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/08/22 12:46:47 UTC, 0 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/08/22 12:46:49 UTC, 0 replies.
- [I] [Bug]: Prism ignores the resume delay of self-checkpointing SDFs, so polling SDFs busy-spin [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/22 13:23:40 UTC, 1 replies.
- [PR] [Prism] Honor the resume delay of self-checkpointing SDF residuals [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/08/22 13:24:08 UTC, 11 replies.
- Re: [PR] Merge Kafka Streams Runner skeleton (#18479) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/22 13:42:49 UTC, 4 replies.
- [PR] Install Cloud Spanner emulator component in Go PreCommit CI [beam] - posted by "christogav (via GitHub)" <gi...@apache.org> on 2026/08/22 15:15:56 UTC, 2 replies.
- Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] - posted by "christogav (via GitHub)" <gi...@apache.org> on 2026/08/22 15:18:35 UTC, 3 replies.
- [PR] fix(dataframe): handle pandas dimensionality reduction in .xs() for single-item matches [beam] - posted by "ManvithPanyam (via GitHub)" <gi...@apache.org> on 2026/08/22 15:40:32 UTC, 6 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/22 21:38:40 UTC, 3 replies.
- [PR] Setup a writable gcloud SDK before installing Spanner emulator component [beam] - posted by "christogav (via GitHub)" <gi...@apache.org> on 2026/08/22 22:22:26 UTC, 0 replies.
- Re: [PR] fix: Setup a writable gcloud SDK before installing Spanner emulator component [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/22 23:06:32 UTC, 2 replies.
- [PR] Revert "[GSoC-273] Feat: Integrate TestPubsubContext to prevent Pub/Sub resource leaks and expand stale cleaner scope" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/23 02:47:37 UTC, 4 replies.
- [PR] [GSoC 2026] Publish the Kafka Streams runner to nightly snapshots [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/08/23 09:05:32 UTC, 1 replies.
- Re: [I] [Feature Request]: Implement Smart Bucketing Strategies for RunInference [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/23 12:46:31 UTC, 1 replies.
- Re: [I] [Bug]: HBase read could stuck at HBaseReader.advance indefinitely [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/23 12:46:46 UTC, 1 replies.
- [I] The PreCommit Go job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/23 15:39:04 UTC, 4 replies.
- [PR] [GSoX-273] Feat: expanding the cleanup rules for orphaned resources [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/23 18:45:59 UTC, 1 replies.
- [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:35:11 UTC, 2 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.7.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:35:32 UTC, 3 replies.
- [PR] Bump actions/checkout from 6 to 7 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:36:16 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.43 to 1.22.44 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:36:40 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/storage from 1.64.0 to 1.65.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:36:58 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.51.0 to 1.51.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:37:13 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.83.0 to 1.83.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:37:18 UTC, 3 replies.
- [PR] Bump github/codeql-action from 4.37.7 to 4.37.8 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:37:44 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.107.2 to 1.107.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 04:38:57 UTC, 4 replies.
- [I] [Flink] Cache materialized side inputs in DataStream batch execution [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/08/24 07:25:54 UTC, 1 replies.
- [PR] [Flink] Cache batch side input materialization in Flink 2 [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/08/24 07:26:42 UTC, 5 replies.
- [PR] use LocalStack TLS hostname in Kinesis YAML IT [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/24 09:18:23 UTC, 2 replies.
- [I] IAM Policy Non-Compliance Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 09:18:43 UTC, 0 replies.
- [I] [IAC_DRIFT_IAM_USER] Action Required: Unauthorized IAM Users Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 09:18:45 UTC, 0 replies.
- [I] [IAC_DRIFT_SA_KEY] Action Required: Unauthorized Service Accounts Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 09:18:59 UTC, 1 replies.
- [I] [SECURITY] Action Required: Unmanaged Service Account Keys Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 09:19:03 UTC, 1 replies.
- [I] [Flink] Make bounded-source split assignment configurable by size [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/08/24 10:03:54 UTC, 1 replies.
- [PR] [Flink] Select bounded-source split assignment by estimated size [beam] - posted by "pkuzmickas (via GitHub)" <gi...@apache.org> on 2026/08/24 10:10:11 UTC, 4 replies.
- [I] [Feature Request]: SolaceIO: Support binary content data payload [beam] - posted by "ngibanel (via GitHub)" <gi...@apache.org> on 2026/08/24 12:19:38 UTC, 2 replies.
- Re: [I] [Feature Request]: Batch Stateful DoFns support in UnifiedWorker: Omit state commits implemented [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 12:47:25 UTC, 1 replies.
- Re: [I] [Bug]: Ongoing operation in Bigtable write step [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/24 12:47:31 UTC, 1 replies.
- [PR] SolaceIO: support binary content (text, bytes) data payload [beam] - posted by "ngibanel (via GitHub)" <gi...@apache.org> on 2026/08/24 13:49:53 UTC, 8 replies.
- [PR] Revert "Install Cloud Spanner emulator component in Go PreCommit CI" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/24 14:00:47 UTC, 3 replies.
- Re: [PR] [GSoC-273] Feat: expanding the cleanup rules for orphaned resources [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/24 15:59:16 UTC, 4 replies.
- [I] [Task]: Upgrade actions/setup-java to v6 [beam] - posted by "brunoborges (via GitHub)" <gi...@apache.org> on 2026/08/24 18:55:20 UTC, 2 replies.
- [PR] Upgrade actions/setup-java to v6 [beam] - posted by "brunoborges (via GitHub)" <gi...@apache.org> on 2026/08/24 18:56:56 UTC, 2 replies.
- [I] The CloudML Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 00:49:12 UTC, 5 replies.
- [PR] Bump github.com/aws/smithy-go from 1.27.8 to 1.27.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 04:23:38 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.80.0 to 1.81.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 04:23:54 UTC, 2 replies.
- Re: [I] [Task]: Kafka IO: Remove custom latency timer in ReadFromKafkaDoFn in favor Kafka's native metrics [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 12:47:09 UTC, 1 replies.
- Re: [I] [Failing Test]: Playground Frontend integrationTest_standalone_miscellaneous_ui [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 12:47:11 UTC, 1 replies.
- Re: [I] [Bug]: Behavior change between Beam 2.66 and 2.71 causing severe buffering [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 12:47:13 UTC, 1 replies.
- Re: [I] [Bug]: ReadFromKafka YAML transform cannot specify JSON schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 12:47:16 UTC, 2 replies.
- Re: [I] [Bug]: PubsubIO used in batch incorrect batch cutoff size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/25 12:47:39 UTC, 0 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/08/25 12:47:43 UTC, 0 replies.
- [PR] Add Vertex Model Monitoring to CHANGES.md [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/25 13:57:09 UTC, 3 replies.
- [PR] Implement Iceberg Table Metadata Driver transform [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/25 15:04:32 UTC, 10 replies.
- [PR] prevent cloudML TFT extras from replacing the SDK under test [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/25 16:13:02 UTC, 4 replies.
- [PR] Fix ZeroDivisionError at initial invocation of monitoring_info when there is no work yet [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/25 19:28:34 UTC, 2 replies.
- [PR] [PubsubIO] Account for message metadata in bounded write batch size [beam] - posted by "1fanwang (via GitHub)" <gi...@apache.org> on 2026/08/25 20:20:44 UTC, 1 replies.
- [PR] Upgrade GCP Libraries BOM to 26.87.0 [beam] - posted by "lqiu96 (via GitHub)" <gi...@apache.org> on 2026/08/25 20:49:50 UTC, 9 replies.
- [PR] fix(beam): guard jinja_variable_flags collision with pipeline options [beam] - posted by "shoemoney (via GitHub)" <gi...@apache.org> on 2026/08/25 20:53:10 UTC, 6 replies.
- [PR] [Gemini] Migrate Python BigQuery away from apitools, deprecate old route [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/08/25 21:39:30 UTC, 2 replies.
- [PR] Bump github.com/fsouza/fake-gcs-server from 1.55.1 to 1.56.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/26 04:23:27 UTC, 3 replies.
- [PR] Update cython requirement from <4,>=3.2.6 to >=3.3.0,<4 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/26 04:23:41 UTC, 4 replies.
- [PR] Allow referencing both issues and PRs in release notes. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/08/26 11:38:19 UTC, 3 replies.
- Re: [I] Duplicate ShardedKey implementations in core module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/26 12:47:36 UTC, 0 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/08/26 12:47:38 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/08/26 12:47:57 UTC, 0 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/08/26 12:48:01 UTC, 0 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/08/26 12:48:03 UTC, 0 replies.
- [PR] Fix nullness in BigQueryIO [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/26 14:39:20 UTC, 3 replies.
- [PR] [GSoC-273] Clarify service account key issue reports [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/08/26 15:38:57 UTC, 2 replies.
- Re: [I] Improve scalability of the Watch transform [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/26 15:57:54 UTC, 0 replies.
- [I] [Bug]: Left frame no longer showing in Javadoc [beam] - posted by "mouyang (via GitHub)" <gi...@apache.org> on 2026/08/26 16:18:56 UTC, 2 replies.
- [PR] AddFiles: extract bounded async task plumbing and Parquet footer reads [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/26 18:33:34 UTC, 7 replies.
- [I] [Bug]: Spiky Java Memory in 2.74-75 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/26 19:24:14 UTC, 1 replies.
- [PR] Update CHANGES.md with new known issues [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/26 19:25:32 UTC, 4 replies.
- [PR] Update Beam website roadmap pages [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/26 20:42:49 UTC, 3 replies.
- [I] [Bug]: MongoDbIO read splitting fails for collections with non-ObjectId _id (splitKeysToFilters hardcodes ObjectId) [beam] - posted by "ogiogidayo (via GitHub)" <gi...@apache.org> on 2026/08/27 02:50:26 UTC, 3 replies.
- [PR] [#39900] Fix MongoDbIO read splitting to preserve non-ObjectId _id types [beam] - posted by "ogiogidayo (via GitHub)" <gi...@apache.org> on 2026/08/27 04:11:10 UTC, 3 replies.
- [PR] Bump github.com/fsouza/fake-gcs-server from 1.56.0 to 1.56.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 04:24:07 UTC, 2 replies.
- [PR] Bump actions/setup-java from 5 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 04:24:45 UTC, 2 replies.
- [PR] Pin googleapis-common-protos<1.70 for py310-tensorflow-212 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/27 12:49:30 UTC, 0 replies.
- [PR] Fix PostCommit PortableJar Flink job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/08/27 12:54:02 UTC, 5 replies.
- [PR] [#36841] Add streaming dispatch seam to the Spark Structured Streaming runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/08/27 13:26:43 UTC, 4 replies.
- [PR] Multi bucket catalog [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/27 13:36:00 UTC, 0 replies.
- Re: [I] [Bug]: Some methods on DeferredSeries and DeferredDataFrame don't work right when returning single items [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:16:39 UTC, 1 replies.
- Re: [I] [Bug]: pickle_library option is ignored [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:16:43 UTC, 1 replies.
- Re: [I] [Bug][prism]: Support receiving Java's CoGBKList Result [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:16:48 UTC, 1 replies.
- Re: [I] [Feature Request]: Splittable DoFn Kafka reader in Python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:16:52 UTC, 1 replies.
- Re: [I] [Bug]: Postgres not connecting in apache beam with go sdk [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:16:56 UTC, 1 replies.
- Re: [I] [Bug]: Dataflow keeps retrying to obtain an already deleted BigQuery dataset [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/27 16:17:00 UTC, 1 replies.
- [I] [Feature Request]: Allow disable user metrics in Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/27 18:14:29 UTC, 1 replies.
- [PR] Beam SQL: name query composites after what was fused into them [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/08/27 19:32:14 UTC, 0 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/08/27 20:53:57 UTC, 2 replies.
- [I] [Feature Request]: Wait.on for Go SDK [beam] - posted by "vgough (via GitHub)" <gi...@apache.org> on 2026/08/27 23:37:23 UTC, 5 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 01:03:30 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 01:04:59 UTC, 1 replies.
- [PR] Fix Flink miniCluster jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/28 01:47:57 UTC, 2 replies.
- Re: [PR] Fix PostCommit Python Dependency job [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/28 01:48:54 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.94.0 to 1.95.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 04:24:29 UTC, 2 replies.
- Re: [I] Mongo document read with non hex objectid [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/28 13:13:26 UTC, 2 replies.
- [I] [Bug]: Mixed data types in _id field causing pipeline failures (SDK 2.53.0) [beam] - posted by "MS-Kinguin (via GitHub)" <gi...@apache.org> on 2026/08/28 13:15:30 UTC, 0 replies.
- [PR] Update commons pool2 2.13.1 [beam] - posted by "ashwin-sampathkumar (via GitHub)" <gi...@apache.org> on 2026/08/28 13:49:24 UTC, 1 replies.
- Re: [PR] Fix/add experiment refactor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 16:39:31 UTC, 0 replies.
- Re: [I] [Feature Request]: Allow users to modify _BeamArgumentParser behavior [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 16:39:38 UTC, 1 replies.
- Re: [I] [Bug]: Flink fails with "cannot handle nodes with more than 64 outputs" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 16:39:42 UTC, 1 replies.
- Re: [I] [Bug]: Type inference failure with closure creation. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 16:39:46 UTC, 1 replies.
- Re: [I] [Feature Request]: Reduce expense of calculating quantiles [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 16:39:50 UTC, 1 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/08/28 16:39:58 UTC, 0 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/08/28 16:40:02 UTC, 0 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/08/28 16:40:04 UTC, 0 replies.
- [PR] upgrade grpc to 1.82.1 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/28 18:23:59 UTC, 0 replies.
- Re: [PR] Fix artifact staging filenames on Windows [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/28 19:02:35 UTC, 0 replies.
- [PR] Fix artifact staging windows filename [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/28 21:35:33 UTC, 7 replies.
- Re: [PR] upgrade grpc to 1.82.1 for test infra and playground [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/28 21:59:14 UTC, 0 replies.
- [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam] - posted by "2akouwu (via GitHub)" <gi...@apache.org> on 2026/08/29 10:22:09 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/08/29 12:38:47 UTC, 0 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/08/29 12:39:01 UTC, 0 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/08/29 12:39:03 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Java 14 records in `SchemaCoder` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/29 12:39:04 UTC, 0 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/08/29 12:39:05 UTC, 0 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/08/29 12:39:07 UTC, 0 replies.
- [PR] Fix flaky Playground local cache test [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/29 22:46:45 UTC, 1 replies.
- [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/30 06:10:01 UTC, 8 replies.
- Re: [I] [Bug]: Beam tag is not working properly [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:39:47 UTC, 0 replies.
- Re: [I] [Feature Request]: Katas need new platform/host [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:39:50 UTC, 0 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/08/30 12:39:51 UTC, 0 replies.
- Re: [I] [Bug]: [Doc] Beam Capability Matrix space [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:39:53 UTC, 0 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/08/30 12:39:55 UTC, 0 replies.
- Re: [I] [Bug]: condition missed after a unnest [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:39:57 UTC, 0 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/08/30 12:39:59 UTC, 0 replies.
- Re: [I] [Feature Request]: Retry policies for ParDo [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:40:01 UTC, 0 replies.
- Re: [I] [Task]: Add Criteo perf test for MLTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:40:03 UTC, 0 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/08/30 12:40:04 UTC, 0 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/08/30 12:40:06 UTC, 0 replies.
- Re: [I] [Bug]: Update or Remove Integrations page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:40:08 UTC, 0 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/08/30 12:40:10 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/08/30 12:40:11 UTC, 0 replies.
- Re: [I] [Task][Go SDK]: Determine canonical local temp directory. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/30 12:40:14 UTC, 0 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/08/30 12:40:15 UTC, 0 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/08/30 12:40:17 UTC, 0 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/08/30 12:40:19 UTC, 0 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/08/30 12:40:21 UTC, 0 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/08/30 12:40:23 UTC, 0 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/08/30 12:40:24 UTC, 0 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/08/30 12:40:26 UTC, 0 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/08/30 12:40:29 UTC, 0 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/08/30 12:40:30 UTC, 0 replies.
- [PR] Deflake JmsIO authentication tests [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/08/30 13:05:31 UTC, 2 replies.
- Re: [I] Speed up merge_accumulators for ApproximateUniqueGlobally [beam] - posted by "sliortega295-ops (via GitHub)" <gi...@apache.org> on 2026/08/30 15:00:01 UTC, 0 replies.
- [PR] [Python] Speed up ApproximateUnique accumulator merging [beam] - posted by "sliortega295-ops (via GitHub)" <gi...@apache.org> on 2026/08/30 16:36:21 UTC, 2 replies.
- Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] - posted by "Gaurav598 (via GitHub)" <gi...@apache.org> on 2026/08/30 21:16:57 UTC, 0 replies.
- [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] - posted by "akshayjadiyanv (via GitHub)" <gi...@apache.org> on 2026/08/30 23:39:10 UTC, 10 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:35:33 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:35:39 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.38 to 1.33.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:37:18 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.293.0 to 0.294.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:37:31 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.83.1 to 1.83.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:37:37 UTC, 3 replies.
- [PR] Bump github/codeql-action from 4.37.8 to 4.37.9 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:38:16 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.7 to 1.45.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:39:04 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.5 to 2.14.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 04:39:19 UTC, 2 replies.
- [I] [ACCOUNT_KEYS_POLICY] Action Required: Service Account Policy Drift [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 09:16:23 UTC, 0 replies.
- [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/08/31 09:16:29 UTC, 0 replies.
- Re: [PR] Fix flaky Playground local cache tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/31 11:18:33 UTC, 0 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/08/31 12:45:49 UTC, 0 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/08/31 12:45:51 UTC, 0 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/08/31 12:45:51 UTC, 0 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/08/31 12:45:53 UTC, 0 replies.
- Re: [I] [Feature Request]: Support pyarrow RecordBatch for MLTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:45:54 UTC, 0 replies.
- Re: [I] [Bug]: Read from datastore with inequality filters [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:45:56 UTC, 0 replies.
- Re: [I] [Bug]: 16177 has type numpy.int64, but expected one of: bytes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:45:58 UTC, 0 replies.
- Re: [I] [Feature Request]: Create a "Try Apache Beam YAML" landing page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:45:59 UTC, 0 replies.
- Re: [I] [Failing Test]: Python GCP xlang fails if a node run two test concurrently [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:46:00 UTC, 0 replies.
- Re: [I] [Task]: Remove archaic PubSubSource and PubSubSink [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:46:02 UTC, 0 replies.
- Re: [I] [Task]: Enable Checker framework on `it` module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:46:03 UTC, 0 replies.
- Re: [I] [Failing Test]: beam_PostRelease_Python_Candidate script broken [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/08/31 12:46:05 UTC, 0 replies.
- [PR] AddFiles: read side of the schema pre-pass [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/08/31 13:15:38 UTC, 0 replies.
- [PR] Treat a 404 from BigQuery table and dataset deletes as success [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/08/31 13:56:02 UTC, 1 replies.
- Re: [I] [Bug]: BigqueryIO: 404 on delete should be a success [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/08/31 13:56:08 UTC, 0 replies.
- Re: [I] [Bug]: Portable Java pipelines hang forever in artifact staging on Windows, staged file name embeds environment id colons [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/08/31 14:20:51 UTC, 0 replies.
- [PR] [wip] formatting [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/31 15:24:51 UTC, 1 replies.
- [PR] [wip] formatting [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/08/31 15:41:01 UTC, 0 replies.
- [PR] Port Wait.On to the Go SDK [beam] - posted by "vgough (via GitHub)" <gi...@apache.org> on 2026/08/31 17:49:00 UTC, 1 replies.
- [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/08/31 18:23:54 UTC, 1 replies.
- Re: [I] [Bug]: BigQueryIO.read() requires GCS tempLocation when using BigQuery Emulator [beam] - posted by "mxtymoshyk (via GitHub)" <gi...@apache.org> on 2026/08/31 19:07:25 UTC, 0 replies.
- [I] [Bug]: Latest.Globally() issues in global window [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/31 19:17:08 UTC, 0 replies.
- [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/08/31 19:20:39 UTC, 2 replies.
- Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/31 19:21:59 UTC, 0 replies.
- Re: [I] [Feature Request]: Use unique id for Python BigQueryIO [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/31 19:22:25 UTC, 0 replies.
- Re: [I] Python SDK BigQuery `schemaUpdateOptions` [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/08/31 19:23:04 UTC, 0 replies.
- [PR] Refactor GCP related secret classes and tests to extensions/google-cloud-platform-core [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/08/31 20:10:40 UTC, 0 replies.
- [PR] normalize firestoreIO [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/08/31 20:40:27 UTC, 0 replies.
- [I] [Bug]: PickleCoder/_MemoizingPickleCoder.as_deterministic_coder() raises TypeError [beam] - posted by "AmirF194 (via GitHub)" <gi...@apache.org> on 2026/08/31 22:06:19 UTC, 1 replies.
- [PR] Fix PickleCoder.as_deterministic_coder() raising TypeError [beam] - posted by "AmirF194 (via GitHub)" <gi...@apache.org> on 2026/08/31 22:07:28 UTC, 1 replies.
- Re: [I] [Failing Test]: Milvus RAG integration tests fail consistently in beam_PreCommit_Python_ML (py3.13) [beam] - posted by "linhongyu510 (via GitHub)" <gi...@apache.org> on 2026/08/31 22:27:26 UTC, 0 replies.