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

---

- Re: [PR] If the partition count or kafka IO size is large, then skip committin… [beam] - posted by "kishorepola (via GitHub)" <gi...@apache.org> on 2026/03/01 08:06:25 UTC, 3 replies.
- [PR] Bump minimatch from 3.1.2 to 3.1.5 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 08:55:16 UTC, 3 replies.
- [PR] Bump go.opentelemetry.io/otel/sdk from 1.38.0 to 1.40.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 08:55:26 UTC, 2 replies.
- Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:19:10 UTC, 4 replies.
- Re: [PR] [Iceberg] Support nested column paths in keep/drop configuration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:19:12 UTC, 6 replies.
- Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:19:14 UTC, 5 replies.
- Re: [PR] chore: udpate libraries-bom to 26.74.0-rc1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:47:29 UTC, 1 replies.
- Re: [PR] [BEAM-9917] Document BigQuery file load behavior with dynamic destinations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:47:32 UTC, 1 replies.
- Re: [PR] [yaml]: add kafka parameter explicitly and uncover kafka test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:47:34 UTC, 0 replies.
- Re: [I] [Bug]: WriteToPubSub silently failing to publish messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:47:40 UTC, 2 replies.
- Re: [I] [Feature Request]: [Streaming Engine Worker] Use more asynchronous processing for auxiliary streaming engine worker processing. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 12:47:45 UTC, 1 replies.
- [PR] RedisIO support PCollection of [beam] - posted by "MichaelGruschke (via GitHub)" <gi...@apache.org> on 2026/03/01 17:22:26 UTC, 6 replies.
- [PR] Bump minimatch in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 19:13:05 UTC, 5 replies.
- Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] - posted by "mtauha (via GitHub)" <gi...@apache.org> on 2026/03/01 19:39:51 UTC, 9 replies.
- [PR] Bump go.opentelemetry.io/otel/sdk from 1.29.0 to 1.40.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/01 22:20:12 UTC, 0 replies.
- [PR] Update java containers. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/02 02:25:09 UTC, 4 replies.
- Re: [I] Add Kafka Streams runner [beam] - posted by "MansiSingh17 (via GitHub)" <gi...@apache.org> on 2026/03/02 03:02:25 UTC, 2 replies.
- Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior (fixes #37445) [beam] - posted by "MansiSingh17 (via GitHub)" <gi...@apache.org> on 2026/03/02 03:35:12 UTC, 0 replies.
- [I] The CloudML Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 04:17:51 UTC, 2 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.3.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 04:28:20 UTC, 1 replies.
- Re: [PR] [release-2.72] Cherry-pick #37633 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/02 07:41:04 UTC, 0 replies.
- [PR] Cherrypick #37721 to release-2.72 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/02 08:02:42 UTC, 8 replies.
- [I] [Bug]: Yaml Dataflow - yaml provider - composite transform cant as middle transform [beam] - posted by "ZwxwZ (via GitHub)" <gi...@apache.org> on 2026/03/02 08:13:36 UTC, 2 replies.
- Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemtry context propagation [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/02 11:59:10 UTC, 5 replies.
- Re: [PR] [Drain] Reduce Fn Runner changes [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/02 12:02:01 UTC, 4 replies.
- Re: [PR] Adds bundleFinalizer support to Dataflow non-portable worker. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/02 12:21:12 UTC, 30 replies.
- Re: [PR] Add Go example for schema-transform nested field access [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:24:44 UTC, 8 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/03/02 12:24:52 UTC, 6 replies.
- Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:24:58 UTC, 4 replies.
- Re: [I] [Feature Request]: Support correct behavior of RequiresTimeSortedInput with AllowedLateness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:48:39 UTC, 0 replies.
- Re: [I] [Bug]: No "Operation ongoing ..." logs for the work threads stuck at deserializing DoFn in python pipelines [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:48:43 UTC, 1 replies.
- Re: [I] [Feature Request]: Add GCP Firestore IO connector for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:48:44 UTC, 1 replies.
- Re: [I] [Feature Request]: KafkaIO - redistribute by key [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 12:48:46 UTC, 1 replies.
- [PR] Pin aircompressor. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/02 14:21:41 UTC, 5 replies.
- [I] [Bug]: KafkaConnectUtils.debeziumRecordInstant() fails with NullPointerException on DELETE operations [beam] - posted by "tstangenberg (via GitHub)" <gi...@apache.org> on 2026/03/02 14:37:33 UTC, 2 replies.
- [PR] Add Iceberg Quickstart page [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/02 20:53:24 UTC, 16 replies.
- Re: [PR] Fix Python PostCommit Dependency [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/02 21:04:44 UTC, 64 replies.
- Re: [PR] [Python] Ad BigQuery Change History source. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/02 21:06:29 UTC, 18 replies.
- Re: [PR] SQL DDL documentation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/02 21:07:46 UTC, 9 replies.
- Re: [PR] Add a configuration to wait for session creation [beam] - posted by "tianz101 (via GitHub)" <gi...@apache.org> on 2026/03/02 21:08:06 UTC, 5 replies.
- Re: [PR] [Dataflow Java Runner] Add support for sending logs directly to Cloud Logging [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/02 23:09:26 UTC, 18 replies.
- [PR] Add more ParquetIo read options [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/03 02:08:55 UTC, 5 replies.
- Re: [PR] Update to latest go version [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/03 05:56:16 UTC, 0 replies.
- [PR] Update go version. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/03 06:22:20 UTC, 1 replies.
- [PR] Update go.mod [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/03 06:44:48 UTC, 1 replies.
- Re: [PR] [release-2.72] Update go.mod [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/03 06:51:19 UTC, 2 replies.
- [I] [Task]: Error prone issues & Code Clarity Bugs [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 09:45:14 UTC, 0 replies.
- [PR] Use JodaTime's static factories instead of the ambiguous constructors. [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 10:29:32 UTC, 18 replies.
- [PR] Error prone string concat when Preconditions is used [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 11:35:26 UTC, 8 replies.
- [PR] [Dataflow Java Streaming] Reset state using finally blocks instead of just catching Exception [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/03 12:04:28 UTC, 3 replies.
- [PR] Add foundational API for Unbounded Sources in Python SDK [beam] - posted by "shaheeramjad (via GitHub)" <gi...@apache.org> on 2026/03/03 12:19:10 UTC, 7 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/03/03 12:24:48 UTC, 13 replies.
- Re: [PR] Add OrderedListState support in Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:24:54 UTC, 8 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/03/03 12:25:01 UTC, 8 replies.
- Re: [PR] feat(ml): add stateless bundle-local size-aware batching and benchmark [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:03 UTC, 7 replies.
- Re: [PR] [Python][Java] Add support for record headers in WriteToKafka (Fixes #27033) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:11 UTC, 6 replies.
- Re: [PR] feat(io): Implement parallel reading in SparkReceiverIO (Fixes #37410) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:18 UTC, 4 replies.
- Re: [PR] support generics in from row and to row conversions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:24 UTC, 6 replies.
- Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:30 UTC, 6 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/03/03 12:25:35 UTC, 5 replies.
- Re: [PR] Added flag for overriding artifact hostname [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:44 UTC, 4 replies.
- Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:44 UTC, 5 replies.
- Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:46 UTC, 5 replies.
- Re: [PR] [IcebergIO] Add ITs for RESTCatalog using BLMS [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:25:49 UTC, 4 replies.
- Re: [I] [Task]: Remove support of Samza runner in new Beam versions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:18 UTC, 1 replies.
- Re: [I] [Task]: Improve the schema support for Beam 3.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:21 UTC, 1 replies.
- Re: [I] [Task]: Deduplicate Coders [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:23 UTC, 1 replies.
- Re: [I] [Task]: Default option changes for IO connectors (e.g., BigQuery IO), Runners (e.g., SA vs SE) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:26 UTC, 1 replies.
- Re: [I] [Feature Request]: Update the default behaviour in `BigQueryIO.Write.Method.DEFAULT` to `STORAGE_API_AT_LEAST_ONCE` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:30 UTC, 1 replies.
- Re: [I] [RRIO]: Implement RequestResponseIO using the Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/03 12:48:45 UTC, 0 replies.
- [PR] Where a Throwable is being caught, take care to rethrow OutOfMemoryError [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/03 13:00:33 UTC, 7 replies.
- [PR] [Dataflow Java Streaming] Ensure that OutOfMemoryError is propagated instead causing work item retry. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/03 13:26:36 UTC, 7 replies.
- [PR] [DebeziumIO] Implement startOffset for Kafka (#28248) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/03/03 14:22:05 UTC, 8 replies.
- [PR] datastore: Same key in mutation batch [beam] - posted by "noseglid (via GitHub)" <gi...@apache.org> on 2026/03/03 17:52:32 UTC, 6 replies.
- Re: [I] There should be no need to redirect to https, as that is done by the TLP server [beam] - posted by "boy397 (via GitHub)" <gi...@apache.org> on 2026/03/03 19:09:25 UTC, 0 replies.
- Re: [I] [Bug]: Prism panic when TestStream is followed by a stateful dofn [beam] - posted by "boy397 (via GitHub)" <gi...@apache.org> on 2026/03/03 19:14:06 UTC, 3 replies.
- [PR] Add default_pickle_library_override delegation to InteractiveRunner [beam] - posted by "praneetnadella (via GitHub)" <gi...@apache.org> on 2026/03/03 19:57:13 UTC, 4 replies.
- Re: [PR] Resolves pytest on ubuntu latest by installing pymilvus [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/03 20:02:11 UTC, 0 replies.
- [PR] Fix ErrorProne BadInstanceof warnings and enable check globally [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 20:53:59 UTC, 5 replies.
- Re: [PR] Omit state commits in stateful Dofn [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2026/03/03 21:29:16 UTC, 36 replies.
- Re: [PR] [Go SDK] Rewrite dot runner to generate DOT from portable pipeline proto [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2026/03/03 21:39:21 UTC, 8 replies.
- [PR] Refactor: Enable EmptyCatch Error Prone check and document ignored exceptions [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 22:01:48 UTC, 3 replies.
- [PR] Fix ErrorProne MalformedInlineTag and enable check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/03 22:11:17 UTC, 3 replies.
- [PR] update java container version to 03-03 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 04:07:47 UTC, 4 replies.
- [PR] Fix ProtectedMembersInFinalClass warnings and enable check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 07:49:00 UTC, 3 replies.
- [PR] Fix EqualsGetClass warnings and enable Error Prone check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 07:57:19 UTC, 1 replies.
- [PR] Fix `MissingSummary` errorprone Warnings Across Codebase [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 08:05:42 UTC, 1 replies.
- Re: [PR] [ErrorProne] Fix EqualsGetClass warnings and enable Error Prone check [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 09:14:50 UTC, 15 replies.
- Re: [PR] [Dataflow Java Streaming] Ensure shared state is reset on OutOfMemoryError and not just Exceptions [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/04 09:27:28 UTC, 0 replies.
- Re: [PR] [ErrorProne] Fix FormatStringShouldUsePlaceholders string concat when Preconditions is used [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/04 09:32:30 UTC, 0 replies.
- Re: [PR] [ErrorProne] Fix MalformedInlineTag and enable check [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 09:48:09 UTC, 5 replies.
- Re: [PR] [ErrorProne] Fix `MissingSummary` Warnings Across Codebase [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 10:16:14 UTC, 4 replies.
- Re: [PR] [ErrorProne] Fix ProtectedMembersInFinalClass warnings and enable check [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 10:16:17 UTC, 3 replies.
- [PR] [ErrorProne] Enable BadImport ErrorProne check and fix violations [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 10:21:41 UTC, 8 replies.
- [PR] [ErrorProne] Enable `MutablePublicArray` Error Prone Check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 10:44:50 UTC, 4 replies.
- [PR] [Dataflow Streaming] Add a pipeline option to skip input elements that cannot be decoded successfully [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/04 10:52:24 UTC, 11 replies.
- Re: [PR] Add Apache Beam installation to Dockerfile [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/04 10:58:44 UTC, 0 replies.
- Re: [PR] Add retry logic for transient commit failures in KafkaCommitOffset [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:23:40 UTC, 5 replies.
- Re: [PR] Add Python example for schema transforms (field selection) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:23:42 UTC, 5 replies.
- Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:24:05 UTC, 1 replies.
- Re: [PR] Exposed source window to AssignContext in window_mapping_fn for side inputs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:24:11 UTC, 7 replies.
- Re: [PR] Added TTL caching for BigQuery table definitions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:06 UTC, 1 replies.
- Re: [I] adding extra_header causing issue while reading GCS file in colab [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:22 UTC, 0 replies.
- Re: [I] [Task]: Use GCP-BOM to manage google cloud dependencies in sdks/java/extensions/ml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:24 UTC, 0 replies.
- Re: [I] [Feature Request]: Vertex AI Feature Store handler for Enrichment transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:26 UTC, 0 replies.
- Re: [I] [Feature Request]: [flink] Remove Java Serializaton of CoderTypeSerializer from Flink savepoints [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:28 UTC, 0 replies.
- Re: [I] [Failing Test]: 404 opensource.org/licenses cause java container build fail [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 12:48:32 UTC, 0 replies.
- [PR] [Direct Runner] Fix flaky test failure and logging configuration by ensuring overridden Loggers are not garbaged collected [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/04 12:54:04 UTC, 3 replies.
- [PR] [Java Portable SDK] Configure JVM so that it exits upon OutOfMemoryError originating in JVM. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/04 13:24:15 UTC, 9 replies.
- [PR] [ErrorProne] Fix UnnecessaryLambda Error Prone issues [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 13:35:45 UTC, 10 replies.
- [PR] [ErrorProne] Enable UseCorrectAssertInTests ErrorProne Check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 14:15:16 UTC, 3 replies.
- Re: [PR] create helper function [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 14:48:39 UTC, 2 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 14:49:37 UTC, 1 replies.
- Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 14:51:17 UTC, 0 replies.
- Re: [PR] [3/3] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 14:52:49 UTC, 0 replies.
- Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 14:53:40 UTC, 0 replies.
- Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/04 15:19:10 UTC, 5 replies.
- Re: [PR] [ErrorProne] JodaConstructors check - Use JodaTime's static factories instead of the ambiguous constructors. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/03/04 16:20:58 UTC, 6 replies.
- [PR] [ErrorProne] Enable StringCharset Error Prone Check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 16:59:53 UTC, 0 replies.
- [PR] [ErrorProne] Fix InlineFormatString checks [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 17:02:24 UTC, 5 replies.
- Re: [PR] [ErrorProne] Enable StringCharset Check [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 17:06:21 UTC, 3 replies.
- [PR] [ErrorProne] Enable LongDoubleConversion check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 17:44:50 UTC, 6 replies.
- Re: [PR] Disable combiner lifting only for count triggers [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/03/04 17:52:33 UTC, 4 replies.
- [PR] [ErrorProne] Fix UnusedVariable warnings across codebase [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 18:40:02 UTC, 16 replies.
- [PR] [Error Prone] Fix Slf4j formatting errors and enable Slf4jFormatShouldBeConst check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 19:03:35 UTC, 40 replies.
- [PR] [ErrorProne] Resolve Error Prone NonCanonicalType warnings across the codebase [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 19:38:44 UTC, 15 replies.
- [PR] [ErrorProne] Fix InvalidParam, InvalidInlineTag, InvalidBlockTag, and InvalidLink checks [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/04 20:54:48 UTC, 21 replies.
- [PR] Fix Python PostCommit Dependency: centralize Vertex AI test skip [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/04 21:09:32 UTC, 1 replies.
- Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] - posted by "nia-potato (via GitHub)" <gi...@apache.org> on 2026/03/04 21:23:48 UTC, 0 replies.
- Re: [I] [Feature Request]: Add S3-compatible storage support for Iceberg managed I/O [beam] - posted by "dejii (via GitHub)" <gi...@apache.org> on 2026/03/05 03:17:07 UTC, 1 replies.
- Re: [PR] Add Apache Beam installation to Beam Playground Container Dockerfile [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/05 06:08:06 UTC, 0 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/05 06:08:07 UTC, 0 replies.
- Re: [PR] [ErrorProne] Fix BadInstanceof and enable check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/05 10:40:57 UTC, 3 replies.
- [PR] [ErrorProne] Enable JavaTimeDefaultTimeZone check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/05 10:47:29 UTC, 18 replies.
- [PR] Fix python postcommit dependency 1 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/05 11:16:11 UTC, 2 replies.
- Re: [I] [Task]: Migrate generative Vertex AI usage to the google-genai package [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 12:48:23 UTC, 1 replies.
- Re: [I] [Task]: Enrich YAML supports for IOs, turnkey transforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 12:48:25 UTC, 1 replies.
- Re: [I] Updating a streaming pipeline fails due to an allegedly changed coder/type for FileIO.Write/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards step [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 12:48:39 UTC, 0 replies.
- Re: [I] [Feature Request]: Add with .withFormatFunction() equivalent to Python SDK BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 12:48:41 UTC, 0 replies.
- [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 12:49:16 UTC, 5 replies.
- Re: [PR] [ErrorProne] Enable EmptyCatch Error Prone check and document ignored exceptions [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/05 13:14:40 UTC, 4 replies.
- [I] [Failing Test]: org.apache.beam.sdk.io.gcp.spanner.changestreams.it.SpannerChangeStreamOrderedWithinKeyIT testOrderedWithinKey [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/05 13:19:07 UTC, 1 replies.
- [PR] pin minimatch ^3.1.4 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/05 16:24:17 UTC, 1 replies.
- [I] [Failing Test]: TestAnomalyDetection.test_multiple_detectors_without_aggregation_0 is possibly flaky [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/05 17:33:24 UTC, 1 replies.
- [PR] [Do not merge yet]Use hive-exec:core for compilation and and shaded for tests [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/05 17:36:16 UTC, 6 replies.
- Re: [PR] [typescript] - pin minimatch ^3.1.4 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 18:43:38 UTC, 4 replies.
- Re: [PR] Iceberg Add Files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 18:44:07 UTC, 18 replies.
- [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/05 22:31:54 UTC, 4 replies.
- [PR] Move FileIO close from RecordWriter to RecordWriterManager [beam] - posted by "dejii (via GitHub)" <gi...@apache.org> on 2026/03/06 04:18:07 UTC, 11 replies.
- Re: [PR] Add S3-compatible storage support for Iceberg managed I/O [beam] - posted by "dejii (via GitHub)" <gi...@apache.org> on 2026/03/06 04:22:21 UTC, 1 replies.
- [PR] [ErrorProne] Enable UnnecessaryLongToIntConversion check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 08:09:02 UTC, 8 replies.
- [PR] [ErrorProne] Enable UnsafeReflectiveConstructionCast check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 09:59:25 UTC, 10 replies.
- [PR] [ErrorProne] Fix UnnecessaryMethodReference Check Findings [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 10:53:14 UTC, 9 replies.
- [PR] [ErrorProne] Enable StaticAssignmentInConstructor check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 11:32:39 UTC, 7 replies.
- Re: [PR] Implemented ML Pipeline Continuous new table rows RunInference [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:22:42 UTC, 7 replies.
- Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:22:43 UTC, 2 replies.
- Re: [PR] Fix trigger example write append [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:22:45 UTC, 1 replies.
- Re: [PR] [Bug] Fix PubsubUnboundedSink not following 1000 messages per batch limit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:22:47 UTC, 5 replies.
- Re: [I] [Task]: Switch to SLF4J 2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:48:16 UTC, 2 replies.
- Re: [I] [Task]: Improve how to handle the Dataflow-specific option `impersonateServiceAccount` for Beam Java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:48:18 UTC, 0 replies.
- Re: [I] [Bug]: Python - SQL Transform fails with only one named PCollection [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/06 12:48:20 UTC, 0 replies.
- Re: [PR] [DebeziumIO] Implement startOffset & offset persistence for Kafka (#28248) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/03/06 13:55:26 UTC, 11 replies.
- [PR] [yaml] - add bigquery destination test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/06 14:46:14 UTC, 30 replies.
- [PR] [ErrorProne] enable ClassInitializationDeadlock, Finalize, NullableTypeParameter, ThreadPriorityCheck [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 15:01:47 UTC, 10 replies.
- Re: [I] [Task]: Update Python slowly updating side input example [beam] - posted by "shubhdevelops (via GitHub)" <gi...@apache.org> on 2026/03/06 15:42:31 UTC, 2 replies.
- Re: [PR] Add more ParquetIo write options [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/06 15:55:16 UTC, 1 replies.
- [PR] Add Python example for slowly updating global window side input pattern [beam] - posted by "shubhdevelops (via GitHub)" <gi...@apache.org> on 2026/03/06 16:07:36 UTC, 10 replies.
- [PR] cherry-pick: Add more ParquetIo write options (#37740) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/06 17:05:14 UTC, 5 replies.
- Re: [PR] Implement pluggable Lineage in Java SDK [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2026/03/06 17:14:37 UTC, 19 replies.
- [PR] [ErrorProne] enable JavaUtilDate, TimeUnitConversionChecker, InvalidThrows checks [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 19:43:47 UTC, 10 replies.
- [PR] [ErrorProne] Fix AutoValueBoxedValues warnings across the codebase [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/06 19:46:10 UTC, 15 replies.
- Re: [I] [Task]: Create a script to train sklearn model for IT test. [beam] - posted by "shubhdevelops (via GitHub)" <gi...@apache.org> on 2026/03/06 20:24:15 UTC, 0 replies.
- Re: [I] [Task]: Add more info on setting up alloy db instance in notebook [beam] - posted by "shubhdevelops (via GitHub)" <gi...@apache.org> on 2026/03/06 20:36:02 UTC, 3 replies.
- [PR] Improve AlloyDB notebook setup instructions by clarifying database cr… [beam] - posted by "shubhdevelops (via GitHub)" <gi...@apache.org> on 2026/03/06 20:50:10 UTC, 6 replies.
- [PR] Remove logging in tfrecordio.py [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/06 23:39:56 UTC, 5 replies.
- Re: [PR] Upgrade jetty version to 12.1.5 in build.gradle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 12:47:21 UTC, 2 replies.
- Re: [PR] fix: prevent state table collision by including system/user prefix [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/07 12:47:24 UTC, 1 replies.
- [PR] [Java][Debezium] Fix NPE in debeziumRecordInstant for DELETE events [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/08 01:02:29 UTC, 5 replies.
- [PR] [Code Review] Support UnboundSource [beam] - posted by "jason810496 (via GitHub)" <gi...@apache.org> on 2026/03/08 06:06:06 UTC, 2 replies.
- Re: [PR] Create PR by mistake [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 06:37:09 UTC, 0 replies.
- Re: [I] [Bug]: Go SDK not faithful to Runner's coder spec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 12:47:30 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Triton Inference Server support for RunInference transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 12:47:33 UTC, 0 replies.
- Re: [I] [Bug]: KafkaIO: Setup failures in downstream DoFn cause message loss with manual offset management [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 12:47:35 UTC, 0 replies.
- Re: [I] RAG: add OpenAI text embedding model [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/08 12:47:37 UTC, 1 replies.
- Re: [I] Beam Python PubSubIO Does Not Support Ordered Key Publishing [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/03/08 18:26:54 UTC, 1 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/03/08 18:47:09 UTC, 3 replies.
- [PR] [Dataflow Streaming] Remove nullness suppression of StreamingDataflowWorker [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/09 11:23:57 UTC, 7 replies.
- [PR] Fix flaky TextIOWriteTest by loosening the shard count [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/09 12:31:56 UTC, 3 replies.
- Re: [I] [Bug]: Default Pub/Sub batch size is smaller than the maximum message size, preventing the sending of large messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 12:48:33 UTC, 1 replies.
- Re: [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 12:48:36 UTC, 0 replies.
- Re: [I] Use topological sort during ProcessBundle in Java SDKHarness [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/09 14:25:12 UTC, 0 replies.
- Re: [I] The PostCommit Python Dependency job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/09 15:44:40 UTC, 0 replies.
- Re: [PR] Support inferring schemas from Python dataclasses [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/09 16:27:20 UTC, 12 replies.
- Re: [PR] [SpannerIO] Add low-latency configuration in Spanner Change Streams [beam] - posted by "tianz101 (via GitHub)" <gi...@apache.org> on 2026/03/09 17:34:28 UTC, 6 replies.
- [PR] Add py313 google-api-python-client dep [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/09 18:14:37 UTC, 6 replies.
- [PR] Fix PreCommit Python ML tests with ML deps installed [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/09 19:58:12 UTC, 3 replies.
- Re: [I] [Task] [IcebergIO]: Add RESTCatalog tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/09 20:43:35 UTC, 0 replies.
- Re: [PR] fix(python): Register all output pcollections of a transform rather than only ones that happened to be accessed in DoOutputsTuple [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/09 22:20:26 UTC, 1 replies.
- [PR] Revert "fix(python): Register all output pcollections of a transform rather than only ones that happened to be accessed in DoOutputsTuple" [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/09 22:20:53 UTC, 8 replies.
- [PR] Fix google-api-python-client python version bound [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/10 01:26:06 UTC, 4 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 06:48:32 UTC, 4 replies.
- [PR] Fix 36181 cloudml benchmarks job [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/10 10:42:47 UTC, 13 replies.
- Re: [PR] [DO NOT MERGE] schema update demo [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 12:48:43 UTC, 1 replies.
- Re: [I] [Bug]: PYTHON SDK / WriteToBigquery with STORAGE_WRITE_API fails when NULLABLE nested RECORD [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 12:48:50 UTC, 1 replies.
- Re: [I] [Bug]: Python SDK avro to beam schema conversion defaults to Any type for nullable atomic union fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 12:48:52 UTC, 1 replies.
- [PR] Fix loop error. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/10 13:23:35 UTC, 2 replies.
- [PR] Cherrypick #37730 to release 2.72 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/03/10 14:17:32 UTC, 4 replies.
- Re: [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 15:41:46 UTC, 0 replies.
- [PR] Cherrypick #37649 to release-2.72 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 15:51:57 UTC, 2 replies.
- [PR] Cherrypick #37642 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 15:53:54 UTC, 2 replies.
- [PR] Cherrypick #37717 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 15:55:32 UTC, 2 replies.
- [PR] Cherrypick #37719 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 15:58:03 UTC, 2 replies.
- [PR] Cherrypick #37619 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 16:01:51 UTC, 1 replies.
- [PR] update java container version to 03-10 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/10 16:03:12 UTC, 8 replies.
- [PR] update python container tag to 03-09 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/10 16:07:38 UTC, 20 replies.
- [PR] Cherrypick #37800 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 16:09:12 UTC, 2 replies.
- [PR] Cherrypick #37725 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/10 16:19:05 UTC, 2 replies.
- Re: [PR] [SpannerIO] Add low-latency configuration in Spanner Change Streams with Heartbeat changes [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/10 16:23:26 UTC, 14 replies.
- [PR] ClickHouseIO - Improve user agent [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2026/03/10 16:42:48 UTC, 6 replies.
- Re: [PR] Migrate to Google Cloud Dataflow Client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/10 18:52:45 UTC, 13 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/10 21:41:44 UTC, 4 replies.
- [PR] Loosen GRPC requirements. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/10 22:02:52 UTC, 6 replies.
- [PR] [release-2.72] Loosen GRPC requirements. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/10 22:08:58 UTC, 6 replies.
- [PR] Privilege Escalation POC [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/10 23:14:51 UTC, 1 replies.
- [I] [Bug]: Image Thumbnails for "Run In Colab" don't render correctly [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/10 23:40:36 UTC, 2 replies.
- [PR] Fix #21317: Replace colons with underscores in window filenames for Windows compatibility [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/11 00:50:39 UTC, 4 replies.
- [I] The PostCommit PortableJar Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 00:53:03 UTC, 3 replies.
- [I] The PostCommit PortableJar Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 00:53:06 UTC, 3 replies.
- [PR] Grpc followup [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/11 01:24:19 UTC, 1 replies.
- [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:16:56 UTC, 3 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:16:59 UTC, 3 replies.
- [I] The PostCommit Python Portable Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:02 UTC, 3 replies.
- [I] The PostCommit XVR Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:05 UTC, 3 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:08 UTC, 3 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:11 UTC, 3 replies.
- [I] The PostCommit XVR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:14 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/03/11 04:17:17 UTC, 3 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:21 UTC, 3 replies.
- [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:24 UTC, 3 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:28 UTC, 3 replies.
- [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 04:17:30 UTC, 3 replies.
- Re: [PR] Test POC [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/11 05:13:28 UTC, 0 replies.
- [I] [Feature Request]: add native, portable support for the Date data type within the Beam IcebergIO, ensuring it works smoothly from the Python SDK. [beam] - posted by "thanatham-google (via GitHub)" <gi...@apache.org> on 2026/03/11 09:22:12 UTC, 0 replies.
- Re: [I] ValueState could use an initial/default value [beam] - posted by "Ri1a (via GitHub)" <gi...@apache.org> on 2026/03/11 11:35:07 UTC, 0 replies.
- Re: [PR] Adds a new coder translator for Java SchemaCoder. [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/03/11 11:46:42 UTC, 3 replies.
- [PR] [Java SDK] Add ValueState.read(T defaultValue) overload [beam] - posted by "Ri1a (via GitHub)" <gi...@apache.org> on 2026/03/11 11:50:00 UTC, 5 replies.
- Re: [I] [Task]: Unable to load tensorflow hub models using TFModelHandler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 12:48:55 UTC, 0 replies.
- Re: [I] [Task]: Make non-benchmark IT tests for MLTransform part of Python Postcommit suite. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 12:48:57 UTC, 0 replies.
- [PR] [Drain] Expose drain to dofn processElement and onTimer [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/11 13:09:17 UTC, 10 replies.
- [PR] fix non-breaking TS vulnerabilities [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/11 14:28:24 UTC, 4 replies.
- [PR] Only pull license for selected tests and publishing container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/11 15:45:57 UTC, 8 replies.
- Re: [I] [Feature Request]: Support for inferring schemas from Python dataclasses [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/11 16:18:52 UTC, 1 replies.
- [PR] [Gemini] Fix bad-unpacking pyrefly error [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/11 16:31:29 UTC, 6 replies.
- [I] [Bug]: Beam playground pydot is not defined [beam] - posted by "Harrypotterrrr (via GitHub)" <gi...@apache.org> on 2026/03/11 17:59:00 UTC, 0 replies.
- [PR] Add portable Date type [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/11 20:43:43 UTC, 8 replies.
- [PR] SDF draining in runner v1 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/11 21:24:22 UTC, 4 replies.
- [PR] Skip intermediate python wheels on pull request trigger [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/11 22:52:58 UTC, 7 replies.
- Re: [PR] SDF draining in dataflow runner v1 [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/03/11 22:53:39 UTC, 9 replies.
- [I] [Bug]: sdk_harness_log_level_overrides not applied because root logger instead of named logger is being used [beam] - posted by "Chr96er (via GitHub)" <gi...@apache.org> on 2026/03/12 00:57:19 UTC, 1 replies.
- Re: [PR] docs: clarify JAVA_HOME and initial build expectations on Windows [beam] - posted by "Esmelealem (via GitHub)" <gi...@apache.org> on 2026/03/12 08:02:11 UTC, 0 replies.
- Re: [PR] docs: Clarify JAVA_HOME setup and initial build expectations for all OSes [beam] - posted by "Esmelealem (via GitHub)" <gi...@apache.org> on 2026/03/12 08:22:04 UTC, 2 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/12 12:06:17 UTC, 0 replies.
- [PR] Cherrypick #37668 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/12 12:12:57 UTC, 4 replies.
- [PR] security testing. do not merge. [beam] - posted by "workflow-security-testing (via GitHub)" <gi...@apache.org> on 2026/03/12 12:29:36 UTC, 85 replies.
- Re: [PR] [Iceberg SQL] Add iceberg CDC table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/12 12:48:20 UTC, 0 replies.
- Re: [I] [Feature Request]: Cross-language / Java support for Enrichment transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/12 12:48:24 UTC, 1 replies.
- Re: [I] [QUESTION] Running Beam using GO on Apache Flink k8s [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/12 12:48:27 UTC, 1 replies.
- [PR] Cherrypick #37817 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/12 13:56:32 UTC, 3 replies.
- [PR] Partly Revert #37832 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/12 15:18:42 UTC, 4 replies.
- [PR] Fix Run in Colab thumbnails blocked by CSP [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/12 16:05:01 UTC, 4 replies.
- [PR] Add a FailoverChannel wrapper on top of IsolationChannel to maintain a set of primary and failover channel. [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/03/12 21:26:44 UTC, 42 replies.
- [PR] apt-get upgrade in container images to install security fixes. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/12 21:55:46 UTC, 7 replies.
- [PR] Update managed-io.md for release 2.72.0-RC1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/12 22:03:53 UTC, 5 replies.
- [PR] upgrade vllm for vuln [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/12 22:49:23 UTC, 4 replies.
- [PR] [Dataflow Streaming] Remove rolled out Windmill isolated channels flag [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/13 02:32:16 UTC, 4 replies.
- [PR] [Dataflow Streaming] Remove rolled out Windmill separate heartbeat stream flag [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/13 02:45:26 UTC, 4 replies.
- [PR] [Dataflow Logging handler] Change @LazyInit to AtomicBoolean [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/13 03:40:41 UTC, 6 replies.
- [PR] [Dataflow Streaming] Prevent commit threads from sharing commit streams [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/13 04:02:17 UTC, 6 replies.
- [I] The Build python source distribution and wheels job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/13 04:17:23 UTC, 2 replies.
- [PR] [Dataflow Streaming] Create a separate option to control commit threads with direct path. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/13 04:19:22 UTC, 4 replies.
- Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/03/13 12:10:45 UTC, 3 replies.
- Re: [PR] [IcebergIO] Change writer open/close logs to debug [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/13 12:48:42 UTC, 2 replies.
- Re: [PR] [IcebergIO] load tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/13 12:48:45 UTC, 2 replies.
- Re: [PR] Regenerate beam container image dependencies to include newer version of grpc. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/13 13:34:27 UTC, 10 replies.
- Re: [I] Create a Watch transform in Python [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/03/13 15:01:20 UTC, 3 replies.
- [PR] Fix python postcommit 30513 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/13 15:05:52 UTC, 5 replies.
- [PR] Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/13 15:06:53 UTC, 3 replies.
- Re: [I] Support for custom Python UnboundedSource [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/03/13 15:08:16 UTC, 0 replies.
- [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/13 16:23:12 UTC, 32 replies.
- [PR] [typescript] - fix rest of vulnerabilities [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/13 17:33:48 UTC, 5 replies.
- [PR] Update python dev container tag [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/13 18:28:12 UTC, 7 replies.
- [I] [Task]: Beam tft extra depends on old version of tensorflow-transform that requires protobuf v4. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/13 19:25:34 UTC, 0 replies.
- [PR] Handle some cases during infer schema from dataclass [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/13 21:29:04 UTC, 23 replies.
- [PR] Revert "upgrade vllm for vuln" [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/03/13 22:36:55 UTC, 4 replies.
- [PR] Fix #37833: Use named logger instead of root logger in transforms/util.py [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/14 00:04:43 UTC, 3 replies.
- Re: [I] [Bug]: Schema inference is non-deterministic [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/14 12:48:03 UTC, 0 replies.
- Re: [I] [Feature Request]: Add integer and string _id keys support to Java IO MongoDB [beam] - posted by "0x1za (via GitHub)" <gi...@apache.org> on 2026/03/14 18:07:24 UTC, 0 replies.
- [I] The Python Cost Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/14 21:41:56 UTC, 1 replies.
- [PR] Pin zookeeper in expansion service [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/14 22:28:31 UTC, 3 replies.
- [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/14 22:39:16 UTC, 15 replies.
- Re: [PR] Include logger name in FnApiLogRecordHandler log entries [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 12:47:50 UTC, 2 replies.
- Re: [I] [Feature Request]: Implement Native Java Remote Inference [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 12:47:53 UTC, 0 replies.
- Re: [I] [GSOC 25] Enhanced Interactive Pipeline Development Environment for JupyterLab [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/15 12:47:56 UTC, 0 replies.
- Re: [I] TextIO.write .withWindowedWrites does not work on windows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/15 18:21:00 UTC, 0 replies.
- [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/15 19:42:21 UTC, 2 replies.
- [PR] feat: improve skill scores for apache/beam [beam] - posted by "popey (via GitHub)" <gi...@apache.org> on 2026/03/16 08:49:20 UTC, 6 replies.
- [PR] Cherrypick #37850 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/16 09:30:13 UTC, 3 replies.
- [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/16 09:58:32 UTC, 3 replies.
- Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/16 10:02:23 UTC, 5 replies.
- Re: [I] [Task]: Upgrade gcs-connector libraries to 3.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/16 12:49:14 UTC, 1 replies.
- Re: [I] [Feature Request]: Implement IBM MQ Sink Connector for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/16 12:49:15 UTC, 1 replies.
- Re: [I] [Bug]: Worker logs on Prism Stand-Alone Binary Not Appearing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/16 12:49:17 UTC, 1 replies.
- [PR] ci: update build configuration [beam] - posted by "beforetested-boop (via GitHub)" <gi...@apache.org> on 2026/03/16 12:59:06 UTC, 1 replies.
- Re: [PR] closed [beam] - posted by "beforetested-boop (via GitHub)" <gi...@apache.org> on 2026/03/16 13:14:16 UTC, 0 replies.
- Re: [I] Handling the restart with apache beam debezium application [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/16 14:56:18 UTC, 0 replies.
- Re: [I] [Bug]: Latest version (2.57) version of apache beam java sdk has dependecy on an old version of mongo driver (3.12) [beam] - posted by "KartikeyTripathi469 (via GitHub)" <gi...@apache.org> on 2026/03/16 15:33:34 UTC, 0 replies.
- Re: [I] [Bug]: Managed transforms API may produce obscure errors during SnakeYAML processing [beam] - posted by "KartikeyTripathi469 (via GitHub)" <gi...@apache.org> on 2026/03/16 15:33:54 UTC, 0 replies.
- [PR] Update managed-io.md for release 2.72.0-RC2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/16 17:26:26 UTC, 4 replies.
- [PR] Adding "new metadata" skill [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/16 17:29:59 UTC, 4 replies.
- Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] - posted by "KartikeyTripathi469 (via GitHub)" <gi...@apache.org> on 2026/03/16 17:40:32 UTC, 0 replies.
- Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] - posted by "KartikeyTripathi469 (via GitHub)" <gi...@apache.org> on 2026/03/16 17:42:09 UTC, 0 replies.
- Re: [I] Globbing asterisk cannot be escaped in file reads. [beam] - posted by "KartikeyTripathi469 (via GitHub)" <gi...@apache.org> on 2026/03/16 17:42:18 UTC, 0 replies.
- [PR] Update Beam website to release 2.72.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/16 19:02:06 UTC, 2 replies.
- [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2026/03/16 19:12:39 UTC, 3 replies.
- [PR] Fix maven archetype dependency for io-components [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/16 20:37:08 UTC, 5 replies.
- [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/03/16 21:52:53 UTC, 2 replies.
- [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/03/16 22:59:59 UTC, 5 replies.
- [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/17 10:04:38 UTC, 0 replies.
- [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/17 10:41:31 UTC, 2 replies.
- [I] [Task]: Getting started - Interactive Overview broken notebook URLs [beam] - posted by "severun (via GitHub)" <gi...@apache.org> on 2026/03/17 10:41:43 UTC, 1 replies.
- Re: [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/17 12:08:17 UTC, 4 replies.
- [PR] Fixes broken URLs in example notebooks [beam] - posted by "severun (via GitHub)" <gi...@apache.org> on 2026/03/17 12:30:24 UTC, 1 replies.
- Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/17 12:49:22 UTC, 0 replies.
- Re: [I] Matcher(s) for TableRow [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/03/18 16:40:37 UTC, 0 replies.
- Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/18 16:55:34 UTC, 4 replies.
- Re: [I] DebeziumIO cannot connect to cloud Postgres instances [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/18 17:06:01 UTC, 1 replies.
- Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/03/18 18:35:47 UTC, 3 replies.
- Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/18 18:57:32 UTC, 0 replies.
- [PR] Address no-access pyrefly error [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/18 19:43:04 UTC, 4 replies.
- Re: [I] [Feature Request]: allow consistent slog redirects [beam] - posted by "vgough (via GitHub)" <gi...@apache.org> on 2026/03/18 21:13:38 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/18 21:16:06 UTC, 2 replies.
- [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/03/18 23:55:18 UTC, 10 replies.
- [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/19 10:11:00 UTC, 3 replies.
- Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/03/19 11:23:21 UTC, 1 replies.
- [PR] [wip] update deserialization [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/19 11:43:34 UTC, 4 replies.
- Re: [I] [Bug]: Cannot read from ssl-enabled cassandra cluster [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/19 12:49:04 UTC, 0 replies.
- Re: [I] [Bug]: DualInputNestedValueProvider is not able to get Value properly if input is RuntimeValueProvider. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/19 12:49:05 UTC, 0 replies.
- Re: [PR] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/03/19 14:44:01 UTC, 0 replies.
- Re: [I] Introduce SchemaTransform API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/19 15:53:55 UTC, 1 replies.
- [I] [Task]: Python schema generated types uses schema registry and coder registry [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/19 16:01:18 UTC, 0 replies.
- Re: [PR] Optimize Kafka IO: Remove Guava Stopwatch overhead from consumer.poll() loop [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2026/03/19 16:27:28 UTC, 2 replies.
- [I] [Task]: update the yaml doc for composite transform changes [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/19 23:19:05 UTC, 1 replies.
- Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/19 23:38:59 UTC, 5 replies.
- [PR] Cherrypick #37871 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/20 08:36:26 UTC, 2 replies.
- [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/20 10:41:30 UTC, 6 replies.
- Re: [PR] [2/2] notebooks: add OpenAI text embeddings [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:21 UTC, 2 replies.
- Re: [I] [Bug]: Prism's handling of side inputs could fail sometime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:25 UTC, 0 replies.
- Re: [PR] [1/2] sdks/python: sink data with tecton feature store [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:31 UTC, 2 replies.
- Re: [PR] sdks/python: enrich data with tecton feature store [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:33 UTC, 2 replies.
- Re: [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:35 UTC, 0 replies.
- Re: [I] [Bug]: org.apache.avro.UnresolvedUnionException: Not in union after updating schema-registry [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/20 12:48:41 UTC, 1 replies.
- [PR] Update Go Version to 1.26.1 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/20 16:04:00 UTC, 3 replies.
- [PR] use sha hash for docker/setup-qemu-action [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/20 17:48:27 UTC, 7 replies.
- [PR] Allow sliding windows + combine with hot key fanout [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/20 19:57:18 UTC, 5 replies.
- [PR] GCS client library migration in Java SDK - part 3 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/03/21 02:49:10 UTC, 4 replies.
- Re: [I] [Bug]: Do not expose logging apis in beam/log [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 12:47:29 UTC, 0 replies.
- Re: [I] [Disabled Test]: :runners:spark:3:test ResumeFromCheckpointStreamingTest testWithResume is disabled due to flake rate [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 12:47:38 UTC, 0 replies.
- Re: [I] [Task]: Ensure the effective communications during the Beam 3.0.0 development process [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 12:47:40 UTC, 1 replies.
- Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/21 12:47:46 UTC, 0 replies.
- [PR] Fix #37894: Update yaml doc for composite transform changes [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/03/21 13:33:00 UTC, 3 replies.
- [PR] [ErrorProne] remove voidUsed check [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/21 16:40:53 UTC, 7 replies.
- [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/22 02:35:27 UTC, 6 replies.
- [PR] [Java IO] Add ArrowFlight IO connector [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/22 04:18:03 UTC, 3 replies.
- [I] [Performance]: Heavy CPU usage by org.github.jamm.MemoryMeter.measureDeep [beam] - posted by "MV-GH (via GitHub)" <gi...@apache.org> on 2026/03/22 12:01:07 UTC, 2 replies.
- [PR] Bump flatted from 3.4.1 to 3.4.2 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/22 14:38:44 UTC, 2 replies.
- [PR] Add hashes for staged files and relevant validations in boot [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/22 18:56:39 UTC, 1 replies.
- [I] The PreCommit Java GCP IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 01:00:16 UTC, 3 replies.
- [PR] Improved comments and readability in minimal_wordcount example [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/23 07:26:35 UTC, 3 replies.
- [PR] Add Quick Start section to README [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/23 07:45:36 UTC, 4 replies.
- [PR] improve Maven badge readability in README [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/23 07:49:54 UTC, 3 replies.
- [PR] Added a descriptive message tell about status badges [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/23 08:17:04 UTC, 3 replies.
- Re: [I] DataflowPipelineJob.waitUntilFinish() crashes when it has created a template. [beam] - posted by "udayaw (via GitHub)" <gi...@apache.org> on 2026/03/23 12:12:52 UTC, 0 replies.
- Re: [I] [Task]: Change sendState to handle state transition in a state machine [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:48:46 UTC, 1 replies.
- Re: [I] [Task]: Support Keras 3 in TFModelHandlers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:48:54 UTC, 1 replies.
- Re: [I] [Feature Request]: ElasticsearchIO Python SDK support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:48:57 UTC, 1 replies.
- Re: [I] [RRIO]: New static RequestResponseIO instantiating methods to accept call, setup, teardown lambdas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:48:59 UTC, 1 replies.
- Re: [I] [RRIO] Add a @ThrowableImmediately annotation for UserCodeExecutionException subclasses that signal throw behavior [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:49:03 UTC, 1 replies.
- Re: [I] [RRIO]: Use @AutoService(RetryWithBackoff.class) to communicate what Exceptions signal retry with backoff [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:49:07 UTC, 1 replies.
- Re: [I] [Feature Request]: Commit failed: value exceeding byte limit - [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 12:49:11 UTC, 1 replies.
- [PR] [Java] Optimize StreamUtils to avoid copying bytes [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/23 13:01:43 UTC, 7 replies.
- [PR] [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/23 13:10:03 UTC, 9 replies.
- [PR] Upgrade Docker setup actions to version 4 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/23 13:31:52 UTC, 3 replies.
- [PR] Update managed-io.md for release 2.72.0-RC3 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/23 13:48:16 UTC, 3 replies.
- [PR] [Post-release 2.71] Cherry pick #37889 into post release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/23 13:49:36 UTC, 4 replies.
- [PR] [WIP] Add ADK model handler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/23 14:42:24 UTC, 2 replies.
- [PR] Sync clickhouse resource manager client version with IO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/23 17:12:45 UTC, 2 replies.
- [PR] [Release-2.72] Cherry-pick #37918 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/23 17:49:08 UTC, 4 replies.
- [PR] Add version to beam-sdks-java-io-components [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/23 18:25:11 UTC, 2 replies.
- [PR] Cherrypick #37920 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/23 18:51:55 UTC, 2 replies.
- [PR] Pin docker actions to sha for now [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/23 19:53:49 UTC, 2 replies.
- [PR] Updates YAML Database transforms to use managed I/O by default [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/03/23 20:24:31 UTC, 3 replies.
- [PR] Pin version for setup-qemu-action [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/23 20:27:05 UTC, 2 replies.
- [PR] Bump cbor2 from 5.8.0 to 5.9.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/23 20:27:48 UTC, 1 replies.
- [PR] Pin gcp actions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/23 22:22:48 UTC, 3 replies.
- [PR] Pin to SHA for GCP GitHub Actions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/24 00:29:25 UTC, 3 replies.
- Re: [I] PGBKCVOperation is undocumented [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/24 04:36:15 UTC, 0 replies.
- [PR] Add docstring for PGBKCVOperations [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/24 04:55:13 UTC, 3 replies.
- Re: [I] [Task]: Go SDK: coder.RegisterCoder needs more precise docstring [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/24 04:59:33 UTC, 0 replies.
- [PR] Pin setuptools below 82 for TensorFlow Hub pkg_resources compatibility [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/24 10:00:55 UTC, 5 replies.
- Re: [PR] ib.collect support wait_for_inputs option [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 12:49:12 UTC, 2 replies.
- Re: [PR] Iceberg CDC streaming source [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 12:49:14 UTC, 2 replies.
- Re: [I] [Feature Request]: auto-detect schema in managed I/O [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 12:49:20 UTC, 0 replies.
- [I] [Bug]: ProcessManager does not reap child processes, causing zombie accumulation on long-running Flink deployments [beam] - posted by "andresti (via GitHub)" <gi...@apache.org> on 2026/03/24 13:49:53 UTC, 2 replies.
- [PR] Bump Java dev containers [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/24 13:56:48 UTC, 4 replies.
- Re: [I] [Task]: Add DatadogIO to website after 2.72 release [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/24 14:06:01 UTC, 0 replies.
- [PR] [#37930][Runners] Reap child processes in ProcessManager to prevent zombie accumulation [beam] - posted by "andresti (via GitHub)" <gi...@apache.org> on 2026/03/24 14:06:37 UTC, 4 replies.
- Re: [I] [Feature Request]: Add support to write record headers in `WriteToKafka` in python SDK [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2026/03/24 14:17:27 UTC, 0 replies.
- [PR] Add outstanding parameters to processElement and onTimer signatures [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/24 14:17:44 UTC, 6 replies.
- [PR] Cherrypick #37924 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/24 15:34:56 UTC, 2 replies.
- [PR] Cherrypick #37927 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/24 15:42:28 UTC, 2 replies.
- [PR] Update managed-io.md for release 2.72.0-RC5 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/24 17:16:32 UTC, 2 replies.
- [PR] Changes273 [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/24 17:48:22 UTC, 2 replies.
- Re: [PR] Add ADK model handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 18:51:25 UTC, 16 replies.
- [PR] remove processContext usage across examples (java and kotlin) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/24 19:00:24 UTC, 2 replies.
- [PR] [wip] Iceberg add files yaml transform and test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/24 19:18:35 UTC, 4 replies.
- [PR] Handle Flink 2 job server tag in releases and SDK snapshot [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/24 19:31:36 UTC, 4 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.12.4 to 2.12.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 20:39:21 UTC, 1 replies.
- Re: [PR] Allow tagged types in with_exception_handling. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/24 20:45:18 UTC, 2 replies.
- Re: [PR] Update changes.md [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/24 21:17:33 UTC, 1 replies.
- [PR] [Security] Bump PostgreSQL JDBC Driver from 42.2.16 to 42.7.10 [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/24 22:27:41 UTC, 9 replies.
- [I] [Security] Upgrade PostgreSQL JDBC Driver to fix CVE-2024-1597, CVE-2022-31197, CVE-2022-21724 [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/24 22:53:58 UTC, 1 replies.
- [I] [Security] Upgrade ActiveMQ from 5.14.5 to 5.19.2 to fix CVE-2023-46604 and other vulnerabilities [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/24 22:57:29 UTC, 1 replies.
- [PR] [Security] Bump ActiveMQ from 5.14.5 to 5.19.2 (fixes CVE-2023-46604) [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/24 23:22:13 UTC, 3 replies.
- [PR] [Integration] Expose length-aware batching in all ModelHandler subcla… [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/03/25 03:50:03 UTC, 2 replies.
- Re: [PR] [Integration] Expose length-aware batching in all ModelHandler subclasses [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 03:52:41 UTC, 9 replies.
- Re: [I] [Bug]: No parallelization for ReadFromParquet (or any Python Read transforms) in Spark RDD Runner [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/03/25 05:30:39 UTC, 0 replies.
- [PR] Improve docstring for PGBKCVOperation [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/25 09:12:24 UTC, 11 replies.
- Re: [I] Section 6.6 of the Apache Beam Python programming guide lacks examples [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/25 12:00:38 UTC, 0 replies.
- Re: [I] [yaml] Normalize ParquetIO [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/25 12:26:12 UTC, 1 replies.
- Re: [PR] Add Pyrefly Check PreCommit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 12:29:29 UTC, 3 replies.
- Re: [I] [Bug]: Documentation update: Correct parameter name for running YAML pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 12:49:06 UTC, 1 replies.
- Re: [I] [Bug]: Failing HL7v2IO Integration Test when upgrading BOM [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 12:49:20 UTC, 0 replies.
- [PR] [Java] Add ByteStringOutputStream.isEmpty() and reduce ByteStringOutputStream.size() calls [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/25 14:42:33 UTC, 5 replies.
- Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam] - posted by "nikitagrover19 (via GitHub)" <gi...@apache.org> on 2026/03/25 15:38:42 UTC, 14 replies.
- [PR] Fix typo in arc readme [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/25 15:42:08 UTC, 3 replies.
- [PR] Add Public Website documentation for RateLimiter [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/25 15:52:18 UTC, 8 replies.
- Re: [PR] [yaml] Iceberg add files yaml transform and test [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/25 17:44:32 UTC, 27 replies.
- [PR] Fix flaky SpannerChangeStreamOrderedByTimestampAndTransactionId IT [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/25 17:51:21 UTC, 4 replies.
- [PR] Remove log message waitStrategy for ClickhouseResourceManager [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/25 18:36:26 UTC, 3 replies.
- [PR] Iceberg AddFiles -- handle FileNotFound exceptions [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/25 18:45:15 UTC, 2 replies.
- [PR] Add explicit warning if cython is not available in setup.py [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/25 19:35:08 UTC, 2 replies.
- [PR] Moves finalize ids out of WorkItem proto and into AssembledWorkItem class. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/03/25 21:51:47 UTC, 5 replies.
- [PR] Bump picomatch from 2.2.2 to 2.3.2 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/25 21:53:37 UTC, 2 replies.
- [PR] [ML] Add AnthropicModelHandler for direct Claude inference [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/03/26 03:25:46 UTC, 4 replies.
- [I] [Task]: [beam] - posted by "sarathchandrakgcp-max (via GitHub)" <gi...@apache.org> on 2026/03/26 05:20:01 UTC, 1 replies.
- Re: [I] [Task]: In Apache Beam [beam] - posted by "sarathchandrakgcp-max (via GitHub)" <gi...@apache.org> on 2026/03/26 05:26:03 UTC, 1 replies.
- [PR] Add python example for nested fields in programming guide [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 07:10:42 UTC, 2 replies.
- [PR] Add python wildcard example for field selection [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 08:39:42 UTC, 4 replies.
- [PR] Add python array example [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 09:02:04 UTC, 4 replies.
- [PR] Add python map examples [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 09:07:01 UTC, 4 replies.
- Re: [I] Coder encode/decode context documentation is lacking [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 11:00:22 UTC, 1 replies.
- Re: [PR] Upgrade Snowflake JDBC client to v4 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 12:34:06 UTC, 2 replies.
- Re: [I] [Task]: Manage Infra privileges via Infra-as-code [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 12:49:35 UTC, 1 replies.
- Re: [I] [Bug]: worker failing on Dataflow runner v2 (Failed to handle for url) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 12:49:40 UTC, 1 replies.
- Re: [I] [Prism] Drain behavior [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 12:49:52 UTC, 0 replies.
- [PR] Bump requests from 2.32.4 to 2.33.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 13:41:10 UTC, 2 replies.
- Re: [PR] Fix Precommit Python Job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/26 13:44:08 UTC, 0 replies.
- Re: [PR] Fix PreCommit Python [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/26 13:44:12 UTC, 0 replies.
- [PR] Fix coder encode decode javadoc [beam] - posted by "Subramanya-Veeregowda (via GitHub)" <gi...@apache.org> on 2026/03/26 13:54:13 UTC, 5 replies.
- [PR] [Java Harness] Reapply optimization to use Caches.weigh on objects within cached blocks [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/26 13:57:22 UTC, 3 replies.
- [PR] [Python] Expand SDF by default in PortableRunner [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/03/26 14:01:44 UTC, 2 replies.
- [PR] Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 14:13:37 UTC, 3 replies.
- [PR] Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 15:13:05 UTC, 3 replies.
- [PR] Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 15:22:32 UTC, 1 replies.
- [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/26 15:40:31 UTC, 4 replies.
- [PR] Fix version of docker github action [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/26 15:54:57 UTC, 2 replies.
- [PR] ClickHouseIO - align the RM with the test containers upgrade [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2026/03/26 15:59:56 UTC, 3 replies.
- [PR] Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 16:07:11 UTC, 3 replies.
- [PR] Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 16:48:36 UTC, 3 replies.
- [PR] Add Staged Artifact validations for RunnerV2 [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/26 17:15:52 UTC, 5 replies.
- [PR] Bump requests from 2.32.4 to 2.33.0 in /infra/enforcement [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 17:19:19 UTC, 1 replies.
- [PR] Add batch Iceberg AddFiles yaml IT [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/26 18:06:51 UTC, 8 replies.
- [I] Migrate Jupyter Sidepanel extension to pip-based installation [beam] - posted by "zhaoyuanTian123 (via GitHub)" <gi...@apache.org> on 2026/03/26 18:23:33 UTC, 0 replies.
- [I] The PreCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/26 18:50:29 UTC, 1 replies.
- [PR] Bump picomatch from 2.3.1 to 2.3.2 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 00:58:47 UTC, 2 replies.
- [PR] Bump picomatch from 2.3.1 to 2.3.2 in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 01:05:23 UTC, 1 replies.
- [I] YAML Test CLI flag mismatch [beam] - posted by "zhaoyuanTian123 (via GitHub)" <gi...@apache.org> on 2026/03/27 01:11:24 UTC, 0 replies.
- [I] The PostCommit Go Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 04:22:17 UTC, 2 replies.
- [PR] Bump nodemailer from 7.0.11 to 8.0.4 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 07:12:17 UTC, 1 replies.
- [I] The PostCommit Go job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 09:49:46 UTC, 3 replies.
- [PR] [Java Harness] add waitForReady to logging stream and control stream to handle sdk starting before the runner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/03/27 12:10:07 UTC, 4 replies.
- Re: [I] [Task]: Add 3.13 GPU containers when dependencies are ready [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 12:49:01 UTC, 1 replies.
- Re: [I] [Task]: Tracking cloudpickle issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 12:49:13 UTC, 0 replies.
- Re: [I] [Bug]: Tour examples are not running [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 12:49:15 UTC, 1 replies.
- Re: [I] [Bug]: Mixed data types in _id field causing pipeline failures (SDK 2.53.0) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 12:49:19 UTC, 1 replies.
- Re: [I] [Bug]: year 0 is out of range when connecting to MongoDB Atlas (SDK 2.53.0) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 12:49:23 UTC, 1 replies.
- [PR] Fix PostCommit Go Dataflow ARM job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/27 13:37:13 UTC, 2 replies.
- [PR] Increase cloud tox job server timeout [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/27 14:24:53 UTC, 3 replies.
- [PR] Some terraform changes to make arc updates work [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/27 19:00:58 UTC, 4 replies.
- [PR] [yaml] Remove test_ReadFromBigQuery_ExternalJavaProvider_0 deselection [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/03/27 20:17:10 UTC, 9 replies.
- [PR] Bump node-forge from 1.3.2 to 1.4.0 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 21:15:52 UTC, 1 replies.
- [PR] Bump handlebars from 4.7.7 to 4.7.9 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/27 21:15:58 UTC, 2 replies.
- [I] The PreCommit Java Debezium IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 00:57:05 UTC, 2 replies.
- [PR] increase timeout via posargs [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/28 01:10:50 UTC, 12 replies.
- [I] Duplicate ShardedKey implementations in core module [beam] - posted by "zhaoyuanTian123 (via GitHub)" <gi...@apache.org> on 2026/03/28 05:11:43 UTC, 1 replies.
- [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] - posted by "christogav (via GitHub)" <gi...@apache.org> on 2026/03/28 12:06:29 UTC, 3 replies.
- Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 12:48:00 UTC, 0 replies.
- Re: [I] [Bug]: Need permission to add exceptions to CSP [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 12:48:05 UTC, 0 replies.
- Re: [I] [Failing Test]: PostCommitJava Sickbay perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 12:48:25 UTC, 0 replies.
- Re: [I] [Task]: Improve Windmill GRPC Streams [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/28 12:48:27 UTC, 0 replies.
- [PR] Add PubSub RateLimiter example [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/03/28 18:05:06 UTC, 5 replies.
- [PR] Run PreCommit RAT on Ubuntu 24.04 small pool [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/28 19:00:21 UTC, 1 replies.
- Re: [PR] Set quota project in beam.io.ReadFromBigQuery in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/29 12:48:02 UTC, 0 replies.
- Re: [I] [Bug]: TensorRT 10.x compatibility issues in TensorRTEngineHandlerNumPy [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/29 12:48:07 UTC, 1 replies.
- Re: [I] [Bug]: apache.calcite CannotPlanException: All the inputs have relevant nodes, however the cost is still infinite. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/29 12:48:14 UTC, 1 replies.
- Re: [I] [Bug]: Apache Beam SqlTransform does not process data distributed. It doesn't use multiple workers." [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/29 12:48:18 UTC, 1 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow V2 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/29 12:48:57 UTC, 1 replies.
- [I] [Bug]: Apache Beam Iceberg IO Does not work with Spark Serialization [beam] - posted by "barunkumaracharya (via GitHub)" <gi...@apache.org> on 2026/03/29 20:18:17 UTC, 0 replies.
- Re: [PR] Fix flaky DataflowRunnerTest by ignoring batch tests in streaming mode [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:49:34 UTC, 0 replies.
- Re: [I] [Bug][Prism]: Prism gets stuck when trying to flatten 2 unbounded pcollections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:49:45 UTC, 1 replies.
- Re: [I] [Bug]: apache_beam.dataframe.convert.to_pcollection() fails on deferred dataframe of csv with only header row [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:49:49 UTC, 1 replies.
- Re: [I] [Bug]: Cannot transform multiple PCollections to Dataframe using the apache_beam.dataframe.transforms.DataframeTransform function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:49:53 UTC, 1 replies.
- Re: [I] [Failing Test]: JmsIOTest. testCheckpointMark flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:49:58 UTC, 0 replies.
- [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 12:50:32 UTC, 4 replies.
- Re: [I] [Bug]: Apache Beam Managed Iceberg IO Does not work with Spark Serialization [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/30 12:58:42 UTC, 4 replies.
- [PR] Migrate pilot workflows to ubuntu-24.04 self-hosted pools [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/30 13:46:31 UTC, 3 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails with with external bigquery write [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/30 13:50:20 UTC, 0 replies.
- [PR] chore: update playground backend [beam] - posted by "workflow-security-testing (via GitHub)" <gi...@apache.org> on 2026/03/30 15:02:41 UTC, 0 replies.
- Re: [PR] security testing [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 15:04:39 UTC, 8 replies.
- Re: [PR] fixed incorrect python wildcard example [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/30 15:08:38 UTC, 1 replies.
- [PR] Revert "Migrate pilot workflows to ubuntu-24.04 self-hosted pools" [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/30 15:14:15 UTC, 2 replies.
- Re: [PR] [python][io] Add native unbounded GenerateSequence PTransform (#18088) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/03/30 15:32:44 UTC, 1 replies.
- [PR] Infra/pilot workflows ubuntu 24.04 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/30 17:27:06 UTC, 7 replies.
- [PR] Adjust schedule for long-running Java ValidatesRunner Dataflow Streaming variants [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/30 18:33:31 UTC, 4 replies.
- [PR] Bump pygments from 2.19.2 to 2.20.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 19:23:27 UTC, 2 replies.
- [PR] Bump pygments from 2.19.2 to 2.20.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 19:26:42 UTC, 2 replies.
- [PR] Bump pygments from 2.19.2 to 2.20.0 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 19:27:52 UTC, 3 replies.
- [PR] Bump pygments from 2.19.2 to 2.20.0 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 19:31:21 UTC, 3 replies.
- [PR] Migrate pilot workflows to ubuntu-24.04 self-hosted runners [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/30 19:32:01 UTC, 11 replies.
- [I] The PreCommit Python Runners job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/30 21:47:28 UTC, 1 replies.
- Re: [PR] Report source lineage from HadoopFormatIO [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2026/03/30 22:12:55 UTC, 1 replies.
- [I] [Bug]: BigQueryIO DIRECT_READ breaks for empty table during Bounded-to-Unbounded conversion [beam] - posted by "dorotaao (via GitHub)" <gi...@apache.org> on 2026/03/31 07:28:19 UTC, 0 replies.
- [PR] Fix vLLM worker [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/31 08:35:16 UTC, 3 replies.
- [PR] [BigQueryIO] Support reading from empty tables using Storage Read API in streaming pipelines [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/31 08:52:56 UTC, 7 replies.
- [PR] Bump to Beam 2.72.0 [beam-starter-java] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/31 09:10:01 UTC, 1 replies.
- [PR] Update default version in republish_released_docker_containers.yml [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/03/31 09:13:10 UTC, 2 replies.
- [PR] [#37994] Fix NullPointerException in Spark Runner with multiple outputs and serialization [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/03/31 09:46:11 UTC, 12 replies.
- [PR] Bump apache-beam from 2.71.0 to 2.72.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 12:03:47 UTC, 0 replies.
- Re: [I] [Task]: Reverse it component migration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 12:49:51 UTC, 0 replies.
- Re: [I] [Failing Test]: Typescript Dataflow tests are failing. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 12:49:54 UTC, 0 replies.
- Re: [I] [Bug]: GBK with global window must fit all values for a key into a memory [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 12:49:55 UTC, 1 replies.
- Re: [I] [Bug]: Test container leak [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 12:49:57 UTC, 0 replies.
- Re: [PR] Add Python 3.14 support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/03/31 15:34:15 UTC, 1 replies.
- [I] [Bug]: Improve performance of the Iceberg AddFiles transform [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/03/31 15:42:48 UTC, 1 replies.
- [I] [Bug]: Make fileio.MatchAll available to Beam YAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/03/31 15:47:38 UTC, 0 replies.
- [I] [Bug]: Make Reshuffle transform available to Beam YAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/03/31 16:27:37 UTC, 1 replies.
- [PR] Improve bq cdc scalability [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/03/31 16:30:30 UTC, 20 replies.
- [PR] Convert nanos to timstamptz [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/31 16:43:19 UTC, 3 replies.
- [I] [Bug]: 'Failed to copy Non partitioned table to Column partitioned table: not supported.' [beam] - posted by "tomaslink (via GitHub)" <gi...@apache.org> on 2026/03/31 17:45:03 UTC, 0 replies.
- [PR] [Iceberg AddFiles] Use thread pool to process incoming datafiles [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/03/31 17:50:05 UTC, 6 replies.
- [PR] Skip clean up versioned images [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/31 18:06:10 UTC, 3 replies.
- [PR] Update Python workflows to Ubuntu-24.04 runners [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/31 18:50:26 UTC, 5 replies.
- [PR] Update Google BOM to 26.79.0 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2026/03/31 19:29:07 UTC, 1 replies.
- [PR] Add GNU time to ARC runner image [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/03/31 19:37:37 UTC, 2 replies.
- [PR] Add 314_ml_test extra to setup.py [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/31 19:59:24 UTC, 1 replies.
- [PR] Downgrade Postgres driver to 42.6.2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/03/31 20:33:28 UTC, 3 replies.
- Re: [PR] Remove 3.14 runs from ML Tests [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/03/31 20:37:19 UTC, 0 replies.