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

---

- Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:14:24 UTC, 6 replies.
- Re: [PR] TFRecordIOSchemaTransformProviderTest - fix race condition [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:14:25 UTC, 6 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 2025/11/01 12:14:27 UTC, 5 replies.
- Re: [PR] Remove temporary KafkaSourceDescriptor.create function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:14:29 UTC, 5 replies.
- Re: [I] [Feature Request]: Make `Neo4jIO.WriteUnwind` output write statistics. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:46:17 UTC, 1 replies.
- Re: [I] [YAML][Feature Request]: Integration and Usage of GCP Secret Manager with the different Apache Beam IOs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:46:20 UTC, 1 replies.
- Re: [I] [Task]: Break up single pending stream commit into multiple commits [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/01 12:46:23 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 2025/11/02 00:50:17 UTC, 11 replies.
- Re: [PR] Fix Playground CI Nightly job [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/02 13:20:30 UTC, 0 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/02 13:20:32 UTC, 0 replies.
- Re: [PR] Fix PreCommit Java IO Direct Job [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/02 13:21:25 UTC, 0 replies.
- Re: [I] The PreCommit Java IOs Direct job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/02 13:21:27 UTC, 0 replies.
- Re: [PR] [1/2] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/11/02 18:23:32 UTC, 7 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/02 22:13:28 UTC, 3 replies.
- [PR] Timestam logicaltype [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/02 22:22:05 UTC, 0 replies.
- Re: [PR] [prism] Support BoundedTrie Metrics [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/11/03 02:53:27 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.1 to 1.20.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 04:15:25 UTC, 2 replies.
- Re: [I] [Bug]: Python type statement unsupported [beam] - posted by "pineapple-pokopo (via GitHub)" <gi...@apache.org> on 2025/11/03 09:19:28 UTC, 1 replies.
- Re: [PR] make use of generic type info in *Utils classes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 12:16:11 UTC, 8 replies.
- Re: [I] [Bug]: FnApiRunner does not handle event-time timer correctly. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 12:46:55 UTC, 0 replies.
- Re: [I] [Bug]: Samza runner fails to run a pipeline with Custom Window followed by Reshuffle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 12:46:58 UTC, 1 replies.
- Re: [I] [Feature Request]: Deterministic serialization of DoFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 12:47:01 UTC, 1 replies.
- Re: [PR] [IcebergIO] Change writer open/close logs to debug [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/03 14:09:03 UTC, 0 replies.
- Re: [PR] [IcebergIO] load tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/03 14:09:35 UTC, 0 replies.
- Re: [PR] make FieldValueTypeInformation creators take a TypeDescriptor parameter [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/03 14:15:21 UTC, 2 replies.
- Re: [PR] [yaml] - add max_read_time_seconds support to PubSub [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/03 14:21:00 UTC, 10 replies.
- Re: [PR] fix jsonToRowTest race condition [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/03 14:23:00 UTC, 3 replies.
- [PR] Install yaml extra when running yaml tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/03 14:53:00 UTC, 3 replies.
- Re: [PR] Adds fields to ProcessBundleRequest [beam] - posted by "wolfchris-google (via GitHub)" <gi...@apache.org> on 2025/11/03 14:53:10 UTC, 0 replies.
- [PR] Adds proto fields for overwriting fetch/write state functionality [beam] - posted by "wolfchris-google (via GitHub)" <gi...@apache.org> on 2025/11/03 15:03:55 UTC, 14 replies.
- Re: [PR] Only log Kafka commit failures every 10m and if failing for > 10m. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/11/03 15:54:35 UTC, 1 replies.
- [PR] feat(typehints): add Python 3.12 TypeAliasType support [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/03 15:57:49 UTC, 8 replies.
- Re: [PR] Fix warning message [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/03 16:14:51 UTC, 2 replies.
- Re: [PR] cherry-pick Free disk space for snapshot job and use correct requirements file (#36681) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/03 16:47:41 UTC, 3 replies.
- Re: [PR] Split some dependencies out of main beam package into existing extras [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 17:37:33 UTC, 3 replies.
- Re: [PR] Async Post Load Test Fixes [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2025/11/03 17:39:35 UTC, 2 replies.
- [I] [Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0 [beam] - posted by "JayajP (via GitHub)" <gi...@apache.org> on 2025/11/03 18:05:25 UTC, 0 replies.
- [PR] Add yaml when generating requirements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/03 18:06:53 UTC, 3 replies.
- Re: [I] [Task]: Switch to portable Data and Time type for JdbcIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/03 19:09:00 UTC, 0 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/03 19:09:59 UTC, 4 replies.
- [PR] Support portable decimal types for Beam SQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/03 19:11:17 UTC, 7 replies.
- Re: [PR] Add Iceberg CDC support to YAML and Blueprints [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/11/03 19:30:35 UTC, 15 replies.
- [PR] Multimap streaming [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/11/03 22:18:53 UTC, 3 replies.
- [PR] Bump github.com/aws/smithy-go from 1.23.1 to 1.23.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 04:08:27 UTC, 2 replies.
- [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/11/04 10:46:49 UTC, 10 replies.
- Re: [PR] [Java] Fix CassandraIO ReadFn to quote column names for reserved keywords [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:16:57 UTC, 9 replies.
- Re: [PR] [DO NOT MERGE] Test spark version - 2.55.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:05 UTC, 1 replies.
- Re: [PR] fix: support vector features in PyOD anomaly detection batching logic [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:08 UTC, 1 replies.
- Re: [I] [Bug]: WriteToIceberg YAML transform on PrismRunner not working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:11 UTC, 0 replies.
- Re: [I] [Bug]: ReadFromIceberg YAML transform cannot run with --runner DataflowRunner flag [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:14 UTC, 0 replies.
- Re: [I] [Bug]: Python event-time timers clearing behavior not consistent on different bundle sizes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:16 UTC, 0 replies.
- Re: [PR] [Gradle] Refactor Java toolchain selection using Gradle toolchain management [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:20 UTC, 1 replies.
- Re: [I] [Feature Request]: Interactive Beam supports asynchronous computations. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/04 12:47:24 UTC, 2 replies.
- Re: [PR] Streaming read for BigQuery [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/04 13:30:11 UTC, 9 replies.
- [PR] feat(io-gcp-bigquery): Add log for direct read quota exceeded retries [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/04 14:49:28 UTC, 3 replies.
- [PR] Fix Docker authentication for Python ValidatesContainer Dataflow With RC tests [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/04 14:56:26 UTC, 9 replies.
- Re: [PR] Remove Python 3.9 support from Apache Beam [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/04 15:55:23 UTC, 1 replies.
- [I] [Bug]: AssignContext for window mapping fn is missing source window when using side inputs [beam] - posted by "alexmalao1 (via GitHub)" <gi...@apache.org> on 2025/11/04 15:55:41 UTC, 2 replies.
- [PR] Iceberg direct write [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/11/04 16:01:49 UTC, 16 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.71.0 to 1.72.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/04 16:23:16 UTC, 0 replies.
- [PR] 30525 post commit validates container [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/04 17:25:57 UTC, 3 replies.
- [PR] Exposed source window to AssignContext in window_mapping_fn for side inputs [beam] - posted by "alexmalao1 (via GitHub)" <gi...@apache.org> on 2025/11/04 17:46:36 UTC, 6 replies.
- Re: [I] [Task]: Add MultimapState support for Dataflow FnAPI [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/11/04 18:11:58 UTC, 1 replies.
- Re: [PR] Kerberos auth python [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/11/04 18:35:56 UTC, 9 replies.
- Re: [PR] When more than one instance of the same PipelineOption subclass is detected, use the first one. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/11/04 19:54:42 UTC, 0 replies.
- Re: [I] [Task]: Add MultimapState support for Beam and Dataflow [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/04 20:09:15 UTC, 1 replies.
- Re: [I] [Bug]: KafkaIO cross-language not working with Go SDK v2.68 on Flink runner [beam] - posted by "StanleyNdunwere (via GitHub)" <gi...@apache.org> on 2025/11/04 20:16:39 UTC, 1 replies.
- [PR] Fix a distribution metric problem when count is zero [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/04 20:16:43 UTC, 0 replies.
- Re: [PR] [Prism] Fix a distribution metric problem when count is zero [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/04 20:17:08 UTC, 4 replies.
- Re: [PR] optimize grpc settings [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/04 20:36:59 UTC, 12 replies.
- Re: [PR] Create a BatchOnly category to exclude some batch tests from Dataflow Validates Runner Streaming [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/04 21:28:06 UTC, 0 replies.
- Re: [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/04 21:34:34 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.2 to 1.20.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:10:29 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.39.5 to 1.39.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:11:32 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.252.0 to 0.255.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:11:42 UTC, 2 replies.
- Re: [PR] Bump google.golang.org/api from 0.252.0 to 0.254.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:11:43 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.18.20 to 1.18.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:12:47 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.89.1 to 1.89.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 04:13:52 UTC, 3 replies.
- [PR] [1/3] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/11/05 06:25:50 UTC, 0 replies.
- Re: [PR] [2/3] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 06:26:26 UTC, 16 replies.
- Re: [PR] [1/3] sdks/python: refactor Milvus-related utilities as prepration step for Milvus Sink I/O integration [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/11/05 06:29:52 UTC, 0 replies.
- Re: [PR] Fix TensorRT compatibility with version 10.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 12:16:43 UTC, 4 replies.
- Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 12:16:49 UTC, 5 replies.
- [PR] Fix Flink IllegalThreadStateException on Java 8 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/05 14:16:18 UTC, 12 replies.
- Re: [PR] Add timestamo logicaltype [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/05 14:42:52 UTC, 0 replies.
- Re: [PR] Add timestamp logicaltype [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 14:44:08 UTC, 3 replies.
- [PR] Clean up setup.py to remove old version restrictions [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/05 16:17:05 UTC, 4 replies.
- [PR] Remove 3.9-specific branches in typehinting module [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/05 16:30:10 UTC, 5 replies.
- [PR] Bump DF Python container tag [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/05 18:04:40 UTC, 4 replies.
- [PR] fix pip intall command [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/05 18:13:50 UTC, 0 replies.
- Re: [PR] fix pip intall command in code changes [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 18:15:01 UTC, 0 replies.
- Re: [PR] [WIP] Java Native Remote Inference [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/05 18:23:05 UTC, 0 replies.
- [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/05 18:26:56 UTC, 5 replies.
- Re: [PR] fix pip install command in code changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/05 18:42:53 UTC, 1 replies.
- Re: [PR] [KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/05 19:57:44 UTC, 1 replies.
- Re: [I] [Feature Request]: Port ReadAllFromBigQuery from Python to Java [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/05 19:59:54 UTC, 0 replies.
- [I] [Feature Request]: Add state sampling for timer processing in the Python SDK [beam] - posted by "ktalluri456 (via GitHub)" <gi...@apache.org> on 2025/11/05 20:19:21 UTC, 2 replies.
- [PR] [BEAM-36736] Add state sampling for timer processing in the Python SDK [beam] - posted by "ktalluri456 (via GitHub)" <gi...@apache.org> on 2025/11/05 20:49:04 UTC, 22 replies.
- Re: [PR] [1/3] sdks/python: refactor Milvus-related utilities as preparation step for Milvus Sink I/O integration [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/05 21:37:32 UTC, 3 replies.
- [PR] Utilizes file_interceptor parameter and sets it to get_normalized_path() function. [beam] - posted by "praneetnadella (via GitHub)" <gi...@apache.org> on 2025/11/06 00:21:36 UTC, 10 replies.
- Re: [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/06 02:32:34 UTC, 0 replies.
- [PR] Bump github.com/docker/docker from 28.5.1+incompatible to 28.5.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 04:09:56 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.89.2 to 1.90.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 04:11:05 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.3 to 1.20.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 04:12:18 UTC, 2 replies.
- Re: [PR] Java Native Remote Inference [beam] - posted by "Ganeshsivakumar (via GitHub)" <gi...@apache.org> on 2025/11/06 07:16:06 UTC, 16 replies.
- [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers in WindmillBag [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/11/06 08:29:34 UTC, 19 replies.
- [PR] [Dataflow Streaming] Replace HashBasedTable with HashMap in CachingStateTable [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/11/06 09:54:21 UTC, 9 replies.
- Re: [PR] fix(iceberg): 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 2025/11/06 12:16:11 UTC, 7 replies.
- Re: [PR] Added flag for overriding artifact hostname [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 12:16:13 UTC, 4 replies.
- Re: [PR] sdks/python: enrich data with tecton feature store [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 12:47:16 UTC, 1 replies.
- Re: [I] [Feature Request]: Cap number of keys in Reshuffle.viaRandomKey [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 12:47:22 UTC, 1 replies.
- Re: [I] [prism] Using Real Time, when operating in "production" mode. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 12:47:26 UTC, 1 replies.
- Re: [PR] [Java] Dataflow runner v1 - Propagate drain mode [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/06 13:57:09 UTC, 14 replies.
- Re: [PR] Update BOM to 26.71.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/11/06 14:55:46 UTC, 4 replies.
- Re: [PR] Enable real-time clock in prism by default. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/06 14:58:42 UTC, 0 replies.
- Re: [I] [Bug]: PrismRunner fails to execute pipeline that DirectRunner succeeds at [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/06 15:27:30 UTC, 2 replies.
- [PR] Fix Docker image tagging for buildx by pulling when missing [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/06 15:35:25 UTC, 5 replies.
- [PR] Unpin the pip version in setupVirtualenv [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/06 15:55:00 UTC, 4 replies.
- [I] [Feature Request]: Warn when a user's ValueState looks like it could use a better state type [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/06 17:05:05 UTC, 0 replies.
- [I] The PostCommit PortableJar Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 18:44:32 UTC, 2 replies.
- Re: [PR] Bump transformers from 4.36.0 to 4.53.0 in /sdks/python/apache_beam/examples/inference/large_language_modeling [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/06 19:05:39 UTC, 0 replies.
- [PR] Fix SCIO Playground [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/11/06 19:40:04 UTC, 3 replies.
- Re: [I] BeamCalcRel implementation of date/time types aren't always Integer [beam] - posted by "vampire-hunter-lincoln (via GitHub)" <gi...@apache.org> on 2025/11/06 20:23:09 UTC, 0 replies.
- [PR] Split some requirements into extras [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/06 20:55:02 UTC, 2 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 21:36:04 UTC, 3 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 21:36:08 UTC, 6 replies.
- [PR] Make RestrictionTrackers.getProgress unblocking [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/06 21:40:22 UTC, 18 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/06 22:14:42 UTC, 1 replies.
- [PR] chore: fix typos in some files [beam] - posted by "khanhkhanhlele (via GitHub)" <gi...@apache.org> on 2025/11/07 03:18:57 UTC, 4 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.39.0 to 0.40.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/07 04:08:16 UTC, 2 replies.
- [I] [Bug]: Add system/user prefix to getId in StateTable, CachingStateTable [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/11/07 10:01:44 UTC, 0 replies.
- [PR] Change FakeClock.sleep() to be safely re-entrant in attempt to fix StreamingDataflowWorkerTest flakes. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/07 11:16:18 UTC, 4 replies.
- [PR] [Website] Clickable cards for cases without links [beam] - posted by "chermenin (via GitHub)" <gi...@apache.org> on 2025/11/07 12:38:17 UTC, 3 replies.
- Re: [I] [Task]: Update Trivial Inference documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/07 12:46:47 UTC, 0 replies.
- Re: [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/07 12:46:49 UTC, 0 replies.
- [PR] Add artifactregistry.writer role to beam-github-actions service account [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/07 13:40:37 UTC, 7 replies.
- [PR] 30519 fix postcommit xvr java dataflow [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/07 13:42:11 UTC, 1 replies.
- Re: [PR] Fix PostCommit XVR GoUsingJava Dataflow job [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/07 14:17:05 UTC, 7 replies.
- Re: [PR] Fix problems leading to Teardown not being called [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/07 14:27:18 UTC, 4 replies.
- [PR] Example of changing bounded read to not do the read within tryClaim. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/07 14:56:15 UTC, 0 replies.
- Re: [I] Section 6.6 of the Apache Beam Python programming guide lacks examples [beam] - posted by "ParmRandhawa (via GitHub)" <gi...@apache.org> on 2025/11/07 16:51:09 UTC, 0 replies.
- [PR] Changes multimap entries Iterable to make a deep copy of pending adds and deletes [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/11/07 17:29:56 UTC, 5 replies.
- [PR] upgrade pg8000 version [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/07 17:38:15 UTC, 4 replies.
- [I] The PostCommit Java Dataflow V1 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/07 18:41:44 UTC, 2 replies.
- [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/07 18:41:48 UTC, 3 replies.
- [PR] Exclude streaming bigquery it tests on test runners [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/07 19:28:56 UTC, 4 replies.
- [PR] Bump dataflow java container version to beam-master-20251107 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/07 19:46:15 UTC, 5 replies.
- [PR] Fix BigQueryIODynamicReadIT to use failing parser [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/07 20:24:53 UTC, 4 replies.
- Re: [PR] Priority to BigQueryProject for executeExtract [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:14:25 UTC, 1 replies.
- Re: [PR] Update ChangeStreamDao to query different TVF for postgresSQL based on the change stream partition mode [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:14:26 UTC, 1 replies.
- Re: [PR] [SQL] add SHOW command [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:14:27 UTC, 11 replies.
- Re: [I] [API Update]: AlloyDBVectorWriterConfig Changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:46:27 UTC, 0 replies.
- Re: [I] [Task]: Add YAML examples using Cloud SQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:46:29 UTC, 1 replies.
- Re: [I] [Bug]: Concurrent exception with ReadFromKafka YAML transform on PrismRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 12:46:32 UTC, 2 replies.
- Re: [I] [Feature Request]: BigQuerySource executeExtract() for EXPORT method should use BigQuery project [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/08 15:49:17 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 22:13:25 UTC, 1 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/08 22:13:33 UTC, 1 replies.
- Re: [I] [Bug]: JMSIO.Write should better handle connection issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/09 12:46:10 UTC, 0 replies.
- Re: [I] [Bug]: Latest.Globally() issues in global window [beam] - posted by "paragkharad2007-star (via GitHub)" <gi...@apache.org> on 2025/11/09 14:27:43 UTC, 1 replies.
- [PR] Bump golang.org/x/sync from 0.17.0 to 0.18.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 04:11:06 UTC, 3 replies.
- [PR] Bump golang.org/x/sys from 0.37.0 to 0.38.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 04:11:10 UTC, 2 replies.
- [PR] Bump golang.org/x/oauth2 from 0.32.0 to 0.33.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 04:11:19 UTC, 2 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.9.0 to 1.10.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 04:11:27 UTC, 3 replies.
- [PR] Bump golangci/golangci-lint-action from 8 to 9 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 04:16:20 UTC, 3 replies.
- [PR] Fix Python 3.10 workflows [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/11/10 09:18:38 UTC, 2 replies.
- Re: [PR] feat: Qdrant Search Handler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 12:46:51 UTC, 2 replies.
- Re: [PR] [Iceberg SQL] Add iceberg CDC table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 12:46:52 UTC, 0 replies.
- Re: [I] [Bug]: Workflow hangs during dependency installation with Pip 25.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 12:46:59 UTC, 1 replies.
- Re: [I] [Bug]: Unable to Restart Google Spanner Change Streams Consumer due to tableExists(table_name) bug [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/10 12:47:02 UTC, 1 replies.
- [PR] Remove `gradle-wrapper.jar` from source tree [beam] - posted by "snazy (via GitHub)" <gi...@apache.org> on 2025/11/10 14:03:28 UTC, 5 replies.
- [PR] split redis into extra [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/10 16:28:12 UTC, 3 replies.
- [PR] split hdfs into extra [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/10 16:30:31 UTC, 5 replies.
- [PR] Move DataflowRunnerTest.java references to Python 3.10 containers [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/10 16:33:35 UTC, 3 replies.
- [I] [Bug]: Type hints lost in core transforms [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/10 16:57:35 UTC, 2 replies.
- [PR] Type inference tests [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/10 17:22:23 UTC, 8 replies.
- [PR] Dont use platform separator for docker build paths. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/10 17:53:59 UTC, 3 replies.
- Re: [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/10 18:09:07 UTC, 0 replies.
- [I] [Bug]: Add SchemaFieldNumber annotations to Iceberg to prevent potential update compatibility issues [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/11/10 20:54:31 UTC, 1 replies.
- [PR] Master [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2025/11/10 21:46:37 UTC, 8 replies.
- [PR] Adds SchemaFieldNumber annotations to Iceberg classes that use the SchemaCoder [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/11/10 21:59:21 UTC, 3 replies.
- [PR] Add pluggable LineageReporter interface [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2025/11/10 22:23:17 UTC, 0 replies.
- [PR] added determeinistic uuid helper and updated the pickler to take in a… [beam] - posted by "praneetnadella (via GitHub)" <gi...@apache.org> on 2025/11/10 23:15:01 UTC, 5 replies.
- Re: [I] [Bug]: Dataflow pre-build with Cloud Build fails when run from Windows due to incorrect backslash (\) in Artifact Registry image path [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/11/11 03:10:57 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.17 to 1.31.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/11 04:10:03 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.4 to 1.20.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/11 04:11:12 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.18.21 to 1.18.22 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/11 04:12:18 UTC, 3 replies.
- Re: [PR] BeamRowWrapper [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/11 12:46:50 UTC, 2 replies.
- Re: [I] [Task]: Remediate CVE-2024-28397 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/11 13:41:04 UTC, 0 replies.
- [PR] Fix flaky GCS bucket deletion in test_create_default_bucket [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/11 14:07:41 UTC, 8 replies.
- [PR] Update GCP-BOM, unpin GCP Spanner version [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/11 15:26:09 UTC, 4 replies.
- [PR] Check that billing project is not null in BigQuerySourceBase [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2025/11/11 17:06:43 UTC, 5 replies.
- [PR] eTandem pool sdk example [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/11 17:38:35 UTC, 0 replies.
- [I] [Feature Request]: [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2025/11/11 17:53:24 UTC, 1 replies.
- Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2025/11/11 18:00:47 UTC, 5 replies.
- Re: [PR] Add Iceberg Streaming Write example with Beam SQL [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/11 18:34:36 UTC, 0 replies.
- [PR] Handle query returned with empty rows gracefully on bigquery enrichmement [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2025/11/11 18:48:27 UTC, 18 replies.
- [I] [Failing Test]: Spanner change stream tests failing on latest GCP BOM [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/11 19:18:37 UTC, 5 replies.
- [PR] Bump Beartype bounds to >= 0.22.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/11 19:42:54 UTC, 7 replies.
- [PR] Added function for deterministic ID for class definitions by hashing. [beam] - posted by "praneetnadella (via GitHub)" <gi...@apache.org> on 2025/11/11 19:49:43 UTC, 18 replies.
- Re: [PR] [SQL] Alter Catalog and Table statements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/11 20:37:59 UTC, 6 replies.
- Re: [PR] Implement pluggable Lineage in Java SDK [beam] - posted by "shnapz (via GitHub)" <gi...@apache.org> on 2025/11/11 21:30:00 UTC, 1 replies.
- [PR] [Do not merge] [BEAM-36736] Add state sampling for timer processing [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/11/11 22:19:26 UTC, 0 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 03:47:50 UTC, 6 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.18 to 1.31.19 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 04:10:16 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.18.22 to 1.18.23 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 04:11:27 UTC, 3 replies.
- [PR] Bump github.com/tetratelabs/wazero from 1.9.0 to 1.10.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 04:11:37 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.4 to 1.20.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 04:14:12 UTC, 3 replies.
- [PR] Fix Post Commit Transform Service [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/12 12:18:13 UTC, 5 replies.
- [PR] Fix CVE-2025-59250 in iceberg hive [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/12 12:44:07 UTC, 4 replies.
- Re: [PR] RAG: add OpenAI text embedding model [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 12:56:05 UTC, 1 replies.
- Re: [I] Getting error while using JdbcIO.ReadWithPartitions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/12 12:56:07 UTC, 0 replies.
- Re: [PR] Trigger dill workflow. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/12 16:31:04 UTC, 0 replies.
- Re: [PR] Add Iceberg CDC support to YAML [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/12 17:07:17 UTC, 9 replies.
- [PR] Convert pipeline.py type comments to type hints [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/12 17:24:11 UTC, 8 replies.
- Re: [PR] Enabled path normalization when enable_best_effort_determinism set to… [beam] - posted by "praneetnadella (via GitHub)" <gi...@apache.org> on 2025/11/12 18:33:58 UTC, 0 replies.
- Re: [PR] Support custom id function in async_dofn [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/13 01:44:49 UTC, 0 replies.
- [PR] Bump commons-cli:commons-cli from 1.9.0 to 1.11.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 04:08:03 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 04:08:20 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.4 to 1.20.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 04:09:41 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.18 to 1.31.20 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 04:12:08 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.18.22 to 1.18.24 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 04:13:23 UTC, 3 replies.
- [PR] Update comment to clarify test triggering [beam] - posted by "mskyrim (via GitHub)" <gi...@apache.org> on 2025/11/13 08:18:02 UTC, 2 replies.
- Re: [PR] Ensure that Operations are aborted when MapTaskExecutor is closed. Add tests around setup/teardown of DoFns [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/13 09:29:42 UTC, 5 replies.
- [PR] Enable MapState, SetState, MultimapState validates runner tests for Dataflow. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/13 09:58:41 UTC, 2 replies.
- Re: [PR] Bump actions/upload-artifact from 4 to 5 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 12:16:44 UTC, 4 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/13 14:02:41 UTC, 2 replies.
- Re: [I] [Task]: Create a script to train sklearn model for IT test. [beam] - posted by "ysinghc (via GitHub)" <gi...@apache.org> on 2025/11/13 14:17:13 UTC, 1 replies.
- [PR] [Proposal] Allow users to specify trusted Avro serializable classes to Dataflow worker [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2025/11/13 15:09:20 UTC, 8 replies.
- [PR] Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/13 15:15:08 UTC, 3 replies.
- Re: [I] Document Beam ZetaSQL timestamp functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/13 15:43:48 UTC, 0 replies.
- Re: [I] Eliminate nullability errors from :sdks:java:extensions:sql:zetasql [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/13 15:43:49 UTC, 0 replies.
- [PR] Bring the Python Version update docs into the main repo [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/13 15:43:52 UTC, 5 replies.
- [PR] Remove remaining ununsed Python 3.9 artifacts [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/13 15:48:53 UTC, 4 replies.
- Re: [PR] Support Beam MicrosInstant conversion to Avro Timestamp [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/13 18:04:44 UTC, 2 replies.
- [PR] Fix DinD Action failure [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/13 19:01:24 UTC, 2 replies.
- Re: [PR] [Elasticsearch] Add support for v9.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/13 20:38:39 UTC, 4 replies.
- Re: [I] [Bug]: Managed I/O with BIGQUERY can not insert TIMESTAMP [beam] - posted by "yihua-cai (via GitHub)" <gi...@apache.org> on 2025/11/13 20:45:54 UTC, 2 replies.
- [PR] Fix PostCommit Python test_create_default_bucket: check None instead of NotFound [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/13 21:36:45 UTC, 3 replies.
- [PR] Bump golang.org/x/text from 0.30.0 to 0.31.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 04:09:21 UTC, 4 replies.
- [PR] Bump golang.org/x/net from 0.46.0 to 0.47.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 04:09:21 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.12.1 to 2.12.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 04:09:21 UTC, 4 replies.
- [PR] Increase the GZip DeflaterOutputStream buffer size to increase performance [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/14 10:18:49 UTC, 4 replies.
- Re: [I] [Bug]: [Dataflow] Don't suppress OutOfMemoryError or other Errors. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:46:46 UTC, 0 replies.
- Re: [I] [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:46:49 UTC, 0 replies.
- Re: [I] [Feature Request]: Tour of Beam should use the beam.LogElements transform instead of defining `class Output(beam.PTransform):` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:46:58 UTC, 1 replies.
- Re: [I] [Bug]: WriteToFiles using a custom sink with compression type .bz2 flush errors. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:46:59 UTC, 1 replies.
- Re: [I] [Bug]: FirestoreIO read and write do not allow specifying the project or database id per transform. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:47:01 UTC, 1 replies.
- Re: [I] [Failing Test]: Many tests failing with invalid JWT signature [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 12:47:03 UTC, 1 replies.
- [PR] [draft] Key into partition [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/14 14:29:53 UTC, 2 replies.
- [PR] Initial wip commit of reimplmementing the async_dofn.py for use in Java [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/14 14:30:52 UTC, 0 replies.
- [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 14:41:35 UTC, 3 replies.
- Re: [PR] Introduce OutputBuilder in Java SDK [beam] - posted by "kellen (via GitHub)" <gi...@apache.org> on 2025/11/14 14:48:38 UTC, 7 replies.
- Re: [PR] Only update watermark if the new value is larger than the existing value [beam] - posted by "chenxuesdu (via GitHub)" <gi...@apache.org> on 2025/11/14 17:47:08 UTC, 0 replies.
- [PR] DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/14 18:22:03 UTC, 2 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 18:42:52 UTC, 6 replies.
- [PR] Improve error message for decoding input stream [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/14 19:23:26 UTC, 4 replies.
- [I] [Feature Request]: Provide more contextual error message in VarIntCoderImpl [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2025/11/14 19:57:58 UTC, 2 replies.
- [PR] Provide more contextual error message for PyCoder [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2025/11/14 20:06:13 UTC, 7 replies.
- [PR] Update Python container tag [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/11/14 22:10:33 UTC, 3 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/14 22:15:50 UTC, 2 replies.
- Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:15 UTC, 2 replies.
- Re: [I] [Feature Request]: Implement a GroupIntoBatches(.WithShardedKey) based sink for PubsubIO.Write [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:52 UTC, 1 replies.
- Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:52 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support in BQ IO to emit dataset they are accessing for lineage tracking [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:53 UTC, 1 replies.
- Re: [I] [Feature Request]: Support StringSet Metrics in Beam for Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:54 UTC, 1 replies.
- Re: [I] [Bug]: PreparePubsubWriteDoFn does not guarantee that a message will not exceed hard request limits [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:54 UTC, 1 replies.
- Re: [I] [Task]: Validate playground snippets in website documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/15 12:46:55 UTC, 1 replies.
- [PR] Update REVIEWERS.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/15 13:19:36 UTC, 3 replies.
- Re: [I] [Task]: Sliding window ptransform for time series data [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 12:46:17 UTC, 0 replies.
- Re: [I] [Feature Request]: AWS SNS? [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 12:46:28 UTC, 1 replies.
- Re: [I] [Feature Request]: AWS SQS [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 12:46:30 UTC, 1 replies.
- Re: [I] [Feature Request]: Azure Event Hub [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 12:46:33 UTC, 1 replies.
- Re: [I] Outdated version of apache-beam on npm registry [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 12:46:35 UTC, 1 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/16 22:15:52 UTC, 1 replies.
- [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 03:49:04 UTC, 2 replies.
- [PR] Improve coder byte calculation methods [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/11/17 06:26:52 UTC, 5 replies.
- [I] [Feature Request]: Add table information to BigQueryStorageApiInsertError [beam] - posted by "hekk-kaori-maeda (via GitHub)" <gi...@apache.org> on 2025/11/17 09:16:15 UTC, 1 replies.
- [PR] Add table information to BigQueryStorageApiInsertError [beam] - posted by "hekk-kaori-maeda (via GitHub)" <gi...@apache.org> on 2025/11/17 09:24:51 UTC, 7 replies.
- [PR] Fix DinD startup failures [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/17 10:25:48 UTC, 8 replies.
- [PR] [KafkaIO] Replace end offset consumer with admin client [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/11/17 10:47:30 UTC, 3 replies.
- Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:00 UTC, 0 replies.
- Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:03 UTC, 0 replies.
- Re: [I] [CsvIO]: Finalize CsvIOReadFiles [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:10 UTC, 1 replies.
- Re: [I] [Feature Request]: Implement equals, hashCode in FlinkRunner's OrderedListState. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:11 UTC, 1 replies.
- Re: [I] [Feature Request]: Add OrderedListState test in StateInternalsTest [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:13 UTC, 1 replies.
- Re: [I] [Feature Request]:[Go SDK] Improve "bad return type" messaging [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:14 UTC, 1 replies.
- Re: [I] [Feature Request]: Develop a way to evolve the construction schema used by transforms safely [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:16 UTC, 1 replies.
- Re: [I] [Bug]: Dependency resolution is happening when installing latest version of apache-beam[gcp] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/17 12:47:17 UTC, 1 replies.
- Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/17 13:21:36 UTC, 6 replies.
- [I] [Feature Request]: Ability to override the endpoint for Google Cloud Storage [beam] - posted by "adamtracymartin (via GitHub)" <gi...@apache.org> on 2025/11/17 14:09:08 UTC, 2 replies.
- [I] [Bug]: PostCommit YAML Xlang Direct is flaky [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/17 15:34:50 UTC, 1 replies.
- [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/17 18:07:18 UTC, 11 replies.
- Re: [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/17 19:19:28 UTC, 3 replies.
- [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/17 19:39:00 UTC, 9 replies.
- [PR] Support micros isntant in spannerio. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/17 20:02:42 UTC, 3 replies.
- Re: [PR] Allow users to specify trusted Avro serializable classes to Dataflow worker [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2025/11/17 21:36:29 UTC, 4 replies.
- [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] - posted by "future-h-takeda-g3 (via GitHub)" <gi...@apache.org> on 2025/11/18 00:27:25 UTC, 1 replies.
- [PR] Bump actions/checkout from 5.0.0 to 5.0.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 01:04:18 UTC, 1 replies.
- [PR] Bump mypy-protobuf from 3.5.0 to 3.7.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 04:08:51 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.76.0 to 1.77.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 04:09:31 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.57.1 to 1.57.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 04:09:47 UTC, 2 replies.
- [PR] Support newer versions of pyarrow. [beam] - posted by "aebrahim (via GitHub)" <gi...@apache.org> on 2025/11/18 06:37:01 UTC, 3 replies.
- [I] [Feature Request]: AvroIO write improvement with number of shards [beam] - posted by "CherisPatelInfocusp (via GitHub)" <gi...@apache.org> on 2025/11/18 08:09:07 UTC, 1 replies.
- Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] - posted by "reneleonhardt (via GitHub)" <gi...@apache.org> on 2025/11/18 10:06:52 UTC, 3 replies.
- Re: [I] [Failing Test]: beam_PostCommit_TransformService_Direct is permared since October 3 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/18 10:46:05 UTC, 2 replies.
- Re: [I] [Feature Request]: Support int32 for properties of Cross lang transformations written in Java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:10 UTC, 1 replies.
- Re: [I] [Bug]: Exception from Downstream DoFn suppressed if upstream DoFn catches it on Dataflow Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:18 UTC, 0 replies.
- Re: [I] [Task]: Migrate from the Gradle Enterprise plugin to Develocity [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:20 UTC, 0 replies.
- Re: [I] [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:23 UTC, 0 replies.
- Re: [I] [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:24 UTC, 0 replies.
- Re: [I] Auto Inference of JdbcIO#NumPartitions seems to be dead code. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 12:47:26 UTC, 0 replies.
- [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/11/18 13:14:12 UTC, 6 replies.
- [I] [Feature Request]: Add support for pyarrow >= 19.0.0 [beam] - posted by "clementmangin (via GitHub)" <gi...@apache.org> on 2025/11/18 14:45:15 UTC, 1 replies.
- Re: [PR] Support beam:logical_type:micros_instant:v1 in SpannerIo. [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2025/11/18 16:48:20 UTC, 3 replies.
- [I] [Bug]: Cross-language pipeline options are not picked up in Java DoFns [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/11/18 18:52:20 UTC, 8 replies.
- [PR] Add kafka read override to Dataflow java runner. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/11/18 19:18:27 UTC, 15 replies.
- [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 20:13:33 UTC, 2 replies.
- [PR] Bump glob from 10.4.5 to 10.5.0 in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/18 20:13:58 UTC, 2 replies.
- Re: [PR] Default offset deduplication for KafkaIO redistribute. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/11/18 20:39:15 UTC, 1 replies.
- [PR] enhance python tests [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/18 23:31:37 UTC, 12 replies.
- [PR] Supports Asynchronous Runs in Interactive Beam [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2025/11/19 00:39:14 UTC, 10 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 04:08:26 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 04:08:37 UTC, 1 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.2.1 to 2.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 04:08:48 UTC, 2 replies.
- [I] [Bug]: Pass project-id to BigQuery Client in Beam Python SDK [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/19 05:42:07 UTC, 0 replies.
- [I] The PreCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 06:44:04 UTC, 3 replies.
- [I] The PreCommit Xlang Generated Transforms job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 06:44:07 UTC, 3 replies.
- [I] [Bug]: Can I use fixed version for yaml provider [beam] - posted by "ZwxwZ (via GitHub)" <gi...@apache.org> on 2025/11/19 07:34:14 UTC, 0 replies.
- [I] The PreCommit Prism Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 09:42:28 UTC, 3 replies.
- [I] The PreCommit Portable Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 09:42:29 UTC, 3 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:47:53 UTC, 5 replies.
- [I] The PreCommit Python Lint job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:47:56 UTC, 3 replies.
- [I] The PreCommit Python Dataframes job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:05 UTC, 2 replies.
- [I] The PreCommit Python PVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:06 UTC, 3 replies.
- [I] The PreCommit Python Integration job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:09 UTC, 3 replies.
- [I] The PreCommit Python Runners job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:18 UTC, 2 replies.
- [I] The PreCommit Python Transforms job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:19 UTC, 5 replies.
- [I] The PreCommit Python Examples job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:22 UTC, 3 replies.
- Re: [I] [Feature Request]: Add metric counting the number of bytes read/written from/to a GCS bucket [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:48:59 UTC, 0 replies.
- Re: [I] [prism] Triggers and Panes and Windowing Strategies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:49:01 UTC, 0 replies.
- Re: [I] [Bug][Prism]: unsupported URN beam:transform:redistribute_(arbitrarily|bykey):v1:Redistribute.Redistribute* [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:49:02 UTC, 0 replies.
- Re: [PR] [TEST ONLY] Enable unsafe trigger tests for prism [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:53:03 UTC, 2 replies.
- Re: [I] [Bug]: Array is missing in `ColumnType` descriptor - ClickHouseIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/19 12:53:06 UTC, 0 replies.
- [PR] [Docs] Add table of contents for contributor docs [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/19 14:38:51 UTC, 4 replies.
- Re: [I] [Failing Test]: `MLTest.test_ml_preprocessing_yaml` is flaky [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/11/19 14:56:22 UTC, 0 replies.
- [PR] Add back sys import. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/19 15:35:26 UTC, 5 replies.
- [PR] Fix DROP IF NOT EXISTS statement [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/19 15:38:36 UTC, 4 replies.
- Re: [I] [Bug]: NPE in SolaceIO getWatermark [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2025/11/19 17:33:42 UTC, 1 replies.
- [I] [Bug]: Varchar logical type fails Iceberg Pipelines [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/19 18:54:18 UTC, 1 replies.
- Re: [I] [Bug]: Eliminate field sorting in Beam schema-aware transforms which can result in compatibility issues [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/19 19:12:12 UTC, 2 replies.
- [PR] Bump golang.org/x/crypto from 0.31.0 to 0.45.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 01:17:54 UTC, 0 replies.
- [PR] Bump golang.org/x/crypto from 0.35.0 to 0.45.0 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 01:36:21 UTC, 2 replies.
- [PR] Bump golang.org/x/crypto from 0.44.0 to 0.45.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 03:31:01 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.7 to 1.20.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 04:09:20 UTC, 2 replies.
- [PR] BEAM-13231: Add glob wildcard escaping utilities to FileSystems [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/20 09:54:18 UTC, 3 replies.
- [PR] Bump js-yaml from 3.14.1 to 3.14.2 in /website/www [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 12:12:19 UTC, 2 replies.
- Re: [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 12:46:51 UTC, 0 replies.
- Re: [I] [Bug]: Triggers with session window not working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 12:47:06 UTC, 1 replies.
- Re: [I] [Bug]: Python TypeError when converting Avro `logicalType` `timestamp-millis` to Beam Schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/20 12:47:08 UTC, 1 replies.
- Re: [PR] Make RestrictionTrackers.getProgress unblocking until initial progress successfully returned [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/20 18:44:23 UTC, 8 replies.
- [PR] Add Iceberg Schema Support for PassThroughLogicalType [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/11/20 18:49:59 UTC, 5 replies.
- Re: [I] [Bug]: There have an error in 'WriteToBigQuery' after updating to 2.69 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/20 20:27:53 UTC, 1 replies.
- [I] [Feature Request]: support numpy 2.3 [beam] - posted by "gpshead (via GitHub)" <gi...@apache.org> on 2025/11/20 23:05:12 UTC, 1 replies.
- [PR] Bump actions/checkout from 5.0.1 to 6.0.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 01:03:34 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.91.1 to 1.92.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 04:11:04 UTC, 2 replies.
- [PR] Bump actions/checkout from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 04:15:08 UTC, 2 replies.
- Re: [I] The PostCommit Java ValidatesRunner SparkStructuredStreaming job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/11/21 05:38:14 UTC, 1 replies.
- [PR] Bump actions/checkout from 4 to 6 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 09:04:27 UTC, 1 replies.
- Re: [PR] Bump actions/checkout from 4 to 5 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 09:04:28 UTC, 1 replies.
- [PR] Bump actions/checkout from 5 to 6 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 12:05:44 UTC, 1 replies.
- Re: [I] How do I compress the output of using the WriteToFiles method? [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 12:46:41 UTC, 0 replies.
- Re: [I] [Bug]: --dataflow_job_file does not work with direct runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 12:46:51 UTC, 1 replies.
- Re: [I] [Bug]: MetricUpdates.isEmpty check does not check for gaugeUpdates [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 12:46:53 UTC, 1 replies.
- Re: [I] [Bug]: Correctly handle Int64_MAX as a key in ordered list state [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/21 12:46:55 UTC, 1 replies.
- [PR] Fix PostCommit YAML Xlang Direct Workflow [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/21 13:25:08 UTC, 23 replies.
- [PR] Update CHANGES to mention extras changes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/21 15:37:36 UTC, 3 replies.
- Re: [I] [Feature Request]: add Milvus Sink I/O Connector [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/21 16:00:25 UTC, 0 replies.
- Re: [I] Use JSON-B instead of an hardcoded Jackson [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:45:56 UTC, 0 replies.
- Re: [I] Ensure coders are updatable partially in a cluster (aka add versions to coders) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:47:26 UTC, 0 replies.
- Re: [I] Migrate to java.time lib instead of joda-time [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:50:05 UTC, 0 replies.
- Re: [PR] [Python]: accepts --serviceAccount as alias of --service_account_email [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:54:26 UTC, 0 replies.
- Re: [I] Unify serviceAccount pipeline option name [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:55:24 UTC, 0 replies.
- Re: [I] Namespace for pipeline options [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:56:55 UTC, 0 replies.
- Re: [I] Remove AvroIO deprecated API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:57:33 UTC, 0 replies.
- Re: [I] Remove TextIO deprecated API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:57:46 UTC, 0 replies.
- Re: [I] [Bug]: Inline exception propagation with fused DoFns can lead to unexpected behavior [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 18:59:04 UTC, 0 replies.
- Re: [I] [Task]: Scope the work about improving Beam Python Typehints [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 19:01:22 UTC, 2 replies.
- Re: [I] [Bug]: Docker worker containers are confusingly named. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 19:05:55 UTC, 2 replies.
- Re: [I] [Feature Request]: Add set of ML Beam containers [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 19:14:21 UTC, 2 replies.
- Re: [I] [Feature Request]: Support generic PTransforms in Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 19:17:48 UTC, 0 replies.
- Re: [I] [Task]: Upgrade or deprecate Jet runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/21 19:19:08 UTC, 0 replies.
- Re: [PR] [BEAM-11980] Java GCS - Implement IO Request Count metrics [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/22 04:42:51 UTC, 1 replies.
- [PR] GCS client library migration in Java SDK - part 1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/22 05:27:43 UTC, 13 replies.
- Re: [I] [Feature Request]: ClickHouseIO - Include Beam runtime environment in User-Agent string [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/22 12:46:08 UTC, 0 replies.
- Re: [I] [Feature Request]: Generalize generate_yaml_docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/22 12:46:16 UTC, 1 replies.
- Re: [I] [Feature Request]: Add fuzz tests to ordered list states. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/22 12:46:20 UTC, 1 replies.
- Re: [I] [Failing Test]: Java PreCommit UnboundedScheduledExecutorServiceTest testThreadsAreAddedOnlyAsNeededWithContention flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/22 12:46:21 UTC, 1 replies.
- Re: [I] [Bug]: Teardown method is never called [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/22 12:46:27 UTC, 0 replies.
- [PR] Fix bigquery cdc storage api issue 31422 [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/22 15:35:33 UTC, 6 replies.
- Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/22 21:03:46 UTC, 0 replies.
- [PR] Fix triggering frequency documentation validation [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/22 21:12:25 UTC, 5 replies.
- Re: [PR] [Java]Enhance BigQuery Streaming Insert Error Handling for Non-200 Responses (#34154) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/23 12:46:07 UTC, 1 replies.
- Re: [I] [Bug]: Non Retained Messages missing after MqttIO.Read checkpoint restore [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/23 12:46:16 UTC, 1 replies.
- Re: [I] [Feature Request]: add a schema annotation and SchemaRegistry method to use LogicalType on POJO/JavaBeans properties [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/23 12:46:18 UTC, 1 replies.
- Re: [I] [Feature Request]: Transaction and Request Tags on SDK connecting to Spanner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/23 12:46:24 UTC, 0 replies.
- Re: [I] [Bug]: Add a consistent schema format for TypedSchemaTransformProvider [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/23 12:46:25 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:32 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:33 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:34 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:35 UTC, 0 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:36 UTC, 1 replies.
- Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 16:58:36 UTC, 0 replies.
- [PR] Fix GcsEndpoint serialization in GcsOptions [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/23 17:44:37 UTC, 3 replies.
- [PR] [TEST] [No need to reivew] Fix Spark 4.x compilation errors for Beam Spark Runner [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/24 02:30:04 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.9 to 1.20.11 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 04:10:53 UTC, 2 replies.
- Re: [I] [Task]: Update Python slowly updating side input example [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/24 06:55:36 UTC, 0 replies.
- [PR] Add python side input pattern [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/24 07:32:31 UTC, 5 replies.
- [I] [Feature Request]: Propagate drain mode up to reduceFn [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/24 09:31:19 UTC, 1 replies.
- Re: [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:46:59 UTC, 1 replies.
- Re: [PR] Update default max publish batch byte size calculation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:02 UTC, 0 replies.
- Re: [PR] [Python]Fix type inference for closures in lambdas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:04 UTC, 0 replies.
- Re: [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:08 UTC, 0 replies.
- Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:09 UTC, 0 replies.
- Re: [I] [Bug]: Spark and Samza runner fail on a test of sliding windows [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:12 UTC, 0 replies.
- Re: [I] [Feature Request]: Hudi Table support / IO Connector for HoodieIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:22 UTC, 0 replies.
- Re: [I] [Bug]: BigQuery streaming at-least-once job missing records [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:25 UTC, 1 replies.
- Re: [I] [Task]: [flink] portable runner is not ported on new Source API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:28 UTC, 1 replies.
- Re: [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/24 12:47:33 UTC, 2 replies.
- [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/24 14:50:23 UTC, 2 replies.
- [PR] ParDoLifecycleTest concurrency bug - callStateMap [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/24 17:04:22 UTC, 4 replies.
- [PR] Move Kafka read with redistribute override to Kafka IO package. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/11/24 17:09:32 UTC, 9 replies.
- [I] [Feature Request]: Add Support for ClickHouse Cluster in `ClickHouseResourceManager` [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/11/24 17:16:24 UTC, 0 replies.
- [PR] Enables persistent state validates runner tests for Dataflow runners. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/11/24 18:37:15 UTC, 4 replies.
- Re: [I] Python Unit Tests is getting much slower since 2.67.0 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/24 19:13:35 UTC, 0 replies.
- Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Java SDK breaking changes [beam] - posted by "allen-dstillery (via GitHub)" <gi...@apache.org> on 2025/11/24 19:24:15 UTC, 0 replies.
- [PR] Fix nullness in some of Beam SQL [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/11/24 20:15:50 UTC, 6 replies.
- [PR] Add new method of generating key for GBEK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/24 20:57:23 UTC, 2 replies.
- Re: [I] [Task]: Single dockerhub repository for Flink job server container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/24 21:46:01 UTC, 0 replies.
- [PR] Add timestamp-nanos avro logical type support in bigquery utils. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/24 22:29:57 UTC, 0 replies.
- [PR] Flink 1.20 support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/24 23:20:49 UTC, 7 replies.
- [I] [Bug]: FirestoreV1 Beam connectors allow configuring inconsistent project/database IDs between RPC requests and routing headers [beam] - posted by "pacoavila808 (via GitHub)" <gi...@apache.org> on 2025/11/24 23:51:58 UTC, 2 replies.
- [PR] Fix inconsistent handling of Firestore Project and Database ID [beam] - posted by "pacoavila808 (via GitHub)" <gi...@apache.org> on 2025/11/24 23:55:58 UTC, 10 replies.
- Re: [I] The Content-Security-Policy header must not be overridden [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/25 02:29:51 UTC, 5 replies.
- [PR] Update _index.md [beam] - posted by "arkim86-JFK (via GitHub)" <gi...@apache.org> on 2025/11/25 10:50:46 UTC, 3 replies.
- Re: [I] [Task] [IcebergIO]: Add RESTCatalog tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/25 12:47:07 UTC, 0 replies.
- Re: [I] [Task]: Yaml - Consider checking for callable in the if branch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/25 12:47:12 UTC, 1 replies.
- Re: [I] [Bug]: [Flink] JdbcIO metrics are always `NaN` when using the FlinkRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/25 12:47:17 UTC, 1 replies.
- Re: [I] [Bug]: segmentation fault in WriteToFile with DirectRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/25 12:47:19 UTC, 1 replies.
- [PR] Reduce weighing overhead for caching blocks [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/11/25 14:27:06 UTC, 2 replies.
- [PR] Bumpy numpy bounds to include 2.3.X [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/11/25 14:46:09 UTC, 1 replies.
- [PR] Fix clean up image skipping images if there were child paths [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/25 15:32:47 UTC, 3 replies.
- [I] [Failing Test]: The Build python source distribution and wheels job is permared [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/25 18:29:35 UTC, 2 replies.
- [PR] Move to macos-15 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/25 18:49:55 UTC, 6 replies.
- [PR] Upgrade HCatalogIO to Hive 4.0.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/25 19:37:13 UTC, 4 replies.
- Re: [I] [Failing Test]: Tests involve hive-exec has to run on Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/25 21:08:43 UTC, 0 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/25 21:30:01 UTC, 1 replies.
- Re: [I] [Failing Test]: GoogleCloudStorageImpl constructor mismatch in GcsUtil [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/25 21:31:10 UTC, 1 replies.
- [PR] Fix CSP issues [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/25 22:46:30 UTC, 2 replies.
- Re: [I] [Feature Request]: Add support for Flink 1.20 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/11/25 23:59:54 UTC, 0 replies.
- [PR] Reflect that dill is no longer a default pickler. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/11/26 00:14:01 UTC, 2 replies.
- [I] [Feature Request]: Allow FirestoreV1ReadFn to configure a different database than pipeline options [beam] - posted by "pacoavila808 (via GitHub)" <gi...@apache.org> on 2025/11/26 00:18:16 UTC, 1 replies.
- [PR] Support specifying database in FirestoreV1ReadFn (resolves #36904) [beam] - posted by "pacoavila808 (via GitHub)" <gi...@apache.org> on 2025/11/26 00:19:47 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.1 to 1.32.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 04:10:11 UTC, 3 replies.
- Re: [I] [Bug]: Tour of Beam (Golang) - playground doesn't work when change the code [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:26 UTC, 1 replies.
- Re: [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:30 UTC, 0 replies.
- Re: [I] [Bug]: GroupByKey() emits only key but not values for streaming job on a FixedWindows() with early trigger [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:33 UTC, 1 replies.
- Re: [I] [Bug]: Using WriteToBigQuery FILE_LOADS in a streaming pipeline does not remove temporary tables [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:35 UTC, 0 replies.
- Re: [I] [Bug]: TextIO.read().withEmptyMatchTreatment(EmptyMatchTreatment.ALLOW) still fails if no file is found [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:36 UTC, 0 replies.
- Re: [I] [Failing Test]: Beam ML unit tests fail with Keras 3.3.3 and TF 2.16.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 12:50:38 UTC, 0 replies.
- [PR] [yaml] - comment out potential race condition until further investigation in enrichment test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/11/26 13:21:57 UTC, 1 replies.
- Re: [PR] [yaml] - tmp fix for enrichment test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 14:50:13 UTC, 3 replies.
- [I] Permission needs to be obtained before adding exceptions to the CSP [beam] - posted by "sebbASF (via GitHub)" <gi...@apache.org> on 2025/11/26 16:27:36 UTC, 0 replies.
- Re: [PR] Add timestamp-nanos avro logical type support in bigquery avro utils. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/26 16:29:48 UTC, 4 replies.
- [PR] Test docker config to fix workflow. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 16:32:27 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 16:33:11 UTC, 3 replies.
- Re: [I] [Feature Request]: Add yaml sql example using calcite_connection_properties, and document this in the transform catalog [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/26 16:36:58 UTC, 0 replies.
- [I] [Bug]: BigQueryIO streaming read issue [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/26 17:33:42 UTC, 1 replies.
- Re: [I] Fix failing "beam_PostCommit_XVR_GoUsingJava_Dataflow" job [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 17:57:56 UTC, 5 replies.
- [PR] fix retry scenario for query to table materialization [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/26 18:40:32 UTC, 2 replies.
- [PR] Enforce useDockerBuildx in workflow. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 19:26:43 UTC, 0 replies.
- [PR] Bump ray from 2.51.1 to 2.52.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 19:42:11 UTC, 1 replies.
- [PR] Bump ray from 2.51.1 to 2.52.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 19:44:05 UTC, 1 replies.
- [PR] fix retry scenario for query to table materialization (#36912) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/26 19:57:07 UTC, 0 replies.
- Re: [PR] cherry pick fix retry scenario for query to table materialization (#36912) [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 19:57:17 UTC, 1 replies.
- Re: [I] [Task]: Consider reducing dependencies in core [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/26 20:55:30 UTC, 0 replies.
- [PR] Cherrypick in extras changes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/11/26 20:56:32 UTC, 4 replies.
- [I] [Failing Test]: BigQueryIO and BigTableIO integration test failed in ValidateRunner_GoUsingJava [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 21:06:03 UTC, 0 replies.
- [PR] Upgrade bom. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/26 21:18:28 UTC, 0 replies.
- [I] The PreCommit Java PVR Prism Loopback job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 21:35:44 UTC, 3 replies.
- [PR] Bump node-forge from 1.3.1 to 1.3.2 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/26 22:10:15 UTC, 1 replies.
- Re: [PR] Re-enable "PostCommit XVR GoUsingJava Dataflow" in cron [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/26 23:44:44 UTC, 5 replies.
- [PR] [DO NOT MERGE] Test if the postcommit GoUsingJava is green. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/27 02:12:06 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.20.11 to 1.20.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 04:10:07 UTC, 2 replies.
- [PR] [Cherrypick] Re-enable "PostCommit XVR GoUsingJava Dataflow" in cron (#36909) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/27 05:20:33 UTC, 3 replies.
- Re: [I] Linkage check script assumes you have a remote called `origin` [beam] - posted by "zhan7236 (via GitHub)" <gi...@apache.org> on 2025/11/27 09:02:05 UTC, 0 replies.
- [PR] Fix linkage check script to handle detached HEAD state [beam] - posted by "zhan7236 (via GitHub)" <gi...@apache.org> on 2025/11/27 09:14:59 UTC, 2 replies.
- [PR] Improve linkage check script documentation for git references [beam] - posted by "zhan7236 (via GitHub)" <gi...@apache.org> on 2025/11/27 09:16:21 UTC, 2 replies.
- [PR] Offset deduplication - Propagate offset and record in output builder [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/27 10:04:32 UTC, 2 replies.
- [PR] Fix flaky Prism Loopback test [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2025/11/27 12:15:08 UTC, 3 replies.
- Re: [I] [Feature Request]: Expose pvalue.Row in core.py rather than pvalue.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:06 UTC, 1 replies.
- Re: [I] [prism] ViewTest.testSideInputWithNestedIterables - user coder errors [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:10 UTC, 1 replies.
- Re: [I] [Feature Request]: provide option for explicit schema data types for batch input sources and callable functions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:17 UTC, 0 replies.
- Re: [I] [Feature Request]: Optimize the number of shards for FileIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:19 UTC, 0 replies.
- Re: [I] Question : What type should I use to read a numeric from bigquery with the go SDK ? [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:20 UTC, 0 replies.
- Re: [I] Java Apache Beam, allow fake external Clients initialized in @Setup method of DoFn with Constructors variables [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 12:47:22 UTC, 0 replies.
- [PR] Fixes BigQueryIODynamicReadTest flakes [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/11/27 13:16:33 UTC, 2 replies.
- Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] - posted by "yuwtennis (via GitHub)" <gi...@apache.org> on 2025/11/27 13:56:05 UTC, 0 replies.
- [PR] Revert "Fix CSP issues" [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/11/27 15:44:57 UTC, 3 replies.
- [I] The Flaky test detection job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 21:35:16 UTC, 3 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/27 22:13:15 UTC, 0 replies.
- [I] The PreCommit Java GCP IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/28 00:50:13 UTC, 1 replies.
- [I] [Bug]: Typo in parameter of doc of WriteToKafka [beam] - posted by "yuwtennis (via GitHub)" <gi...@apache.org> on 2025/11/28 02:54:07 UTC, 1 replies.
- [PR] fix: Typo in params of WriteToKafka [beam] - posted by "yuwtennis (via GitHub)" <gi...@apache.org> on 2025/11/28 07:46:08 UTC, 5 replies.
- [PR] Add support for sharding while avro write [beam] - posted by "CherisPatelInfocusp (via GitHub)" <gi...@apache.org> on 2025/11/28 08:11:34 UTC, 2 replies.
- [PR] Fix typo in WriteToKafka docstring: deserializer -> serializer [beam] - posted by "ANONYMOUSZED-beep (via GitHub)" <gi...@apache.org> on 2025/11/28 09:49:28 UTC, 2 replies.
- Re: [PR] [do not merge/draft] Key into partition [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/28 12:16:35 UTC, 0 replies.
- [PR] [KafkaIO] Make ReadFromKafkaDoFn restriction trackers unsplittable [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/11/28 12:40:36 UTC, 7 replies.
- Re: [I] [Feature Request]: Slowness in WriteToJson step in streaming jobs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/28 12:47:00 UTC, 1 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to pass table properties to be set when creating a table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/28 12:47:04 UTC, 0 replies.
- Re: [I] [Failing Test]: Onnx inference unit tests are failing. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/28 12:47:12 UTC, 0 replies.
- [I] [Bug]: beam_PreCommit_Python_ML fails with AttributeError [beam] - posted by "yuwtennis (via GitHub)" <gi...@apache.org> on 2025/11/28 13:53:25 UTC, 1 replies.
- [PR] fix: withErrorHandler is not supported with File_Load [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/11/28 15:00:13 UTC, 2 replies.
- Re: [PR] Fix typo in parameters of WriteToKafka in Python doc [beam] - posted by "yuwtennis (via GitHub)" <gi...@apache.org> on 2025/11/29 02:22:33 UTC, 0 replies.
- [PR] Sql calcite connection properties docs [beam] - posted by "Arunodoy18 (via GitHub)" <gi...@apache.org> on 2025/11/29 05:41:58 UTC, 4 replies.
- Re: [PR] Upgrade sqlline from 1.4.0 to 1.12.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/29 12:46:33 UTC, 0 replies.
- Re: [I] [Feature request]: Support XGBoost 2.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/29 12:46:50 UTC, 0 replies.
- Re: [PR] Update BOM to 26.72.0 [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/29 17:38:57 UTC, 1 replies.
- Re: [PR] Add Apache Iceberg support and Catalog support to Beam SQL documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/30 12:46:28 UTC, 0 replies.
- Re: [PR] Save Logical Type and Coder Registry on cloudpickle save main session [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/30 12:46:30 UTC, 0 replies.
- Re: [PR] Add property support to trivial_inference.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/30 12:46:32 UTC, 0 replies.
- Re: [PR] Default getUseStorageApiConnectionPool to true instead of false [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/30 12:46:43 UTC, 0 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/11/30 18:42:00 UTC, 1 replies.
- [PR] Remove dead code. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/11/30 23:36:16 UTC, 1 replies.