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

---

- [PR] Multikey autofix [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/01 06:18:49 UTC, 0 replies.
- [PR] run setup before release checkout [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/01 07:43:22 UTC, 4 replies.
- Re: [PR] [Python] Add UnboundedSource SDF wrapper (#19137) [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/06/01 07:50:27 UTC, 15 replies.
- Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/01 08:46:59 UTC, 9 replies.
- Re: [PR] [Dataflow Streaming] Prepare BoundedQueueExecutor for MultiKey bundles [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/01 08:59:06 UTC, 4 replies.
- Re: [PR] [Dataflow Streaming] Enable state tag encoding v2 [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/01 09:02:37 UTC, 1 replies.
- Re: [PR] support generics in from row and to row conversions [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2026/06/01 09:47:58 UTC, 9 replies.
- [PR] Bump nanasess/setup-chromedriver from 2 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:12:18 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.102.1 to 1.102.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:12:24 UTC, 1 replies.
- [PR] Bump github.com/golang-cz/devslog from 0.0.15 to 0.0.16 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:12:29 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.21 to 1.22.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:13:44 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.8 to 1.41.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:14:55 UTC, 1 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.11.0 to 1.12.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 10:15:08 UTC, 1 replies.
- [I] The Republish Released Docker Images job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 11:18:55 UTC, 1 replies.
- Re: [PR] Implements the Delta Lake source with support for splitting [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/06/01 13:53:02 UTC, 8 replies.
- Re: [I] [GSoC 2026] Kafka Streams Runner — translation framework + Impulse translator [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/06/01 14:09:36 UTC, 2 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:05 UTC, 6 replies.
- Re: [PR] [Go SDK] Add GroupIntoBatches transform (#19868) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:14 UTC, 5 replies.
- Re: [PR] [#38059] Fix GCS glob matching to support ** and / in object names [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:16 UTC, 6 replies.
- Re: [PR] datastore: Same key in mutation batch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:23 UTC, 5 replies.
- Re: [PR] RedisIO support PCollection of [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:25 UTC, 5 replies.
- Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:31 UTC, 6 replies.
- Re: [PR] Added flag for overriding artifact hostname [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 14:20:38 UTC, 1 replies.
- Re: [PR] Add Worker hashes for Golang [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/06/01 17:02:20 UTC, 2 replies.
- Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/06/01 17:54:26 UTC, 18 replies.
- [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/01 19:26:04 UTC, 9 replies.
- [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/01 20:59:34 UTC, 12 replies.
- [PR] Updates Beam master container tags for Dataflow [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:03:54 UTC, 2 replies.
- Re: [PR] Enable connection pooling by default [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:11:32 UTC, 1 replies.
- Re: [PR] Fix truncating file handle [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:18:19 UTC, 1 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:19:15 UTC, 1 replies.
- Re: [PR] Update Beam website to release 2.74.0 [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/06/01 23:21:39 UTC, 2 replies.
- Re: [PR] feat: Add LogElements transform to Java SDK [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:23:28 UTC, 5 replies.
- Re: [I] [Bug]: IcebergIO write fails with "Null value set on non-nullable field keyMetadata" — @Nullable not detected in SerializableDataFile schema [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/01 23:27:34 UTC, 0 replies.
- [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/02 09:06:36 UTC, 24 replies.
- Re: [PR] [WIP] Multikey [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/02 09:09:47 UTC, 0 replies.
- [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/02 11:38:34 UTC, 4 replies.
- [PR] Jsonpick ver [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/06/02 12:30:40 UTC, 2 replies.
- Re: [PR] Bump jsonpickle upper bound. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/06/02 12:50:59 UTC, 8 replies.
- [I] [Bug]: Fix num_storage_api_streams for batch [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/02 13:07:58 UTC, 1 replies.
- Re: [PR] [wip] js2py to quickjs [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/02 13:17:53 UTC, 0 replies.
- Re: [PR] js2py to quickjs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 13:19:11 UTC, 1 replies.
- Re: [PR] add datadog io normalization and yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/02 13:21:29 UTC, 5 replies.
- Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 13:36:49 UTC, 5 replies.
- Re: [I] [Failing Test]: A few failed tests for TestStream with keyed elements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 13:49:13 UTC, 1 replies.
- Re: [I] [Failing Test]: Dataflow V2 VR Streaming Flakiness due to timeout close worker pool [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 13:49:23 UTC, 1 replies.
- [I] [Feature Request]: add drain() method to PipelineResult [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/02 14:09:29 UTC, 1 replies.
- [PR] [yaml] - mongodb read normalization [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/02 14:27:26 UTC, 32 replies.
- [PR] [OpenTelemetry] Add gcp otel auth extension [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/02 14:49:48 UTC, 6 replies.
- [I] [Bug]: Beam YAML documentation not reflecting full parameters. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2026/06/02 15:09:34 UTC, 3 replies.
- Re: [PR] Migrate to Google Cloud Dataflow Client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/02 15:40:56 UTC, 0 replies.
- Re: [I] [Task]: Migrate Dataflow v1b3 Client to Python Client Library [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/02 15:41:00 UTC, 0 replies.
- [PR] Cdc read 3 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/02 16:21:19 UTC, 0 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 16:48:36 UTC, 13 replies.
- [PR] Fix BigQuery Storage Write API stream count for bounded writes [beam] - posted by "Akshatsharma2205 (via GitHub)" <gi...@apache.org> on 2026/06/02 16:52:16 UTC, 16 replies.
- [PR] Fix BigQuery Storage Write API stream count for batch writes [beam] - posted by "SPUERSAIYAN (via GitHub)" <gi...@apache.org> on 2026/06/02 17:07:20 UTC, 8 replies.
- Re: [PR] Update managed-io.md for release 2.74.0-RC3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/02 17:33:24 UTC, 0 replies.
- [PR] Move google-auth lower bounds to >= 2.0.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/02 19:14:45 UTC, 3 replies.
- [PR] pin commons-configuration2 version to 2.15.0 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/02 20:14:04 UTC, 8 replies.
- [I] The CloudML Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 05:11:47 UTC, 6 replies.
- [PR] Bump beamVersion from 2.73.0 to 2.74.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 06:27:57 UTC, 0 replies.
- [PR] Fix cloudML TFT install avoiding pip ResolutionTooDeep [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/03 08:16:29 UTC, 6 replies.
- [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 08:17:40 UTC, 6 replies.
- [PR] [BigQueryIO[ Improve sharding for bounded pcolleciton [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/03 09:36:46 UTC, 6 replies.
- [PR] [OpenTelemetry] Default open telemetry configuration behind experiment [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/03 12:24:29 UTC, 4 replies.
- [PR] [OpenTelemetry] FNHarness, Dataflow Runner v1 - set open telemetry settings [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/03 12:38:18 UTC, 4 replies.
- Re: [PR] [BigQueryIO] Improve sharding for bounded pcolleciton [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/03 12:55:12 UTC, 7 replies.
- Re: [PR] Add DoFnRunner::finishKey() method [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/06/03 13:17:41 UTC, 10 replies.
- [PR] Add drain support for Dataflow and Flink [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/03 13:46:56 UTC, 14 replies.
- Re: [PR] Add metrics for Kafka offset commit failures [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 13:58:35 UTC, 5 replies.
- Re: [PR] [yaml] - expand jinja method [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 13:58:45 UTC, 3 replies.
- Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 13:58:54 UTC, 3 replies.
- Re: [PR] ML pipelines: RunInference - OSS Image Object detection, OSS Image Captioning, OSS Image Classification [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 13:59:03 UTC, 11 replies.
- Re: [I] [Feature Request]: BQ: Allow map values to be nullable in GCP SDK BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 14:09:01 UTC, 1 replies.
- Re: [I] [Feature Request]: Request to use BASIC enum when calling tables.get() in BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 14:09:11 UTC, 2 replies.
- Re: [I] [Task]: Remediate CVE-2024-28397 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/03 14:15:49 UTC, 1 replies.
- [PR] [OpenTelemetry] Add open telemetry dependency to dataflow worker [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/03 14:38:46 UTC, 1 replies.
- [PR] Fix Dataflow cost benchmark after Dataflow client migration [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/03 15:46:43 UTC, 6 replies.
- [PR] Update huggingface model handler info [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/03 15:54:33 UTC, 5 replies.
- [PR] Fix offlineRepositoryRoot relative to Beam repo root [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/03 16:03:31 UTC, 3 replies.
- Re: [I] [yaml] Normalize RunInference transform [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/03 16:57:19 UTC, 1 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 17:12:48 UTC, 2 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 17:12:50 UTC, 6 replies.
- [PR] Fix internal test configuration for Dataflow client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/03 17:29:23 UTC, 5 replies.
- Re: [I] [Task]: Create the initial source with basic read support and BeamParquetHandler [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/03 18:20:24 UTC, 0 replies.
- Re: [I] [Task]: Add support for splitting the source [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/03 18:20:25 UTC, 0 replies.
- Re: [I] [Task]: Add support for dynamic work rebalancing [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/03 18:20:26 UTC, 0 replies.
- [PR] try single pip install [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/03 18:55:23 UTC, 2 replies.
- [PR] [Experiment] Try single pip call + uv usage [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/03 19:21:02 UTC, 1 replies.
- [PR] Update beam-master container [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/03 20:09:37 UTC, 11 replies.
- [PR] Update republish released docker workflow defaults to 2.74.0 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/03 20:17:01 UTC, 3 replies.
- [PR] Normalize types in dataclass field type resolving [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/03 20:18:27 UTC, 8 replies.
- [PR] [Experimental] Fix Yaml Xlang Test Timeout [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/03 20:20:31 UTC, 8 replies.
- [PR] Upgrade Beam version to 2.74.0 [beam-starter-java] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/03 21:14:59 UTC, 2 replies.
- [PR] Upgrade Google Cloud libraries-bom to 26.83.0 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/03 21:39:21 UTC, 9 replies.
- [PR] Bump distlib from 0.3.9 to 0.4.1 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:06:10 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.102.2 to 1.103.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:07:49 UTC, 2 replies.
- [PR] Bump github.com/aws/smithy-go from 1.26.0 to 1.27.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:07:55 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.9 to 1.41.11 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:09:12 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.20 to 1.32.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:10:30 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.19 to 1.19.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:11:43 UTC, 3 replies.
- [I] The PostCommit Python Examples Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:26 UTC, 3 replies.
- [I] The PostCommit Python ValidatesContainer Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:36 UTC, 2 replies.
- [I] The PostCommit Python Examples Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:37 UTC, 3 replies.
- [I] The PostCommit Python Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:47 UTC, 7 replies.
- [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:54 UTC, 2 replies.
- [I] The PostCommit Python Examples Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 22:20:55 UTC, 3 replies.
- [PR] Bump apache-beam from 2.71.0 to 2.74.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 00:16:22 UTC, 0 replies.
- Re: [PR] Bump apache-beam from 2.71.0 to 2.73.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 00:16:24 UTC, 1 replies.
- [I] The PostCommit Python ValidatesRunner Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 01:38:11 UTC, 3 replies.
- [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 01:38:15 UTC, 3 replies.
- [PR] Bump org.jetbrains.kotlin.jvm from 2.1.0 to 2.4.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 02:58:05 UTC, 0 replies.
- Re: [PR] Bump org.jetbrains.kotlin.jvm from 2.1.0 to 2.3.21 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 02:58:07 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.282.0 to 0.283.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:40:16 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.22 to 1.22.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:41:58 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.1 to 2.14.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:42:10 UTC, 2 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:05 UTC, 9 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:14 UTC, 3 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:16 UTC, 6 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:19 UTC, 31 replies.
- [I] The PostCommit XVR Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:23 UTC, 4 replies.
- [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:09:27 UTC, 3 replies.
- Re: [I] [Feature Request]: Add a native Logging transform to Java SDK [beam] - posted by "SushrutVaidya (via GitHub)" <gi...@apache.org> on 2026/06/04 09:50:22 UTC, 0 replies.
- [PR] [Dataflow Streaming] [Multi Key] Prepare StreamingModeExecutionContext and StreamingWorkScheduler for multi-key execution. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/04 11:08:11 UTC, 39 replies.
- Re: [PR] add upgrade gcp bom workflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 13:25:09 UTC, 10 replies.
- Re: [I] [Bug]: Iceberg managed connector upgrade failed in GCP Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 13:34:27 UTC, 1 replies.
- Re: [I] [Task]: validate timestamps / windowing metadata in FnApiDoFnRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 13:34:35 UTC, 1 replies.
- Re: [I] [Failing Test]: JavaUsingPython postcommit tests are failing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 13:34:37 UTC, 1 replies.
- Re: [PR] Side Input improvements [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/04 15:54:39 UTC, 4 replies.
- [PR] Automate OpenTelemetry license entries in bomupgrader [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/04 16:56:03 UTC, 8 replies.
- Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/04 17:23:35 UTC, 4 replies.
- Re: [I] [Feature Request]: Allow disable user metrics in Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/04 17:23:48 UTC, 0 replies.
- [PR] [Dataflow] Fix thread safety of HotKey logger [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/04 19:03:17 UTC, 5 replies.
- Re: [PR] Add embedded NVIDIA Dynamo support to vLLM ModelHandler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/04 19:31:30 UTC, 8 replies.
- [PR] [wip] try codesql [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/04 19:52:13 UTC, 1 replies.
- [PR] update agent skills table [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/04 20:40:22 UTC, 6 replies.
- [PR] Request service account credentials for GSoC 2026 - Hansel Tepal [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/04 20:56:41 UTC, 7 replies.
- [I] [Feature Request]: Iceberg IO Hash Distribution Mode Support for Spark Based Runners [beam] - posted by "barunkumaracharya (via GitHub)" <gi...@apache.org> on 2026/06/04 21:03:06 UTC, 3 replies.
- Re: [PR] Enable code scanning alerts [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/04 21:31:49 UTC, 4 replies.
- Re: [PR] [Dataflow Streaming] Rearrange work scheduling code for multi key bundles [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/04 21:59:42 UTC, 0 replies.
- Re: [I] Correctly comment or remove Metrics Cache [beam] - posted by "PRADDZY (via GitHub)" <gi...@apache.org> on 2026/06/04 22:03:01 UTC, 2 replies.
- [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/04 22:26:56 UTC, 11 replies.
- [PR] [Python] Document RunInference metrics cache lifecycle [beam] - posted by "PRADDZY (via GitHub)" <gi...@apache.org> on 2026/06/04 22:27:27 UTC, 4 replies.
- [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/04 22:31:34 UTC, 8 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/06/05 01:28:16 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.24 to 1.22.25 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:24:39 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.62.2 to 1.62.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:25:00 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.103.1 to 1.103.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:26:22 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.22 to 1.32.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:27:43 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.11 to 1.41.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:29:03 UTC, 3 replies.
- [PR] Revert "remove playground annotations from BatchElementsExample " [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/05 11:13:35 UTC, 3 replies.
- [I] [Task]: Implement a full Iceberg CDC incremental source [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/05 12:29:27 UTC, 0 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/06/05 13:19:52 UTC, 5 replies.
- Re: [PR] Add support for datetime, date, and frozenset to FastPrimitivesCoder [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 13:19:55 UTC, 7 replies.
- Re: [I] [Feature Request]: ib.collect support wait_for_inputs option [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 13:33:05 UTC, 0 replies.
- Re: [PR] [Iceberg SQL] Add iceberg CDC table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 13:33:15 UTC, 2 replies.
- Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 13:33:17 UTC, 2 replies.
- Re: [I] [Feature Request]: Generalize reading arbitrary types from files. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 13:33:21 UTC, 1 replies.
- Re: [I] [Bug]: Beam playground pydot is not defined [beam] - posted by "PRADDZY (via GitHub)" <gi...@apache.org> on 2026/06/05 14:35:40 UTC, 0 replies.
- [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/05 14:55:53 UTC, 13 replies.
- [PR] Preserve partitioning on temp FILE_LOADS tables [beam] - posted by "PRADDZY (via GitHub)" <gi...@apache.org> on 2026/06/05 16:28:53 UTC, 8 replies.
- [PR] [Iceberg CDC] Add watch for snapshots source [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/05 19:01:53 UTC, 9 replies.
- [PR] defer ConstructionTimeTest fixtures to setUpClass [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/05 19:23:06 UTC, 1 replies.
- [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/05 19:40:26 UTC, 13 replies.
- Re: [PR] [WIP] Iceberg CDC streaming source [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 19:45:55 UTC, 0 replies.
- [PR] [Iceberg CDC] Add Changelog readers and update resolver [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/05 20:14:18 UTC, 0 replies.
- Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 23:48:39 UTC, 19 replies.
- Re: [I] runtime_type_check DoFn wrapper doesn't call setup and teardown [beam] - posted by "rgupta90 (via GitHub)" <gi...@apache.org> on 2026/06/06 02:25:57 UTC, 1 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 04:49:07 UTC, 3 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 04:49:17 UTC, 5 replies.
- [PR] Update Gemini text classification to gemini-2.5-flash [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/06 12:24:13 UTC, 7 replies.
- Re: [PR] Update SpannerIO.java - comment documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:42:56 UTC, 1 replies.
- Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:42:58 UTC, 4 replies.
- Re: [I] [Task]: Propagate context from windmill to windowedValue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:20 UTC, 0 replies.
- Re: [I] [Failing Test]: Re-enable the skipped Change Stream Unit tests after refactor test code [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:22 UTC, 0 replies.
- Re: [I] [Bug]: SolaceIO seems to lose messages during Dataflow scaling/rebalancing events [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:23 UTC, 1 replies.
- Re: [I] [Failing Test]: Pylint failed when hypothesis > 6.148.3 is used [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:25 UTC, 1 replies.
- Re: [I] Permission needs to be obtained before adding exceptions to the CSP [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:26 UTC, 1 replies.
- Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:31 UTC, 1 replies.
- Re: [I] [Bug]: Dependency resolution is happening when installing latest version of apache-beam[gcp] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 12:54:37 UTC, 1 replies.
- Re: [I] [Bug]: Type hints lost in core transforms [beam] - posted by "rgupta90 (via GitHub)" <gi...@apache.org> on 2026/06/06 17:47:07 UTC, 0 replies.
- Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 12:46:56 UTC, 6 replies.
- Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 12:46:58 UTC, 6 replies.
- Re: [PR] Iceberg CDC streaming source [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:09 UTC, 1 replies.
- Re: [I] [Bug]: pytest retry configuration is not effective [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:13 UTC, 1 replies.
- Re: [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:19 UTC, 1 replies.
- Re: [I] [Bug] [BQ Streaming Inserts]: Whole number in float field is treated like an int [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:23 UTC, 1 replies.
- Re: [I] [Task]: Fix hugging face ModelHandler top level imports [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:27 UTC, 1 replies.
- Re: [I] [Bug]: Python BQ directrunner postcommits flake with KeyError: '__pyx_vtable__' [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 13:02:31 UTC, 1 replies.
- [I] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/07 13:13:42 UTC, 3 replies.
- Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/07 15:22:12 UTC, 13 replies.
- Re: [PR] ClickHouseIO: Add DateTime64 support for sub-second timestamp precision [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2026/06/07 16:49:48 UTC, 4 replies.
- [PR] Bump github.com/aws/smithy-go from 1.27.1 to 1.27.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:25:57 UTC, 2 replies.
- [PR] [Dataflow Streaming] Fix nullness supression in StreamingModeExecutionContext [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/08 07:58:01 UTC, 9 replies.
- Re: [I] [Bug]: [Spanner Change Streams] Increased polling frequency for idle change streams causes increased Cloud Spanner load [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/08 09:50:24 UTC, 1 replies.
- [PR] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/08 09:55:28 UTC, 8 replies.
- [PR] fix flaky Arm postcommit test collection on Python 3.14 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/08 10:39:34 UTC, 5 replies.
- [I] The PreCommit Java IOs Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 11:16:23 UTC, 6 replies.
- [PR] [OpenTelemetry] Add turning off to gcpauth extension [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/08 12:57:45 UTC, 4 replies.
- Re: [PR] Fix/add experiment refactor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:44:18 UTC, 13 replies.
- Re: [I] [Task]: Migrate BigQuery v2 Client to Python Client Library [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:07 UTC, 0 replies.
- Re: [I] [Feature Request]: Support portable logical type for Beam SQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:16 UTC, 0 replies.
- Re: [I] [Task]: Polish Beam SQL user experience [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:20 UTC, 2 replies.
- Re: [I] [Bug]: WriteToParquet exhibits different behavior when using return versus yield [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:25 UTC, 1 replies.
- Re: [I] [Bug]: Error occurs when assigning an interface to a field of a struct used for emitting in Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:29 UTC, 1 replies.
- Re: [I] [Bug]: Error reading from BigQueryIO.readTableRowsWithSchema() when query contains an array of structs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 13:55:33 UTC, 1 replies.
- [PR] Fix parsing of dataflow api endpoint URLs to remove trailing slash [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/08 15:49:32 UTC, 7 replies.
- Re: [I] [Bug]: ReadFromCSV does not handle EmptyDataframe well internally [beam] - posted by "apanich (via GitHub)" <gi...@apache.org> on 2026/06/08 15:57:28 UTC, 2 replies.
- [I] [Feature Request]: BigtableIO should use ValueProviders for attempt and operation timeouts [beam] - posted by "brandtnewton (via GitHub)" <gi...@apache.org> on 2026/06/08 16:11:36 UTC, 1 replies.
- [PR] feat: add configurable bigtable retries [beam] - posted by "brandtnewton (via GitHub)" <gi...@apache.org> on 2026/06/08 16:14:10 UTC, 0 replies.
- [PR] Fix MatchContinuously translation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/08 16:58:46 UTC, 5 replies.
- [PR] Fix race condition in statesampler_fast.pyx [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/08 17:07:59 UTC, 9 replies.
- [PR] pin pip>=26.1 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/08 19:57:09 UTC, 9 replies.
- [PR] Add memory profiler for Python [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/06/09 00:46:25 UTC, 7 replies.
- [PR] Allow strongly-consistent schema updates in BigQueryIO [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/09 02:52:31 UTC, 19 replies.
- [PR] Bump distlib from 0.3.9 to 0.4.2 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:23:27 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.103.2 to 1.103.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:24:50 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.45.0 to 0.46.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:24:55 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.22 to 1.19.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:26:15 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.12 to 1.42.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:27:31 UTC, 3 replies.
- [PR] Bump golang.org/x/text from 0.37.0 to 0.38.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:27:36 UTC, 2 replies.
- Re: [I] [Bug]: Reset bigtable version [beam] - posted by "kellen (via GitHub)" <gi...@apache.org> on 2026/06/09 07:19:23 UTC, 1 replies.
- [PR] Unpin google-cloud-bigtable version (fixes apache#37637) [beam] - posted by "kellen (via GitHub)" <gi...@apache.org> on 2026/06/09 07:27:19 UTC, 2 replies.
- [PR] Fix Xlang IO Direct installGcpTest uv cache lock [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/09 09:56:21 UTC, 9 replies.
- Re: [PR] Unpin google-cloud-bigtable version (fixes #37637) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 10:42:21 UTC, 1 replies.
- [PR] [FnApi] Add support for a new name field to ApiServiceDescriptor under StandardProtocols.API_SERVICE_DESCRIPTOR_NAME [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/09 13:08:45 UTC, 0 replies.
- Re: [PR] Set consuming_received_data=True during bundle setup [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 13:28:19 UTC, 2 replies.
- Re: [I] > # :wave: Welcome to GitHub Learning Lab's "Introduction to GitHub" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 13:28:27 UTC, 2 replies.
- Re: [I] [Task]: Improve the MLTransform preprocessing page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 13:28:32 UTC, 1 replies.
- Re: [I] [Bug]: WriteToFiles in python leave few records in temp directory when writing to large number (100+) of files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 13:28:36 UTC, 1 replies.
- Re: [I] [Bug]: :beam_CleanUpPrebuiltSDKImages :beam-test-tools:removeStaleSDKContainerImages FAILED [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 13:28:40 UTC, 1 replies.
- Re: [PR] Use Flink 2.0 for load tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/09 14:05:31 UTC, 4 replies.
- [PR] Increase Precommit PythonDocker workflow timeout [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/09 14:35:15 UTC, 4 replies.
- Re: [PR] Disable public ip for Dataflow Validates Runner test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/09 14:35:24 UTC, 2 replies.
- [PR] Support MAP type in RowJson and fix datetime parsing with spaces [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 14:51:43 UTC, 6 replies.
- [PR] SQL API Extensions, Usability Improvements, and Subquery Decorrelation [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 15:17:34 UTC, 0 replies.
- [PR] SQL Physical Operator Fixes and Enhancements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 15:21:51 UTC, 0 replies.
- [PR] Reconcile schema nullability in BeamCoGBKJoinRel [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 15:55:28 UTC, 7 replies.
- Re: [PR] Release Note: Rename Dataflow Runner to Dataflow Portable Runner [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/06/09 16:12:41 UTC, 5 replies.
- [PR] Adds a Github action for running Delta Lake I/O unit tests [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/09 16:18:24 UTC, 8 replies.
- [PR] Implement Spark SQL parser extensions and enhance analytic functions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 16:40:08 UTC, 0 replies.
- [PR] Add support for STDDEV_POP and STDDEV_SAMP in VarianceFn [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 17:07:25 UTC, 17 replies.
- [PR] Enhance SQL Sort operator and UDF type resolution infrastructure [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/09 17:29:58 UTC, 1 replies.
- [PR] Implement BeamFileSystemClient for Delta Lake connector (#38554) [beam] - posted by "joaohmalves (via GitHub)" <gi...@apache.org> on 2026/06/09 17:44:29 UTC, 1 replies.
- Re: [PR] Implement BeamFileSystemClient for Delta Lake connector [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 17:46:19 UTC, 16 replies.
- [PR] FIx yaml doc generation [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/09 17:54:26 UTC, 9 replies.
- [I] [Bug]: OnWindowExpirationContext does not work [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/09 18:43:35 UTC, 4 replies.
- [PR] [IcebergIO] Support TableIdentifiers with special characters [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/09 18:57:01 UTC, 5 replies.
- [PR] Fix wordcount_rust requirements.txt and documentation [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/09 18:58:13 UTC, 5 replies.
- [PR] Fix OnWindowExpirationContext. [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/09 19:24:58 UTC, 6 replies.
- [PR] update iceberg add files parameters [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/09 20:37:06 UTC, 4 replies.
- [PR] [SQL] Support positional parameters [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/09 20:46:18 UTC, 9 replies.
- [PR] [wip] spotless [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/09 20:56:14 UTC, 0 replies.
- [PR] [IcebergIO] Improve TableCache [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/09 21:26:38 UTC, 8 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 22:03:33 UTC, 13 replies.
- Re: [PR] Add instrumentation for memory profiling in Python SDK [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 02:10:02 UTC, 9 replies.
- [PR] Add BigQueryIO support for clone table creation [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/10 04:13:43 UTC, 12 replies.
- Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/10 04:14:30 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.23 to 1.32.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 04:24:36 UTC, 2 replies.
- [PR] Bump actions/checkout from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 04:25:40 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.25 to 1.22.26 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 04:25:57 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.283.0 to 0.284.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 04:26:07 UTC, 2 replies.
- [PR] Use p310_ml_test extra [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/10 08:13:06 UTC, 1 replies.
- [PR] Add metric for Kafka offset commit failures [beam] - posted by "Kriti-dev07 (via GitHub)" <gi...@apache.org> on 2026/06/10 10:00:32 UTC, 6 replies.
- [PR] Fix ml_test protobuf conflict for Yaml Xlang Direct [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/10 12:41:09 UTC, 6 replies.
- Re: [I] [Bug]: The`:sdks:java:javadoc:aggregateJavadoc` task does not work with Java 11 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 13:44:05 UTC, 1 replies.
- Re: [I] [Task]: Remove support for the typing module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 13:44:11 UTC, 1 replies.
- Re: [I] [Task]: Compile Java Examples Main on Java 11/17/21 when run Java Example Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 13:44:23 UTC, 0 replies.
- [PR] [wip] DeltaLake yaml normalization [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/10 13:54:25 UTC, 1 replies.
- [PR] [Python] Add UnboundedSource ValidatesRunner test on portable runners [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/06/10 14:01:39 UTC, 9 replies.
- [I] [Task]: Make CodeQL fully operational [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/10 14:13:02 UTC, 0 replies.
- [PR] Fix Dataflow legacy worker abort loop thread death issue [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/10 14:48:45 UTC, 6 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.22.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 17:14:15 UTC, 3 replies.
- [PR] Bump torch from 1.13.1 to 2.12.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 18:14:25 UTC, 2 replies.
- Re: [PR] [mqtt] Add portable MqttIO Read/Write transforms for batch and streaming (revives #32385) [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 18:41:41 UTC, 16 replies.
- [PR] Bump torch from 1.13.1 to 2.12.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 18:52:05 UTC, 2 replies.
- Re: [I] Beam Python PubSubIO Does Not Support Ordered Key Publishing [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/06/10 19:13:14 UTC, 2 replies.
- [PR] fix parsing error for typescript [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/10 19:17:27 UTC, 2 replies.
- [I] The Release Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 19:23:25 UTC, 1 replies.
- [I] The PostCommit Java PVR Spark4 Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 19:23:31 UTC, 2 replies.
- [PR] Revert "[Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/10 19:48:16 UTC, 5 replies.
- Re: [I] [Task]: Normalize DatadogIO [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/10 19:51:36 UTC, 0 replies.
- Re: [PR] SQL DDL documentation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/10 20:00:36 UTC, 11 replies.
- [PR] Add Delta Lake source to the Java Managed API [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/10 20:14:57 UTC, 9 replies.
- [PR] Bump torch from 2.2.0 to 2.12.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 20:31:24 UTC, 2 replies.
- [PR] Don't preempt snapshot runs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/10 20:40:35 UTC, 4 replies.
- [I] [Bug]: ProtoByteBuddyUtils should use ByteBuddyUtils.getClassLoadingStrategy [beam] - posted by "cushon (via GitHub)" <gi...@apache.org> on 2026/06/10 21:02:03 UTC, 2 replies.
- [PR] Replace ClassLoadingStrategy with custom loading strategy [beam] - posted by "cushon (via GitHub)" <gi...@apache.org> on 2026/06/10 21:03:22 UTC, 15 replies.
- [PR] Turn to manual build for Go for CodeQL [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/10 21:08:34 UTC, 4 replies.
- [PR] Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 21:19:44 UTC, 3 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.22.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 21:19:49 UTC, 3 replies.
- [PR] Adds a new agent SKILL for developing new I/O connectors [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/10 23:28:12 UTC, 6 replies.
- [PR] Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 00:29:51 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.26 to 1.22.27 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 04:24:42 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.48.0 to 1.49.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 04:24:59 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.23 to 1.19.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 04:26:16 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.55.0 to 0.56.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 04:26:24 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.24 to 1.32.25 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 04:27:46 UTC, 2 replies.
- [I] The PostCommit Java PVR Spark Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:04:54 UTC, 3 replies.
- [PR] Add MLTransform embedding benchmarks [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/11 06:37:57 UTC, 11 replies.
- [PR] fix uv cache lock contention in parallel installGcpTest [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/11 07:29:28 UTC, 2 replies.
- [PR] [Dataflow Streaming] [Multi Key] MultiKey failure handling + Integration [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/11 12:11:06 UTC, 5 replies.
- [PR] [Dataflow Streaming] [Multi Key] Drop failed work in BoundedQueueExecutor::pollWork [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/11 13:37:18 UTC, 9 replies.
- [PR] [Dataflow Streaming] Activate SourceState Finalizers before submitting workitem to harness threads [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/11 13:38:31 UTC, 8 replies.
- [PR] Bump @grpc/grpc-js from 1.14.3 to 1.14.4 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:48:44 UTC, 2 replies.
- Re: [PR] Fix google-api-python-client python version bound [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:24 UTC, 2 replies.
- Re: [I] [Feature Request]: Time series processing for batch data [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:32 UTC, 1 replies.
- Re: [I] [Bug]: DaskRunner GBK is broken, pending upstream fix in dask [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:40 UTC, 1 replies.
- Re: [I] [Bug]: Incorrect exception message setting wrong expectations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:41 UTC, 1 replies.
- Re: [I] [Bug]: Dependency Issue with Apache Beam 2.51.0 Upgrade [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:44 UTC, 1 replies.
- Re: [I] [Task]: Enrich Managed IO by onboarding more IOs and making Iceberg feature complete [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 13:49:59 UTC, 0 replies.
- [PR] Updates references to the I/O connector skill [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/11 16:06:57 UTC, 5 replies.
- [PR] Updates CHANGES.md to mention the Delta Lake source [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/11 16:44:40 UTC, 6 replies.
- Re: [I] [Feature Request]: Implement AsyncDoFn in Java [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/11 16:57:33 UTC, 0 replies.
- [I] [Task]: Use the new Iceberg FileFormat API [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/11 17:40:44 UTC, 3 replies.
- [I] CVE Consideration Request – GitHub Actions Workflow RCE Vulnerability in Apache Beam [beam] - posted by "rishiarora123 (via GitHub)" <gi...@apache.org> on 2026/06/11 17:45:48 UTC, 2 replies.
- [PR] upgrade expansion sevice to Java 17 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/11 18:14:31 UTC, 1 replies.
- [PR] Spanner: Extend SpannerIO to support Spanner OMNI mTLS setup [beam] - posted by "sagnghos (via GitHub)" <gi...@apache.org> on 2026/06/11 18:15:44 UTC, 1 replies.
- Re: [PR] Spanner: Extend SpannerIO to support Spanner Omni mTLS setup [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 18:40:49 UTC, 10 replies.
- Re: [PR] [Experimental] Use uv over pip in Python Dockerfiles [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/11 18:45:37 UTC, 0 replies.
- [PR] SQL Subquery Decorrelation [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/11 19:26:25 UTC, 2 replies.
- Re: [I] [Calcite SQL] Query Parametrization [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/11 19:58:40 UTC, 0 replies.
- Re: [PR] [IcebergIO] Let hash distribution mode spill over if file gets too large [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 21:18:55 UTC, 5 replies.
- [PR] 20260611 upgrade exponsion jar to java17 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/11 21:27:36 UTC, 2 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 22:12:53 UTC, 4 replies.
- [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 22:13:04 UTC, 2 replies.
- [PR] [Infra] Add beam_viewer and beam_writer roles for GSoC 2026 participant [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/12 00:21:20 UTC, 4 replies.
- [I] The PostCommit Java PVR Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 01:34:08 UTC, 3 replies.
- [PR] Bump torch from 2.8.0+cpu to 2.12.0 in /sdks/python/container/ml/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 01:43:43 UTC, 1 replies.
- [PR] Make ModelManager import more robust [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2026/06/12 05:19:32 UTC, 11 replies.
- [PR] [WIP] Portable VoidCoder [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/06/12 07:59:33 UTC, 4 replies.
- [PR] fix failure in opentelemetry-gcp-auth-extension jar [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/12 10:17:52 UTC, 3 replies.
- [PR] Exclude testSideInputNotReadyTimer from Spark batch suites [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/12 10:49:09 UTC, 5 replies.
- [PR] [OpenTelemetry] Turn off gcp otel auth extension by default. [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/12 12:06:46 UTC, 5 replies.
- [PR] [OpenTelemetry] Add open telemetry dependency to dataflow pipeline runner [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/12 12:10:38 UTC, 6 replies.
- [PR] Potential fix for code scanning alert no. 1: Environment variable built from user-controlled sources [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/12 12:24:33 UTC, 0 replies.
- [PR] Add Gemini RunInference example notebook [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/12 13:29:28 UTC, 4 replies.
- Re: [PR] [FnApi Java] Add support for separate named data streams to provide bundle isolation [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:38:13 UTC, 18 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.22.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:39:22 UTC, 1 replies.
- Re: [PR] Upgrade expansion jar to java17 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/12 13:40:06 UTC, 7 replies.
- Re: [I] [Feature Request]: Pass in URN information to GCP Runner. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:41:48 UTC, 1 replies.
- Re: [I] [Feature Request]: Add Write Support for Azure CosmosDB with Core(SQL) API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:41:52 UTC, 1 replies.
- Re: [I] [Task]: Upgrade checkerframework to 3.39.0+ [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:42:00 UTC, 0 replies.
- Re: [I] [Bug]: Pointer dereference error with Spanner partitioned reads on Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 13:42:02 UTC, 0 replies.
- Re: [I] [Feature Request]: Expose setMaxRequestCallbackWaitTime in BigQuery storage write [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/06/12 14:29:10 UTC, 0 replies.
- [I] [Failing Test]: Milvus RAG integration tests fail consistently in beam_PreCommit_Python_ML (py3.13) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/12 14:29:19 UTC, 0 replies.
- [I] [Failing Test]: SqsIOWriteBatchesTest is flaky (Mockito ArgumentsAreDifferent in timeout-related tests) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/12 14:30:05 UTC, 1 replies.
- [I] [Feature Request]: Add support for Flink 2.1.2 [beam] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/06/12 15:12:16 UTC, 1 replies.
- [PR] Bump github.com/apple/swift-nio from 2.84.0 to 2.101.0 [beam-swift] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 15:12:28 UTC, 1 replies.
- [PR] Improve BigQueryIO Storage Write API error messages [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 15:15:36 UTC, 15 replies.
- [PR] address DOM text reinterpreted as HTML alert [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/12 15:18:44 UTC, 31 replies.
- [PR] Update Bigquery Client [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/06/12 16:41:00 UTC, 8 replies.
- Re: [PR] Potential fix for environment variable built from user-controlled sources [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/12 16:56:43 UTC, 5 replies.
- Re: [PR] update spotless to 7.2 and reformat [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/12 17:34:23 UTC, 0 replies.
- Re: [PR] Bump com.avast.gradle:gradle-docker-compose-plugin from 0.16.12 to 0.17.5 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:43:33 UTC, 1 replies.
- Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.6.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:43:50 UTC, 1 replies.
- Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.6.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:43:57 UTC, 1 replies.
- Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:44:03 UTC, 1 replies.
- Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.5.1 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:44:09 UTC, 1 replies.
- Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:44:33 UTC, 0 replies.
- Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:45:12 UTC, 0 replies.
- Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 17:47:04 UTC, 0 replies.
- Re: [I] Improve memory profiling for users of Portable Beam Python [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/06/12 18:56:21 UTC, 0 replies.
- [PR] SQL API Extensions: Expose planning APIs and make classes public [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 19:39:54 UTC, 12 replies.
- [PR] SQL Database DDL & Usability Improvements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 19:39:56 UTC, 15 replies.
- Re: [PR] SQL API Extensions and Usability Improvements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/12 19:39:57 UTC, 0 replies.
- [PR] Bump pyo3 from 0.27.2 to 0.29.0 in /sdks/python/apache_beam/examples/wordcount_rust/word_processing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 19:43:16 UTC, 1 replies.
- Re: [I] [Go SDK] fileio.MatchAll() cannot match all files on GCS [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/12 20:14:44 UTC, 0 replies.
- [PR] Adds a Dataflow integration test suite for Delta Lake [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/06/12 21:40:22 UTC, 9 replies.
- Re: [I] [Playground][Frontend] : Persist editor state and SDK selection in localStorage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 13:02:52 UTC, 0 replies.
- Re: [I] [Task]: Display commit history when creating a perf alert [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 13:03:09 UTC, 0 replies.
- Re: [I] [Task]: [RRIO] [Throttle] transform that slows down element transmission without an external resource [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 13:03:12 UTC, 0 replies.
- Re: [I] [Task]: [RRIO] [Testing] Support a CRUD endpoint [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 13:03:13 UTC, 0 replies.
- Re: [I] [Task]: Also remove META-INF for excluded transitive dependencies in Beam vendored dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 13:03:15 UTC, 0 replies.
- [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/13 15:56:13 UTC, 3 replies.
- [PR] Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 19:44:52 UTC, 1 replies.
- Re: [I] [Feature Request]: Define an expansion service jar for Delta Lake [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/13 19:48:04 UTC, 0 replies.
- [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 1: in-memory per-source-partition tracking [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/14 07:32:00 UTC, 8 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/14 09:24:28 UTC, 5 replies.
- Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/14 09:24:52 UTC, 5 replies.
- Re: [I] [Task]: Upgrade self-hosted runner base image [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 13:07:09 UTC, 0 replies.
- Re: [I] [Feature Request]: gRPC connector to Dataproc Metastore [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 13:07:14 UTC, 1 replies.
- Re: [I] [RRIO] [Call] Consider many requests to one API call use cases [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 13:07:18 UTC, 1 replies.
- Re: [I] [Stuck Test]: GitHub Action issue_comment trigger not scalable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 13:07:26 UTC, 0 replies.
- Re: [I] [Feature Request]: Add per-worker labelled/histogram metrics to BigQuery IO for the Dataflow Legacy Harness. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 13:07:28 UTC, 0 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 21:56:24 UTC, 3 replies.
- [I] The PreCommit Java Flink Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 01:37:04 UTC, 3 replies.
- [PR] Bump distlib from 0.4.2 to 0.4.3 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 04:30:54 UTC, 1 replies.
- [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:16:08 UTC, 3 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:16:12 UTC, 7 replies.
- Re: [I] [GSoC 2026] Kafka Streams Runner — ExecutableStage (stateless ParDo) translator [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/06/15 08:23:30 UTC, 1 replies.
- [PR] [Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/15 10:18:00 UTC, 10 replies.
- [PR] Add support for Apache Flink 2.1.3 [beam] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/06/15 11:28:26 UTC, 17 replies.
- [PR] Fix PostCommit YAML Xlang Direct after Java 17 expansion service upgrade [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/15 12:44:35 UTC, 5 replies.
- [PR] Update BEAM_DEV_SDK_CONTAINER_TAG version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/15 13:59:26 UTC, 5 replies.
- Re: [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 14:37:52 UTC, 1 replies.
- Re: [I] [Bug]: Latest.Globally() issues in global window [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 14:37:56 UTC, 1 replies.
- Re: [I] [Bug]: ProtoCoder fails on super large protobufs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 14:38:11 UTC, 0 replies.
- Re: [I] [Feature Request]: HuggingFacePipelineModelHandler Load Large Models on Multiple GPUs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 14:38:14 UTC, 0 replies.
- Re: [I] [Bug]: Java SDK Sampling Data from PCollection at the Source is redundant, since the Source already has a perfect estimate of per element size. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 14:38:16 UTC, 0 replies.
- [I] Add support for Apache Flink 2.1.2 [beam] - posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2026/06/15 14:47:07 UTC, 2 replies.
- Re: [PR] Revert "Upgrade expansion jar to java17" [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 15:37:33 UTC, 3 replies.
- Re: [I] [Feature Request]: ClickHouseIO: Add DateTime64 support for sub-second timestamp precision [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/15 16:34:04 UTC, 0 replies.
- Re: [PR] [mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 17:15:18 UTC, 15 replies.
- [PR] Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 17:55:38 UTC, 2 replies.
- [PR] Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 18:12:54 UTC, 2 replies.
- [PR] [Website] Update Python version compatibility table [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/15 18:22:09 UTC, 6 replies.
- [PR] Fix AsyncWrapperTest timeout and flakiness issues. [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/06/15 18:37:20 UTC, 6 replies.
- [PR] [aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/15 19:11:14 UTC, 7 replies.
- [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails consistently (io expansion-service shadowJar not found) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/15 19:48:22 UTC, 0 replies.
- [PR] Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 20:22:41 UTC, 1 replies.
- [PR] Roll forward io expansion service to Java17 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/15 21:18:53 UTC, 16 replies.
- [PR] Bump starlette from 1.2.1 to 1.3.1 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 02:45:38 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.91.0 to 1.92.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 04:23:36 UTC, 2 replies.
- [I] [GSoC 2026] Kafka Streams runner — WatermarkManager part 2: wire into ExecutableStageProcessor [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/16 05:01:13 UTC, 2 replies.
- Re: [I] In WithKeys, get coder for key more safely. [beam] - posted by "adityaRaj369 (via GitHub)" <gi...@apache.org> on 2026/06/16 05:20:41 UTC, 0 replies.
- [I] [Task]: Add support for Apache Flink 2.2.x runner [beam] - posted by "mananmangal (via GitHub)" <gi...@apache.org> on 2026/06/16 06:07:21 UTC, 2 replies.
- [PR] Add unit tests to Go harness package (issue #21386) [beam] - posted by "weibangpeng (via GitHub)" <gi...@apache.org> on 2026/06/16 06:39:10 UTC, 6 replies.
- [PR] Add Flink 2.2.1 runner support [beam] - posted by "mananmangal (via GitHub)" <gi...@apache.org> on 2026/06/16 07:41:24 UTC, 17 replies.
- [PR] [GCP] Optimize BigQuery TriggerCopyJobs performance for WRITE_APPEND [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/16 09:26:06 UTC, 3 replies.
- [I] [Feature Request]: Multi-Source BigQuery Copy Jobs for Python SDK [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/16 09:59:15 UTC, 5 replies.
- [PR] [Python] Optimize BigQuery copy jobs in file loads using multi-source copy [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/16 13:03:23 UTC, 9 replies.
- Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Java SDK breaking changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 14:19:31 UTC, 1 replies.
- Re: [I] [Failing Test]: CommunityMetrics PreCommit broken by gradle-docker-compose-plugin:0.17 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 14:19:51 UTC, 0 replies.
- Re: [I] [Task]: Improve python statecache [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 14:19:53 UTC, 0 replies.
- [PR] Add publish_time_field to ReadFromPubSub YAML transform [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/16 14:56:34 UTC, 12 replies.
- Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/16 14:56:55 UTC, 0 replies.
- [PR] Fix CloudML TFT driver install avoiding pip ResolutionTooDeep [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/16 16:05:45 UTC, 3 replies.
- [PR] [GSoC 2026] Kafka Streams runner — WatermarkManager part 2: wire into ExecutableStageProcessor [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/16 17:21:14 UTC, 9 replies.
- [PR] Handle multi-key bundles in side-input runner [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/06/16 18:02:56 UTC, 17 replies.
- [PR] Fix sentence in SQL DDL page [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/16 20:12:14 UTC, 5 replies.
- [PR] Disable public IP for Dataflow Python and Go Validate runner tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/16 21:28:15 UTC, 8 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 22:16:57 UTC, 3 replies.
- [PR] [Dataflow Streaming] Access state/timerinternals via StepContext [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/16 22:35:33 UTC, 8 replies.
- [PR] [GSOC 2026] Adding logic to validate and generate an error if there are key… [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/16 22:41:51 UTC, 7 replies.
- [I] [SECURITY] Action Required: Rogue Service Account Keys Detected [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/17 01:07:01 UTC, 1 replies.
- [PR] [Beam SQL Shell] Add Iceberg SQL dep when using icebergio [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/17 02:23:32 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.7.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:23:07 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.7.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:23:17 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.284.0 to 0.285.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:23:27 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.103.3 to 1.104.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:24:54 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.27 to 1.22.28 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:26:21 UTC, 2 replies.
- [I] [Task]: Rename dataflow runner v2 to dataflow portable runner [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/06/17 04:36:03 UTC, 0 replies.
- [I] The PostCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:57 UTC, 6 replies.
- [I] [Bug]: When using FnApi and DataStream, bundle processing is not isolated due to limited queues and multiplexing [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/17 10:07:54 UTC, 0 replies.
- Re: [PR] Attempt to force a newer version of Jetty for sql expansion service jar. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 13:52:44 UTC, 2 replies.
- Re: [I] [Feature Request]: Update JmsIO to use jakarta packages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 13:53:06 UTC, 0 replies.
- Re: [I] [Bug]: RunInference with automatic refresh using a global window side inputs takes too long to update sometimes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 13:53:08 UTC, 0 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.23.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 14:19:05 UTC, 1 replies.
- [PR] Bump vllm from 0.10.1.1 to 0.23.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 14:34:38 UTC, 1 replies.
- [PR] Add retry filter support to the Java Remote RetryHandler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/17 15:53:14 UTC, 5 replies.
- [PR] Fix Milvus ML PreCommit flakes from parallel Docker startup [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/17 17:33:58 UTC, 2 replies.
- [PR] Drop Flink 1.17,1.18 support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/17 18:41:13 UTC, 7 replies.
- Re: [I] [Failing Test]: beam_PostCommit_XVR_Samza permared validatesCrossLanguageRunnerGoUsingJava TestDebeziumIO_BasicRead [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/17 18:55:42 UTC, 0 replies.
- Re: [I] [Feature Request]: Support FARM_FINGERPRINT [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/17 18:57:16 UTC, 0 replies.
- Re: [I] [Bug]: Reserved keywords content of the columns overlaps each other [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/17 18:57:52 UTC, 0 replies.
- [PR] Fix Milvus ML PreCommit xdist, container startup, and grpc readiness [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/17 21:36:29 UTC, 2 replies.
- Re: [PR] [Beam SQL Shell] Add Iceberg deps when using icebergio [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/17 21:45:11 UTC, 0 replies.
- [PR] Validate Project of staging bucket [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/06/17 21:47:11 UTC, 13 replies.
- [I] [Feature Request]: Add max_read_time to ReadFromPubsub similar to ReadFromKafka [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/17 22:25:58 UTC, 0 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 22:50:26 UTC, 1 replies.
- Re: [PR] Fix The PreCommit Python ML tests with ML deps installed job [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 23:24:32 UTC, 3 replies.
- [PR] Added Criteo TFT fill_in_missing helper [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/17 23:54:17 UTC, 11 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.49.0 to 1.50.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 04:23:29 UTC, 2 replies.
- [PR] Fix inference benchmark CI timeouts with correct argument quoting [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/18 10:58:02 UTC, 2 replies.
- [PR] Fix PostCommit Java PVR Flink Batch job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/18 11:31:24 UTC, 2 replies.
- [PR] Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 12:18:56 UTC, 1 replies.
- [PR] [Java] Increase CallTest sleep durations to keep test from being flaky [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/18 12:57:54 UTC, 6 replies.
- Re: [PR] fix parsing error for typescript for CodeQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 13:26:57 UTC, 1 replies.
- [PR] Fix pip ResolutionTooDeep [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/18 13:36:14 UTC, 6 replies.
- Re: [I] [Task]: YAML - E2E example pipelines for common use cases [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 13:42:11 UTC, 0 replies.
- Re: [I] [Bug]: Operation ongoing in step EU/Write mutations to Cloud Spanner/Read information schema for at least 05m00s without outputting or completing in state process [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 13:42:28 UTC, 0 replies.
- Re: [I] Dataflow pipelines in GCP are 2x to 3x times slower in apache beam java sdk ver 250 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 13:42:31 UTC, 0 replies.
- [PR] cancel user code with interruption after timeout [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/18 13:54:22 UTC, 6 replies.
- [PR] Bump nodemailer from 8.0.5 to 9.0.1 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 14:58:28 UTC, 1 replies.
- [PR] Add drain states to PipelineResult [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/18 15:45:02 UTC, 3 replies.
- [PR] [Gemini] Port client-side throttling to the Java SDK [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/18 15:53:22 UTC, 3 replies.
- Re: [I] [Feature Request]: Add metrics tracking for offset commit failures and retry attempts in KafkaCommitOffset [beam] - posted by "Shri-Vardhan (via GitHub)" <gi...@apache.org> on 2026/06/18 16:00:14 UTC, 0 replies.
- [PR] [Iceberg AddFiles] Add NameMapping when creating table [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/18 16:01:12 UTC, 9 replies.
- [PR] [Python] Add Watch transform with growth_of polling SDF [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/06/18 16:06:20 UTC, 2 replies.
- [PR] [Iceberg AddFiles] Remove shardedKey [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/18 16:41:48 UTC, 6 replies.
- [PR] Bump actions/checkout from 4 to 7 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 20:12:24 UTC, 0 replies.
- Re: [PR] Bump actions/checkout from 4 to 6 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 20:12:26 UTC, 1 replies.
- [PR] Make MaxRowCountForPageSizeCheck available with ValueProvider [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/06/18 20:21:45 UTC, 4 replies.
- [I] [Bug]: Watermark age for `PeriodicImpulse` regression in v2.74.0 [beam] - posted by "jbandoro (via GitHub)" <gi...@apache.org> on 2026/06/18 20:53:55 UTC, 0 replies.
- [I] The PostCommit Go VR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 22:16:36 UTC, 3 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 22:53:33 UTC, 1 replies.
- [PR] Cache BigQuery table definitions in Python SDK [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/18 23:52:59 UTC, 6 replies.
- [PR] Sanitize logging in FanOutStreamingEngineWorkerHarness [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/06/19 03:12:40 UTC, 3 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.6.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 04:23:15 UTC, 3 replies.
- [PR] Bump github.com/moby/moby/api from 1.54.2 to 1.55.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 04:23:32 UTC, 2 replies.
- [PR] Bump github.com/moby/moby/client from 0.4.1 to 0.5.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 04:23:40 UTC, 2 replies.
- [PR] Bump actions/checkout from 6 to 7 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 04:25:25 UTC, 15 replies.
- Re: [I] [Feature Request]: Specify output_type in ReadFromBigQuery Beam YAML transform [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/06/19 06:25:37 UTC, 1 replies.
- [PR] [Dataflow Java] Fix incorrect warning log when specifying logger override [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/19 08:29:17 UTC, 3 replies.
- [PR] Bump actions/checkout from 6 to 7 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 12:02:47 UTC, 1 replies.
- Re: [I] [Bug]: Remove Spanner exclusion once bug is fixed [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 13:44:28 UTC, 3 replies.
- [PR] [Iceberg SQL] Create cached tables with correct name [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/19 19:58:59 UTC, 5 replies.
- [PR] Bump gradle-wrapper from 8.12 to 9.6.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 20:12:46 UTC, 2 replies.
- Re: [PR] Bump gradle-wrapper from 8.12 to 9.5.1 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 20:12:48 UTC, 1 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 22:33:22 UTC, 0 replies.
- [PR] Bump pydantic-settings from 2.14.1 to 2.14.2 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 23:25:51 UTC, 3 replies.
- [PR] Bump msgpack from 1.1.2 to 1.2.1 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/19 23:25:57 UTC, 3 replies.
- [PR] Bump msgpack from 1.1.2 to 1.2.1 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 02:55:46 UTC, 3 replies.
- [PR] Bump pydantic-settings from 2.14.1 to 2.14.2 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 02:56:01 UTC, 3 replies.
- [PR] [Iceberg AddFiles] Support creating namespaces if needed [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/06/20 03:15:45 UTC, 3 replies.
- [I] [GSoC 2026] Kafka Streams runner — KStreamsPayload Serde (GroupByKey prerequisite) [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/20 11:41:46 UTC, 3 replies.
- Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 13:02:49 UTC, 2 replies.
- [PR] Improve WithKeys coder inference context [beam] - posted by "adityaRaj369 (via GitHub)" <gi...@apache.org> on 2026/06/20 14:34:23 UTC, 8 replies.
- [I] The LoadTests Go Combine Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 16:01:34 UTC, 1 replies.
- [I] The LoadTests Go GBK Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 16:01:41 UTC, 1 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 22:40:40 UTC, 0 replies.
- [PR] [BEAM] Fix Python VarIntCoder OverflowError on uint64 values [beam] - posted by "AviKndr (via GitHub)" <gi...@apache.org> on 2026/06/20 23:03:30 UTC, 4 replies.
- [I] [Bug]: Python VarIntCoder raises OverflowError on unsigned 64-bit (uint64) integers [beam] - posted by "AviKndr (via GitHub)" <gi...@apache.org> on 2026/06/20 23:14:04 UTC, 0 replies.
- Re: [I] [Bug]: Python VarIntCoder raises OverflowError on uint64 integers [beam] - posted by "AviKndr (via GitHub)" <gi...@apache.org> on 2026/06/20 23:17:05 UTC, 0 replies.
- [I] The PostCommit Java Nexmark Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/21 08:10:23 UTC, 4 replies.
- [I] The PostCommit Java Tpcds Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/21 08:10:33 UTC, 4 replies.
- [PR] [GSoC 2026] Kafka Streams runner — KStreamsPayload Serde (GroupByKey prerequisite) [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/21 08:29:30 UTC, 8 replies.
- Re: [I] [Feature Request]: add OpenAI text embeddings notebook [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/21 13:14:56 UTC, 0 replies.
- Re: [I] Can not publish pubsub message with ordering key [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/21 13:15:03 UTC, 1 replies.
- [PR] [wip] delta lake yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/21 17:54:34 UTC, 13 replies.
- Re: [I] Python Beam SDK Harness hangs when installing pip packages [beam] - posted by "pritamdodeja (via GitHub)" <gi...@apache.org> on 2026/06/21 19:36:27 UTC, 0 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.42.0 to 0.43.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 04:27:54 UTC, 4 replies.
- [PR] Bump github.com/golang-cz/devslog from 0.0.16 to 0.0.17 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 04:27:58 UTC, 2 replies.
- [PR] Fix Nexmark Flink lz4-java capability conflict [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/22 07:54:24 UTC, 7 replies.
- [PR] Update pandas version upper bound to support python 3.14 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/22 11:57:23 UTC, 6 replies.
- [PR] Fix inference benchmark CI timeouts [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/22 13:15:32 UTC, 2 replies.
- [PR] try to fix forward with 17 only [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/22 13:39:45 UTC, 0 replies.
- Re: [PR] [Python] Add PCollection.with_side_outputs for chainable side outputs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 14:21:14 UTC, 2 replies.
- Re: [I] [Bug]: RequestResponseIO: Call wraps retryable exceptions in UserCodeExecutionException, preventing retry/backoff [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 14:21:19 UTC, 0 replies.
- Re: [I] [Feature Request]: PubSubIO read considering OrderingKey [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 14:21:22 UTC, 1 replies.
- Re: [I] Include logger name in FnApiLogRecordHandler log entries [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 14:21:24 UTC, 1 replies.
- Re: [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 14:21:30 UTC, 0 replies.
- [I] Security Advisory: Self-Hosted Runner Risk (Skor: 100/100) [beam] - posted by "Notime02 (via GitHub)" <gi...@apache.org> on 2026/06/22 15:02:37 UTC, 0 replies.
- [I] Potential sensitive files found in repository [beam] - posted by "shunfeng8421 (via GitHub)" <gi...@apache.org> on 2026/06/22 15:51:21 UTC, 0 replies.
- [PR] Fix Flink 2.1+ dependency resolution [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/22 19:17:20 UTC, 8 replies.
- [PR] Debug playground failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/22 19:33:47 UTC, 0 replies.
- Re: [PR] try to fix forward tests for java 17 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/22 19:49:27 UTC, 2 replies.
- Re: [PR] Fix playground precommit test failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/22 20:05:59 UTC, 4 replies.
- [PR] Attempt to run the precommit test on java 17 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/22 20:18:29 UTC, 1 replies.
- [PR] [IcebergIO] Raise Java 17 floor for IcebergIO's Java 11 dependents [beam] - posted by "peterphitran (via GitHub)" <gi...@apache.org> on 2026/06/22 21:19:06 UTC, 11 replies.
- [PR] Fix ThreadSanitizer data race and optimize AsyncWrapperTest [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/06/22 21:31:00 UTC, 6 replies.
- Re: [I] [Task]: YAML - update expand_jinja method [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/22 21:46:05 UTC, 0 replies.
- Re: [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/22 23:03:45 UTC, 3 replies.
- [PR] increase PostCommit XVR Spark3 workflow timeout [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/23 01:54:14 UTC, 2 replies.
- [PR] [Gemini] Add batching support to Java Remote Inference [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/23 02:04:23 UTC, 5 replies.
- [PR] Bump google.golang.org/api from 0.285.0 to 0.286.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 04:23:28 UTC, 2 replies.
- [PR] Enable playground tests triggered on cron schedule [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/23 07:38:54 UTC, 5 replies.
- [PR] Enable precommit yaml xlang test on code merge [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/23 08:56:06 UTC, 4 replies.
- Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 13:27:19 UTC, 0 replies.
- Re: [I] [Failing Test]: testBatchGroupIntoBatchesOverrideBytes and testBatchGroupIntoBatchesOverrideCount failed when running on Dataflow Batch mode [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 13:27:21 UTC, 0 replies.
- [PR] Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 14:06:40 UTC, 2 replies.
- [PR] Attempt to fix PostCommit Python by reverting PRs [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/23 14:58:06 UTC, 5 replies.
- Re: [PR] Bump torch from 2.8.0+cpu to 2.12.1 in /sdks/python/container/ml/py313 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 15:34:30 UTC, 0 replies.
- [PR] Extend ADKAgentModelHandler to support deploying local models [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/23 16:04:28 UTC, 8 replies.
- [PR] Fix bundle finalizer callbacks for SDF [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/23 16:09:53 UTC, 9 replies.
- [I] [Feature Request]: Implement Native Java Remote Inference [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/23 16:09:54 UTC, 0 replies.
- Re: [PR] Revert "Update transform catalogue docs" [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/06/23 16:34:23 UTC, 0 replies.
- [PR] Fix Flink XVR Tests for Flink 2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/23 18:35:38 UTC, 7 replies.
- [PR] Added schema_update_options to Python BigQuery writes [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/23 19:41:51 UTC, 4 replies.
- Re: [PR] Fix ThreadSanitizer data race and failed RPC calls [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/06/23 21:12:40 UTC, 4 replies.
- Re: [I] Python Postcommits timing out on postCommitIT [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/23 21:46:24 UTC, 1 replies.
- [PR] Fixed DirectRunner PubSub subscriber client lifecycle [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/24 00:45:43 UTC, 4 replies.
- Re: [PR] delta lake python/yaml [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/24 04:00:59 UTC, 3 replies.
- [PR] Bump actions/cache from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/24 04:25:42 UTC, 2 replies.
- [PR] [ReduceFnRunner] Fix Prefetches [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/24 08:05:11 UTC, 5 replies.
- [PR] [Dataflow Streaming] Increase stuck commit invalidation timeout to 1 hour [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/24 08:09:55 UTC, 4 replies.
- [PR] Add UnboundedCountingSource::to for bounded reads from an UnboundedCountingSource [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/24 09:23:35 UTC, 3 replies.
- [PR] [Dataflow Java Streaming] Add a timeout to how long commits will retry to the service. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/06/24 09:47:04 UTC, 7 replies.
- [PR] [mqtt] Retrigger Python Xlang Messaging PostCommit [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/24 11:17:26 UTC, 3 replies.
- [PR] [Gemini] Migrate Python BigQuery off of apitools client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/24 12:08:39 UTC, 2 replies.
- [PR] [mqtt] Fix streaming xlang IT failing the Messaging PostCommit [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/06/24 12:14:11 UTC, 6 replies.
- Re: [I] [Feature Request]: Parallel reading support in SparkReceiverIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/24 13:17:59 UTC, 0 replies.
- [PR] Add a github workflow to publish vllm image. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/24 14:04:46 UTC, 2 replies.
- Re: [I] MQTT IO connector for Python [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/24 14:06:48 UTC, 1 replies.
- Re: [I] [Feature Request]: Cache the BigQuery table definition instead of calling tables.get() from every worker [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/06/24 14:12:22 UTC, 0 replies.
- [PR] [Python] Bound Watch state with a timestamp cursor [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/06/24 14:52:07 UTC, 0 replies.
- Re: [I] JsonToRow can catch errors in downstream transforms [beam] - posted by "utkarshparekh (via GitHub)" <gi...@apache.org> on 2026/06/24 14:53:32 UTC, 1 replies.
- [PR] Revert #38863 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/24 15:52:42 UTC, 2 replies.
- [PR] Disable flaky SDF finalization tests [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/06/24 16:35:27 UTC, 2 replies.
- [PR] pdate changes log for yaml improvements etc [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/24 17:05:07 UTC, 0 replies.
- Re: [PR] update changes log for yaml improvements etc [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/24 17:05:16 UTC, 11 replies.
- Re: [I] Flaky python3 test in Python PreCommit [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/24 19:08:18 UTC, 0 replies.
- [PR] Fix cut_release_branch workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/24 19:34:03 UTC, 2 replies.
- [PR] Update beam-master [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/06/24 19:40:48 UTC, 4 replies.
- [PR] Fix race condition in DirectRunner executor shutdown [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/24 19:57:48 UTC, 10 replies.
- Re: [I] [Task]: Beam tft extra depends on old version of tensorflow-transform that requires protobuf v4. [beam] - posted by "potiuk (via GitHub)" <gi...@apache.org> on 2026/06/25 00:58:49 UTC, 0 replies.
- [PR] Initial zizmor [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/25 01:25:52 UTC, 5 replies.
- [PR] Fix JsonToRow swallowing downstream errors when runners fuse transforms. [beam] - posted by "utkarshparekh (via GitHub)" <gi...@apache.org> on 2026/06/25 02:37:26 UTC, 6 replies.
- [PR] Update cython requirement from <4,>=3.2.5 to >=3.2.6,<4 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:23:08 UTC, 2 replies.
- Re: [PR] Revert #38863 FnApi Java [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/25 06:59:10 UTC, 0 replies.
- Re: [I] [Task]: Setup a GCS based delta lake repo for integration testing [beam] - posted by "utkarshparekh (via GitHub)" <gi...@apache.org> on 2026/06/25 10:29:23 UTC, 0 replies.
- [I] [Java] context.Output within try catch can catch errors from downstream transforms [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/25 12:13:05 UTC, 3 replies.
- [PR] update changes log for yaml improvements etc (#39093) [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/25 12:23:19 UTC, 1 replies.
- Re: [PR] cherry-pick (#39093) [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 12:24:27 UTC, 3 replies.
- Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/25 12:43:21 UTC, 1 replies.
- Re: [I] [Bug]: Change reflection-based schema generation to generate deterministic schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:44 UTC, 1 replies.
- Re: [I] [Feature Request]: Golang support/documentation for unbounded DoFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:46 UTC, 1 replies.
- Re: [I] [Feature Request]: Add Spanner ChangeStream support to Golang [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:47 UTC, 1 replies.
- Re: [I] [Bug]: sdk-go anonymous dofn function some times not working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:49 UTC, 1 replies.
- Re: [I] [Task]: Create Colab Notebook for `WriteToFhir` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:51 UTC, 1 replies.
- Re: [I] [YAML] Add documentation to the Beam site. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:53 UTC, 1 replies.
- Re: [I] [Feature Request]: Create a Java/Scala Example in "Getting Started With Apache Spark" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:55 UTC, 1 replies.
- Re: [I] [Feature Request]: Allow metrics export to `DataflowRunner` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:57 UTC, 1 replies.
- Re: [I] [Feature Request]: Support all collections.abc types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:17:58 UTC, 1 replies.
- Re: [I] [Bug]: Codecov Python no longer accurate since Oct 12th missing most files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:18:00 UTC, 1 replies.
- Re: [I] [Task]: publish test results for GHA Python tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:18:02 UTC, 1 replies.
- Re: [I] [Feature Request]: Request Response IO for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:18:04 UTC, 1 replies.
- Re: [I] [Feature Request]: Control number of files or size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:18:06 UTC, 1 replies.
- Re: [I] [Bug]: Non-actionable and spammy " "warnings about GetWorkTimingInfosTracker.java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 13:18:07 UTC, 1 replies.
- [PR] remove infra change [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/25 14:03:18 UTC, 0 replies.
- Re: [PR] remove infra change comment in 2.75 release [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 14:03:44 UTC, 3 replies.
- [I] [Task]: Remove Zizmor findings [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/25 14:11:04 UTC, 0 replies.
- [PR] Revert pr 38983 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/25 15:11:34 UTC, 4 replies.
- [PR] Fix bq load for clashing copy job names [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/25 15:15:05 UTC, 9 replies.
- [PR] Add zizmor to existing precommit GHA workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/25 16:51:19 UTC, 7 replies.
- [PR] Avoid RequestResponseIO throttler access when throttler is absent [beam] - posted by "hoang-shyftplan (via GitHub)" <gi...@apache.org> on 2026/06/25 17:28:39 UTC, 10 replies.
- [PR] Fix OpenSearch username/password env fallback in examples [beam] - posted by "hoang-shyftplan (via GitHub)" <gi...@apache.org> on 2026/06/25 17:30:24 UTC, 6 replies.
- [PR] Bump google-cloud-aiplatform from 1.60.0 to 1.133.0 in /sdks/python/apache_beam/testing/benchmarks/cloudml [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 18:02:33 UTC, 3 replies.
- Re: [PR] Revert "[Python] Optimize BigQuery copy jobs in file loads using multi-source copy" [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/25 18:36:10 UTC, 2 replies.
- [PR] [release-2.75] Cherry-pick #39096 to the branch [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/25 18:48:57 UTC, 13 replies.
- Re: [I] Add support for dynamic destinations when writing to Kafka [beam] - posted by "mananmangal (via GitHub)" <gi...@apache.org> on 2026/06/25 20:30:48 UTC, 2 replies.
- [PR] including GitHub Actions to schedule daily audits and Add documentati… [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/25 20:41:40 UTC, 7 replies.
- [PR] [release-2.75] Cherry-pick #39100 to the branch [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/25 21:16:58 UTC, 3 replies.
- [PR] Fix flaky ML RunInference tests by disabling reshuffle on beam.Create [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/26 01:32:33 UTC, 4 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 04:23:59 UTC, 1 replies.
- [PR] [BigQuery] appends to tables can be asynchronous when doing copy jobs [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/26 08:10:17 UTC, 5 replies.
- [I] [Task]: Python quickstart lists outdated Python version support (missing 3.13, still lists 3.8) [beam] - posted by "jayjayakumar (via GitHub)" <gi...@apache.org> on 2026/06/26 09:34:24 UTC, 1 replies.
- [PR] Docs: update Python version support in Python quickstart [beam] - posted by "jayjayakumar (via GitHub)" <gi...@apache.org> on 2026/06/26 09:43:54 UTC, 7 replies.
- [PR] Fix typos in ExecutorServiceParallelExecutor.java [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/26 10:22:47 UTC, 4 replies.
- Re: [PR] Bump torch from 2.7.1 to 2.12.1 in /sdks/python/container/ml/py312 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 12:59:15 UTC, 2 replies.
- Re: [I] [Task]: Write artifacts in human readable form generated by MLTransform along with generated TF graph. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:15:55 UTC, 1 replies.
- Re: [I] [Bug]: Cannot use S3 with Cloudflare R2. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:15:56 UTC, 1 replies.
- Re: [I] [Feature]: Custom timestamps for Kinesis IO reader (currently always approx publish timestamp) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:16:04 UTC, 0 replies.
- Re: [I] [Test Fix]: Reduce size of Fhir IO integration tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:16:06 UTC, 0 replies.
- Re: [I] [Bug]: DirectRunner fails after grouping into batches, and applying flat map with assertion error [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:16:07 UTC, 0 replies.
- Re: [I] [yaml] Add resource hints to Beam YAML syntax [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:16:10 UTC, 0 replies.
- Re: [I] [yaml] Add Beam YAML Troubleshooting Guide [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 13:16:11 UTC, 0 replies.
- [PR] Avoid output inside try-catch in Java IO [beam] - posted by "Aryankn29 (via GitHub)" <gi...@apache.org> on 2026/06/26 13:56:12 UTC, 5 replies.
- Re: [PR] [release-2.75] Cherry-pick #39100 and #39106 to the branch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/06/26 14:33:51 UTC, 0 replies.
- [I] [Task]: Increase Yaml code coverage to a minimum of 80% overall [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/26 16:58:10 UTC, 0 replies.
- [PR] add more coverage for yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/26 16:59:59 UTC, 3 replies.
- [I] [Bug]: ClickHouseIO.Write hangs indefinitely on stalled connection — no socket/connect timeout configured on client-v2 [beam] - posted by "tomnewton (via GitHub)" <gi...@apache.org> on 2026/06/26 17:57:52 UTC, 2 replies.
- Re: [I] Replace cloudbuild_v1_client with Google Cloud Build client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/26 18:05:45 UTC, 1 replies.
- Re: [I] Replace dataflow_v1b3_client with a Google Cloud Python client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/06/26 18:06:27 UTC, 1 replies.
- [PR] Add ValidatesRunner cross-SDK test coverage comparison [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/06/26 18:41:41 UTC, 0 replies.
- [PR] fix race condition in statesampler with lock for reset [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/26 18:54:46 UTC, 6 replies.
- [PR] Bump gradle-wrapper from 8.12 to 9.6.1 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 20:13:19 UTC, 0 replies.
- [PR] Fix flaky GcsIOIntegrationTest and handle GCS bucket creation race conditions [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/26 22:29:23 UTC, 5 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 22:40:48 UTC, 1 replies.
- [PR] Fix a flaky test in ApproximateQuantilesTest [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/27 00:11:37 UTC, 8 replies.
- [I] Account Keys Compliance Issue Detected [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 00:21:47 UTC, 2 replies.
- [PR] Deduplicate messages in PubSub ordering key integration test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/27 08:24:48 UTC, 3 replies.
- Re: [PR] Fix dataframe warnings on ChainedAssignmentError [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/27 08:30:17 UTC, 0 replies.
- Re: [I] [Feature Request]: Set quota project in `beam.io.ReadFromBigQuery` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 12:55:10 UTC, 0 replies.
- Re: [I] [Bug]: Beam roles infra - Unable to run the Dataflow TPU example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 12:55:12 UTC, 0 replies.
- Re: [I] [Bug]: Add system/user prefix to getId in StateTable, CachingStateTable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 12:55:18 UTC, 1 replies.
- Re: [I] [yaml] Normalize io.gcp.DicomSearch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 12:55:31 UTC, 0 replies.
- Re: [I] [yaml] Normalize SnowflakeIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 12:55:33 UTC, 0 replies.
- [I] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/27 13:37:00 UTC, 6 replies.
- [PR] Implement GroupByKey translation for Kafka Streams runner (#18479) [beam] - posted by "boy397 (via GitHub)" <gi...@apache.org> on 2026/06/27 20:36:22 UTC, 3 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-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/06/27 22:36:23 UTC, 0 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/06/27 22:37:44 UTC, 1 replies.
- [PR] ci: pin GitHub Actions to full commit SHAs [beam] - posted by "XananasX7 (via GitHub)" <gi...@apache.org> on 2026/06/28 04:21:58 UTC, 1 replies.
- [PR] [GSoC 2026] Kafka Streams runner — GroupByKey (GlobalWindow, fire at watermark) [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/06/28 09:44:21 UTC, 25 replies.
- Re: [I] [yaml] Normalize MongoDBIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 13:00:39 UTC, 1 replies.
- Re: [I] [yaml] Normalize KinesisIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 13:00:40 UTC, 0 replies.
- Re: [I] [yaml] Normalize FirestoreIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 13:00:41 UTC, 0 replies.
- [PR] try to fix post commit yaml test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/28 18:03:14 UTC, 0 replies.
- [I] The LoadTests Python ParDo Flink Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 21:50:39 UTC, 1 replies.
- Re: [PR] fix post commit yaml test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/28 23:12:38 UTC, 10 replies.
- [PR] Bump cloud.google.com/go/storage from 1.62.3 to 1.63.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 04:25:31 UTC, 2 replies.
- [PR] Bump github.com/aws/smithy-go from 1.27.2 to 1.27.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 04:25:44 UTC, 2 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.6.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 04:25:51 UTC, 1 replies.
- [PR] Write append tables can be asynchronous (#39120) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/29 09:46:46 UTC, 3 replies.
- [PR] [OpenTelemetry] Add tracing support to GCP Spanner IO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/29 12:57:32 UTC, 3 replies.
- [PR] [OpenTelemetry] Add tracing support to GCP PubsubIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/29 13:00:13 UTC, 3 replies.
- [PR] [OpenTelemetry] Add tracing support to KafkaIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/29 13:01:42 UTC, 3 replies.
- [PR] [OpenTelemetry] Context propagation for Runner v1 and SimpleDoFnRunner [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/06/29 13:04:03 UTC, 4 replies.
- Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 13:54:04 UTC, 1 replies.
- Re: [I] [yaml] Normalize DebeziumIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 13:54:18 UTC, 0 replies.
- Re: [I] [Task]: Missing ValidatesRunner tests for watermark hold for bundle-cached elements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 13:54:21 UTC, 0 replies.
- [PR] [Cherry pick] - fix post commit yaml test (#39142) [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/29 14:10:00 UTC, 8 replies.
- Re: [PR] Fix flaky PubSub integration test by deduplicating messages [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/29 14:21:42 UTC, 2 replies.
- [PR] Use Flink 2.2 container for load tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/29 16:39:34 UTC, 3 replies.
- [PR] [IcebergIO] Cache destination Row keys in AssignDestinationsAndPartitions [beam] - posted by "atognolas (via GitHub)" <gi...@apache.org> on 2026/06/29 17:30:02 UTC, 4 replies.
- [PR] [IcebergIO] Use GroupByKey for bounded inputs to avoid OOM [beam] - posted by "atognolas (via GitHub)" <gi...@apache.org> on 2026/06/29 17:30:20 UTC, 5 replies.
- [PR] [IcebergIO] Fix stale openWriters count in RecordWriterManager [beam] - posted by "atognolas (via GitHub)" <gi...@apache.org> on 2026/06/29 17:30:39 UTC, 6 replies.
- [PR] [IcebergIO] Use partition-aligned manifests for faster query pruning [beam] - posted by "atognolas (via GitHub)" <gi...@apache.org> on 2026/06/29 17:31:00 UTC, 4 replies.
- [PR] Retry starting SubprocessServer on failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/29 17:40:53 UTC, 5 replies.
- [PR] Add query_output_schema to ReadFromBigQuery for BEAM_ROW + query support [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/06/29 19:21:13 UTC, 2 replies.
- [PR] [Interactive Beam] Fix caching deadlock, wait race conditions, and stale graph in notebooks [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2026/06/29 21:13:10 UTC, 2 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.25 to 1.32.26 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 06:55:47 UTC, 1 replies.
- Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.2 to 2.14.3 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 06:55:53 UTC, 1 replies.
- Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.8.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 06:55:59 UTC, 2 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.6.0 to 2.7.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 06:56:04 UTC, 1 replies.
- Re: [PR] Fix CloudML TFT benchmark deps for manylinux_2_28 Dataflow workers [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/06/30 07:29:50 UTC, 2 replies.
- Re: [PR] Upgrade TFX stack to 1.21.x and remove numpy/pandas bounds [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 07:59:58 UTC, 4 replies.
- [PR] Bump js-yaml from 3.14.2 to 3.15.0 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 08:49:48 UTC, 2 replies.
- Re: [PR] Deflake PreCommit Java watchForNewFiles [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 13:13:04 UTC, 0 replies.
- Re: [I] [Bug]: FlinkRunner does not correctly implement bundle requirements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/30 13:13:34 UTC, 0 replies.
- [PR] fix flakey fileiotest [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/30 13:31:14 UTC, 12 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.28 to 1.22.29 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/30 13:31:53 UTC, 0 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.24 to 1.19.25 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/30 13:33:15 UTC, 1 replies.
- Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.8.0 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/06/30 14:22:41 UTC, 1 replies.
- Re: [PR] Revert previous fixes and upgrade TFX stack to 1.21.0 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/30 16:10:06 UTC, 5 replies.
- [PR] Fix lost state updates in Set state [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/30 18:32:31 UTC, 4 replies.
- [I] [Feature Request]: Support random access in the Go Filesystem API (io.ReaderAt / io.ReadSeeker) [beam] - posted by "mdreizin (via GitHub)" <gi...@apache.org> on 2026/06/30 18:46:29 UTC, 0 replies.
- [PR] [GSoC 2026] Fixing the github action Unmanaged Service Account Keys [beam] - posted by "HansMarcus01 (via GitHub)" <gi...@apache.org> on 2026/06/30 19:46:32 UTC, 4 replies.
- [PR] Update managed-io.md for release 2.75.0-RC1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/30 19:53:42 UTC, 3 replies.
- Re: [I] MQTT IO should compute watermark and ack messages outside of finalizeCheckpoint method [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/30 20:07:02 UTC, 1 replies.
- [I] [Task]: Migrate Mqtt client [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/30 20:15:29 UTC, 0 replies.
- [PR] Migrate MqttIO to HiveMQ Mqtt client [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/30 20:46:50 UTC, 5 replies.
- [PR] Add "-Pjava21Home" to stage docker step in build_release_candidate workflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/06/30 21:23:27 UTC, 2 replies.
- Re: [PR] Revert previous workarounds and upgrade TFX stack to 1.21.0 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/06/30 22:09:47 UTC, 0 replies.