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

---

- [I] [Bug]: No "Operation ongoing ..." logs for the work threads stuck at initializing operations [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/01 05:08:18 UTC, 0 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 06:39:28 UTC, 4 replies.
- Re: [I] BeamSQL aggregation analytics functionality [beam] - posted by "masfworld (via GitHub)" <gi...@apache.org> on 2025/09/01 07:25:07 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.69.0 to 1.70.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 08:00:08 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.4 to 1.31.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 08:07:21 UTC, 3 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.4 to 1.31.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 08:07:24 UTC, 1 replies.
- Re: [PR] feat(pubsub): add batch mode support for WriteToPubSub in DataflowRunner [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/01 09:00:15 UTC, 4 replies.
- [I] [Bug]: Cannot get schema in managed I/O [beam] - posted by "cona-bear (via GitHub)" <gi...@apache.org> on 2025/09/01 09:13:18 UTC, 4 replies.
- Re: [PR] #24167 Document<->Row conversion for FirestoreIO [beam] - posted by "Luiscri (via GitHub)" <gi...@apache.org> on 2025/09/01 09:51:41 UTC, 1 replies.
- Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/01 11:20:08 UTC, 4 replies.
- Re: [PR] Implement a hierarchy for Beam SQL Calcite Schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:15:28 UTC, 13 replies.
- Re: [PR] Adding time partitioning support for python storage write api [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:15:33 UTC, 10 replies.
- Re: [PR] [Jules] Add OpenAI Remote Model Handler implementation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:46:50 UTC, 2 replies.
- Re: [I] [Bug]: Provisioning runners fails [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:46:58 UTC, 1 replies.
- Re: [I] [Feature Request]: Add InsertRetryPolicy for non-successful BigQuery insertAll responses. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:47:00 UTC, 1 replies.
- Re: [I] [Bug]: Unable to use S3 bucket for ReadFromSnowflake staging bucket name [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:47:02 UTC, 1 replies.
- Re: [I] [Feature Request]: Properly incorporate bulk multimap side input reads into caching. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:47:04 UTC, 1 replies.
- Re: [I] [Bug]: BigQueryIO - unknown repeated fields are merged incorrectly to payload [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:47:05 UTC, 1 replies.
- Re: [I] [Feature Request]: OpenTelemetry Support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 12:47:07 UTC, 0 replies.
- Re: [I] The LoadTests Python CoGBK Flink Batch job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/01 13:00:19 UTC, 0 replies.
- [PR] feat(pubsub): support batch mode in WriteToPubSub transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/01 17:39:07 UTC, 11 replies.
- [PR] Only retrieve the shared caches once during setup in ReadFromKafkaDoFn [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/09/01 18:45:44 UTC, 0 replies.
- Re: [PR] [KafkaIO] Only retrieve the shared caches once during setup in ReadFromKafkaDoFn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/01 20:07:04 UTC, 3 replies.
- Re: [PR] [YAML] Fraud Detection MLOps Workflow Example [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/09/01 22:17:47 UTC, 5 replies.
- [PR] [KafkaIO] Exit the poll loop in ReadFromKafkaDoFn after consumerPollingTimeout has elapsed [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/09/01 22:21:31 UTC, 6 replies.
- Re: [PR] Upgrade Errorprone to 2.31.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 00:38:36 UTC, 0 replies.
- [PR] feat(worker): add lull logging for bundle processor creation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/02 01:08:24 UTC, 0 replies.
- Re: [I] [Feature Request]: Beam Configurable SDK Restart Proposal [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/09/02 04:39:02 UTC, 0 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2025/09/02 11:03:53 UTC, 9 replies.
- Re: [PR] ignore overridden setters and getters in JavaBeanSchema [beam] - posted by "tilgalas (via GitHub)" <gi...@apache.org> on 2025/09/02 11:07:36 UTC, 0 replies.
- Re: [PR] Switch streaming engine worker harness based on job settings [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:15:48 UTC, 15 replies.
- Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:15:49 UTC, 12 replies.
- Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:15:51 UTC, 8 replies.
- Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:15:52 UTC, 5 replies.
- Re: [I] [Bug]: Inline exception propagation with fused DoFns can lead to unexpected behavior [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:46:43 UTC, 3 replies.
- Re: [I] [Bug]: Errors when switching from streaming_inserts to Storage_Write_API when using repeated Struct or Record fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:47:00 UTC, 0 replies.
- Re: [I] [prism] Document contradiction between Stateful and Splittable DoFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 12:47:01 UTC, 0 replies.
- Re: [PR] refactor(build): update changelog formatting in gradle task [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/02 14:35:55 UTC, 2 replies.
- Re: [PR] Add validation to check for non-ints from partitionfns [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 14:50:43 UTC, 5 replies.
- Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 7.2.1 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 14:52:15 UTC, 2 replies.
- [PR] Fix PreCommit Python Transforms job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/02 15:04:44 UTC, 8 replies.
- [PR] Cache deterministic types [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/02 15:05:17 UTC, 4 replies.
- Re: [PR] Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:05:41 UTC, 1 replies.
- Re: [PR] Create new SubProject to not depend on Dataflow in Kafka [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:06:00 UTC, 1 replies.
- Re: [PR] Add BigQuery Storage Read API Enrichment Handler [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:06:30 UTC, 3 replies.
- Re: [PR] Extending WindowedValue with ElementMetadata [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:07:06 UTC, 0 replies.
- Re: [PR] Allow Dofn Input/Output Typing [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:10:02 UTC, 2 replies.
- Re: [I] [Feature Request]: PrismRunner should support transform overrides [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:14:33 UTC, 2 replies.
- Re: [I] [Task]: Deprecate Python native SpannerIO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:21:54 UTC, 0 replies.
- Re: [I] [Feature Request]: KafkaIO - redistribute by key [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/02 15:23:14 UTC, 0 replies.
- Re: [I] [Feature Request]: Add GCP Firestore IO connector for Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 15:26:05 UTC, 0 replies.
- Re: [PR] Introduce more abstract handling of throttling signaling [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/02 16:17:43 UTC, 3 replies.
- Re: [PR] Fix jdbc logical type not found when python sdk worker running in docker env [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 16:43:29 UTC, 19 replies.
- [PR] Fix: Correctly assign feature to release [beam] - posted by "flpablo (via GitHub)" <gi...@apache.org> on 2025/09/02 17:29:58 UTC, 1 replies.
- [PR] Add JDBCIO to managed io. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/02 18:15:27 UTC, 0 replies.
- [PR] Add auth for models [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/02 18:19:32 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Spanner change stream support to python. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 18:28:02 UTC, 1 replies.
- [PR] Add Iceberg to AlloyDB Blueprint [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/02 18:39:56 UTC, 19 replies.
- Re: [PR] [DRAFT] Add Iceberg to AlloyDB Blueprint [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/02 19:35:41 UTC, 0 replies.
- Re: [PR] Allow stateful exception handling [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/02 19:41:52 UTC, 0 replies.
- [PR] Cloudpickle deterministic coder changes.md. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/02 20:10:05 UTC, 3 replies.
- Re: [PR] [Prism] Fix two kinds of errors when using json log format. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/02 20:30:53 UTC, 0 replies.
- Re: [I] [Feature Request]: Design and Implement CoderLogicalType [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 20:33:03 UTC, 0 replies.
- Re: [PR] Update iceberg to 1.9.2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/02 21:07:54 UTC, 12 replies.
- [PR] Bump github.com/spf13/cobra from 1.9.1 to 1.10.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 22:54:38 UTC, 3 replies.
- [I] [Feature Request]: Support PROTO protobuf in WriteToPubSub Beam YAML [beam] - posted by "jonathaningram (via GitHub)" <gi...@apache.org> on 2025/09/02 23:01:32 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.2 to 1.19.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/02 23:44:17 UTC, 3 replies.
- Re: [PR] Support managed jdbc io (Postgres) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 05:36:06 UTC, 18 replies.
- Re: [I] [Bug]: beam.io.gcp.bigquery.ReadFromBigQuery failing with permission issue [beam] - posted by "ssu1276 (via GitHub)" <gi...@apache.org> on 2025/09/03 07:12:23 UTC, 2 replies.
- Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:15:09 UTC, 6 replies.
- Re: [PR] Support Protobuf 6.x. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:15:14 UTC, 2 replies.
- Re: [PR] BEAM-9626: Move out optional packages from core dependencies - 20259 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:46:27 UTC, 1 replies.
- Re: [I] [Task]: Close feature gaps between regular and CDC Iceberg sources [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:46:40 UTC, 1 replies.
- Re: [I] [Bug]: Race condition in FileSystems initialisation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:46:41 UTC, 1 replies.
- Re: [I] Redis IO Doesn't Support Selecting DB Index [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 12:46:56 UTC, 0 replies.
- Re: [PR] Bump cloud.google.com/go/spanner from 1.83.0 to 1.85.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/03 14:21:02 UTC, 0 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/03 14:55:04 UTC, 4 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/03 15:09:40 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Protobuf 6.x in Python SDK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/03 16:02:32 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/09/03 16:41:41 UTC, 0 replies.
- Re: [I] Use JSON-B instead of an hardcoded Jackson [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:42:06 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/09/03 16:42:24 UTC, 0 replies.
- Re: [I] Unify serviceAccount pipeline option name [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:42:33 UTC, 0 replies.
- Re: [I] Namespace for pipeline options [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:42:42 UTC, 0 replies.
- Re: [I] Remove AvroIO deprecated API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:42:49 UTC, 0 replies.
- Re: [I] Remove TextIO deprecated API [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:42:55 UTC, 0 replies.
- Re: [I] Get rid of jackson to avoid the continuous flow of CVEs in Jackson [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:43:09 UTC, 2 replies.
- Re: [I] [Beam I/O Standards] Avoid partially-built PTransform objects [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:43:19 UTC, 2 replies.
- Re: [I] Obtain metadata field at once in file system's IO connectors [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:43:50 UTC, 0 replies.
- Re: [I] [Task]: Make Prism default [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:44:30 UTC, 2 replies.
- Re: [I] [Tracking Umbrella] Prism Runner areas for contribution. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:44:42 UTC, 0 replies.
- Re: [I] [Task]: Enrich Managed IO by onboarding more IOs and making Iceberg feature complete [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:45:12 UTC, 0 replies.
- Re: [I] [Task]: Default option changes for IO connectors (e.g., BigQuery IO), Runners (e.g., SA vs SE) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:45:26 UTC, 0 replies.
- Re: [I] [Task]: Enrich ML features such as RAG, Anomaly Detection [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:45:33 UTC, 2 replies.
- Re: [I] [Task]: Consider reducing dependencies in core [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:45:48 UTC, 1 replies.
- Re: [I] [Feature Request]: Update the default behaviour in `BigQueryIO.Write.Method.DEFAULT` to `STORAGE_API_AT_LEAST_ONCE` [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:46:13 UTC, 0 replies.
- Re: [I] [Task]: Deduplicate Coders [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:46:24 UTC, 1 replies.
- Re: [I] [Task]: Scope the work about improving Beam Python Typehints [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:47:43 UTC, 0 replies.
- Re: [I] [Task]: Improve the schema support for Beam 3.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:47:52 UTC, 0 replies.
- Re: [I] [Bug]: Docker worker containers are confusingly named. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:48:05 UTC, 0 replies.
- Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:48:18 UTC, 3 replies.
- Re: [I] [Task]: Remove support of Samza runner in new Beam versions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:49:30 UTC, 0 replies.
- Re: [I] [Bug]: Prism isn't correctly used as the default for streaming pipelines. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:49:50 UTC, 2 replies.
- Re: [I] [Task]: Deprecate Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/03 16:50:21 UTC, 0 replies.
- [PR] feat(build): add validation task for CHANGES.md formatting [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/03 17:30:12 UTC, 4 replies.
- Re: [I] [Bug]: JDBC logical type not found when running a Python pipeline in docker env [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/03 19:16:03 UTC, 0 replies.
- Re: [I] [Bug]: xlang JDBC (versions 2.65.0, 2.66.65)- No logical type registered for URN 'beam:logical_type:javasdk:v1' [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/03 19:46:03 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.87.2 to 1.87.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 20:53:26 UTC, 2 replies.
- Re: [PR] Integrate lambda name pickling with Cloudpickle [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/03 22:06:17 UTC, 24 replies.
- [PR] allow numpy integers for partition functions for backwards compatibility [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/04 01:29:20 UTC, 4 replies.
- [PR] fix(Partition): support numpy integer types in partition validation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/04 01:29:22 UTC, 2 replies.
- [PR] Support managed jdbc io (MySQL) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/04 02:16:22 UTC, 6 replies.
- Re: [I] Log the reason for failure for BigQuery jobs [beam] - posted by "mburuian6 (via GitHub)" <gi...@apache.org> on 2025/09/04 06:03:24 UTC, 2 replies.
- [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/04 06:18:11 UTC, 8 replies.
- [PR] [Java]Enhance BigQuery Streaming Insert Error Handling for Non-200 Responses (#34154) [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/04 10:24:17 UTC, 8 replies.
- [PR] Spanner: Extend SpannerIO support for experimental hosts [beam] - posted by "sagnghos (via GitHub)" <gi...@apache.org> on 2025/09/04 11:18:06 UTC, 4 replies.
- Re: [PR] Add YAML Editor and Visualization Panel [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/04 11:54:21 UTC, 6 replies.
- Re: [PR] [Go SDK] Add Write transform to cross-language Bigtable package - fixes #35873 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:15:02 UTC, 9 replies.
- Re: [I] When will Flink 2.0 and above be supported? [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:46:49 UTC, 0 replies.
- Re: [I] [Task]: Ensure the effective communications during the Beam 3.0.0 development process [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:46:50 UTC, 1 replies.
- Re: [I] [Task]: Enrich YAML supports for IOs, turnkey transforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:46:51 UTC, 1 replies.
- Re: [I] [Feature Request]: Unify metrics that are to be aggregated on google worker and on the portable runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:46:57 UTC, 1 replies.
- Re: [I] [Bug]: FlinkRunner never calls finish_bundle and OOM eventually [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:46:58 UTC, 1 replies.
- Re: [I] [Feature Request]: Add option to set maximum Storage API streams when using autosharding [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 12:47:02 UTC, 1 replies.
- [PR] Bump actions/setup-go from 5 to 6 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 13:31:55 UTC, 1 replies.
- [PR] Correctly exclude prism when using external transforms [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/04 14:06:53 UTC, 3 replies.
- [PR] Bump actions/setup-python from 5 to 6 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 14:18:25 UTC, 1 replies.
- Re: [PR] [YAML]: add optional schema config for all transforms [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/04 14:31:35 UTC, 12 replies.
- [PR] Comment send email action [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/04 14:40:16 UTC, 3 replies.
- [I] [Task]: Migrate generative Vertex AI usage to the google-genai package [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/04 14:43:01 UTC, 0 replies.
- [PR] fix(Partition): support numpy integer types in partition validation [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/04 15:11:53 UTC, 2 replies.
- Re: [PR] [#34236] Add Vertex AI Multi-Modal embedding handler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/04 15:29:49 UTC, 10 replies.
- Re: [PR] Update notebook to use embedding gemma [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 16:03:50 UTC, 3 replies.
- [I] [Bug]: Mqtt checkpointmark implementation is wrong [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/04 18:25:27 UTC, 1 replies.
- [PR] Support managed jdbc io (Oracle) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/04 18:56:23 UTC, 3 replies.
- [PR] Support managed jdbc io (SQLServer) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/04 18:57:04 UTC, 5 replies.
- Re: [I] [Feature Request]: Add Beam YAML use case Streaming Inference [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/04 18:57:45 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Beam YAML use case Simple Batch Processing [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/04 18:57:50 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Beam YAML use case Change Data Capture [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/04 18:58:06 UTC, 1 replies.
- Re: [I] [Feature Request]: Add Beam YAML use case Feature Engineering and Model Evaluation [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/04 18:58:09 UTC, 0 replies.
- Re: [I] [Feature Request]: Beam YAML, Kafka and Iceberg User Accessibility [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/04 18:58:15 UTC, 2 replies.
- Re: [I] datastoreio doesn't work with entities containing keys [beam] - posted by "remko (via GitHub)" <gi...@apache.org> on 2025/09/04 19:58:00 UTC, 3 replies.
- [PR] Fix MqttIO read checkpoint logic [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/04 20:41:09 UTC, 4 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 21:34:28 UTC, 3 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/04 22:14:30 UTC, 1 replies.
- Re: [PR] Introduce Schema Registry Functionality to Managed KafkaIO Write. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 00:27:57 UTC, 7 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.50.0 to 1.50.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 04:08:30 UTC, 4 replies.
- [PR] [Java]Add Support for DateTime, Array, Tuple, Float32, Float64 in ClickHouseIO parseDefaultExpression (#33692) [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/05 05:31:13 UTC, 12 replies.
- Re: [PR] Allow users to pass service name for profiler for Java And Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 12:14:36 UTC, 6 replies.
- Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 12:14:39 UTC, 5 replies.
- [PR] Fail container if failed to load meta options [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/05 12:29:16 UTC, 3 replies.
- Re: [PR] workflows: add `ubuntu-latest` to `beam_PreCommit_Python_ML`, `beam_PostCommit_Python`, and `beam_PreCommit_Python_Coverage` [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/05 12:40:47 UTC, 14 replies.
- Re: [I] [Bug]: Writing to a BigQuery partition requires clustering info to succeed if destination table has clustered fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 12:46:21 UTC, 0 replies.
- Re: [I] [CsvIO]: Support non-UTF8 text encoding for parse/reads and writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 12:46:32 UTC, 1 replies.
- Re: [I] [CsvIO]: Create CsvIOParseLoadIT class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/05 12:46:43 UTC, 0 replies.
- [PR] Add ALLOYDB_PASSWORD to Examples and Coverage workflow [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/05 12:56:33 UTC, 4 replies.
- Re: [PR] [2/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/05 12:57:09 UTC, 16 replies.
- [PR] sdks/python: enrich data with tecton feature store [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/05 13:00:17 UTC, 0 replies.
- [PR] [Java] Fix expensive OneOfType precondition messages by making them lazy [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/05 13:08:30 UTC, 6 replies.
- [PR] Update beam_PreCommit_Whitespace.yml to run validateChanges [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/05 13:25:54 UTC, 3 replies.
- [PR] [Java] Change precondition checks to use lazy formatting [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/05 13:35:24 UTC, 12 replies.
- Re: [PR] [3/3] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/05 13:36:42 UTC, 3 replies.
- Re: [PR] Log an error if parsing a meta option file fails [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/05 13:59:26 UTC, 2 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/05 14:07:49 UTC, 0 replies.
- Re: [I] [Task]: Polish the CHANGES.md and the previous release blogs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/05 14:26:11 UTC, 0 replies.
- [PR] Add prism to capability matrix [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/05 15:05:39 UTC, 4 replies.
- Re: [I] [Task]: Add Prism to runner capability matrix [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/05 15:12:20 UTC, 2 replies.
- [I] [Bug]: Default Pub/Sub batch size is smaller than the maximum message size, preventing the sending of large messages [beam] - posted by "brodin (via GitHub)" <gi...@apache.org> on 2025/09/05 15:35:06 UTC, 2 replies.
- Re: [PR] Update Beam Protobuf Schema (Java) [beam] - posted by "jkimshop (via GitHub)" <gi...@apache.org> on 2025/09/05 15:41:57 UTC, 10 replies.
- [PR] Logs the BigQuery error that caused the load job failure (resolves #1… [beam] - posted by "mburuian6 (via GitHub)" <gi...@apache.org> on 2025/09/05 15:43:05 UTC, 10 replies.
- [PR] [WIP][Prism]Support after_processing_time trigger [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/05 15:50:47 UTC, 3 replies.
- [PR] [Release-2.68] cherry-pick #36063 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/05 17:10:20 UTC, 4 replies.
- [PR] Make SpannerChangeStreamPlacementTableIT against Spanner prod. [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/09/05 17:36:22 UTC, 4 replies.
- [PR] Hint Suggestions for invalid pipeline options [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/05 18:37:16 UTC, 9 replies.
- [PR] JsonToRowTest: fix race condition [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/05 18:44:10 UTC, 15 replies.
- [PR] YAML example suite minor updates [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/09/05 20:47:31 UTC, 3 replies.
- Re: [PR] Bump torch from 1.13.1 to 2.8.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:14:25 UTC, 6 replies.
- Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:14:25 UTC, 4 replies.
- Re: [I] [Feature Request]: Enable to capture Kafka errors like JMSWriteResult [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:23 UTC, 0 replies.
- Re: [I] [Bug]: :sdks:python:test-suites:tox:py312:testPython312 could be flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:27 UTC, 1 replies.
- Re: [I] [Bug]: Cross-language pipeline options are not picked up in Java DoFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:29 UTC, 5 replies.
- Re: [I] [Bug]: tour of beam content cannot be scrolled on ipad [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:31 UTC, 1 replies.
- Re: [I] [Feature Request]: Topic array support for MqttIO.Read [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:32 UTC, 1 replies.
- Re: [I] [Bug]: arm64 container image has the wrong arch for Google Cloud Profiler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 12:45:40 UTC, 0 replies.
- [PR] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread. [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/09/06 19:27:02 UTC, 0 replies.
- Re: [PR] [KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread. [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/09/06 19:59:47 UTC, 9 replies.
- [PR] [YAML] - update readme to correct pipeline [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/06 20:02:10 UTC, 0 replies.
- [PR] [KafkaIO] Only update size metrics once per batch [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/09/06 22:08:09 UTC, 4 replies.
- Re: [PR] [YAML] - update readme to correct pipeline calls [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/06 22:35:12 UTC, 3 replies.
- Re: [I] [Feature Request]: Support validate-only mode for YAML pipeline parsing (no IO/data access) [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/09/07 03:37:11 UTC, 0 replies.
- Re: [PR] sdks/python: integrate Weaviate vector database I/O connector [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/07 11:47:17 UTC, 1 replies.
- Re: [PR] sdks/python: integrate OpenAI embedded generator [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/07 11:48:54 UTC, 1 replies.
- [PR] sdks/python: sink data with tecton feature store [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/07 12:21:31 UTC, 0 replies.
- Re: [PR] feat: Qdrant Search Handler [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/07 12:27:04 UTC, 2 replies.
- Re: [PR] fix the end_stamp issue for the initial partition [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/07 12:45:53 UTC, 2 replies.
- Re: [I] [Feature Request]: SQL Shell Google Pub/Sub subscription external table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/07 12:46:17 UTC, 0 replies.
- Re: [I] [Bug]: BigtableIO integration tests not actually testing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/07 12:46:19 UTC, 0 replies.
- Re: [I] [Bug]: Illegal Argument Exception even though the type is matching [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/07 12:46:19 UTC, 0 replies.
- [PR] Cherry pick #35981 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/07 12:48:45 UTC, 6 replies.
- [PR] [Python]Fix type inference for closures in lambdas [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/07 15:36:13 UTC, 2 replies.
- [PR] RAG: Add OpenAI text embedding model [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/07 16:24:07 UTC, 0 replies.
- [PR] Update default max publish batch byte size calculation [beam] - posted by "utsav-pal (via GitHub)" <gi...@apache.org> on 2025/09/07 18:19:03 UTC, 3 replies.
- Re: [PR] RAG: add OpenAI text embedding model [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/07 18:38:27 UTC, 3 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 00:49:56 UTC, 3 replies.
- [I] RAG: add OpenAI text embedding model [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/08 01:11:27 UTC, 0 replies.
- [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 03:44:31 UTC, 19 replies.
- [PR] Cherrypick #36063: [Java] Fix expensive OneOfType precondition messages by making them lazy [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/08 10:32:39 UTC, 3 replies.
- [PR] Cherrypick #36014: Fix jdbc logical type not found when python sdk worker running in docker env [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/08 10:34:55 UTC, 3 replies.
- Re: [I] [Bug]: SpannerIO.Write does not support named schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:46:58 UTC, 1 replies.
- Re: [I] [Bug]: PubsubIO on Flink Runner not acknowledging old messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:00 UTC, 1 replies.
- Re: [I] [Bug]: Incorrect Output for Beam SQL MONTH and YEAR window queries [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:02 UTC, 1 replies.
- Re: [I] [Task]: Re-enable pip check on macos tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:05 UTC, 1 replies.
- Re: [I] [RRIO] [Task]: Add withErrorHandler to accept ErrorHandler.BadRecordErrorHandler [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:07 UTC, 1 replies.
- Re: [I] [Feature Request]: Docker images with both runtime and launch environments [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:10 UTC, 1 replies.
- Re: [I] [Bug]: Flink Job manager metaspace classloader leak [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/08 12:47:12 UTC, 1 replies.
- Re: [PR] Added documentation for return vs yield usage in DoFn.process() [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/08 13:32:58 UTC, 1 replies.
- Re: [I] [Feature Request]: Interactive Visualization of Beam Python YAML Pipeline [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/09/08 13:35:52 UTC, 0 replies.
- [I] [Task]: add a yaml ut for expand_pipeline [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/08 14:47:43 UTC, 0 replies.
- [PR] [yaml] - add yaml top level keys test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/08 14:48:03 UTC, 0 replies.
- Re: [PR] Improve Iceberg Blueprint and documentation and Tests [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/08 16:20:45 UTC, 0 replies.
- Re: [I] [Task]: Deprecate Twister2 runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/08 17:33:54 UTC, 0 replies.
- [I] [Bug]: Resource hints are not propagated when using `with_exception_handling` [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2025/09/08 17:58:03 UTC, 5 replies.
- Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/08 18:03:12 UTC, 9 replies.
- [PR] [Python] Fix: Propagate resource hints through with_exception_handling [beam] - posted by "ian-Liaozy (via GitHub)" <gi...@apache.org> on 2025/09/08 18:30:44 UTC, 13 replies.
- Re: [I] [Feature Request]: YAML - add optional output schema and error handling to transforms [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/08 19:31:52 UTC, 0 replies.
- Re: [I] [Feature Request]: VertexAIImageEmbeddings adding the ability to send in contextual text too [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/08 20:51:36 UTC, 0 replies.
- [PR] Add interactive dependency to notebooks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/08 21:35:01 UTC, 6 replies.
- [PR] Pin avro 1.12.0 in expansion service [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/08 22:33:31 UTC, 10 replies.
- [PR] Make dill optional [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/08 23:43:32 UTC, 13 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.2 to 1.19.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 04:15:02 UTC, 3 replies.
- [I] [Feature Request]: add CloudSQL Examples and update the Beam website [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/09 06:41:08 UTC, 1 replies.
- [PR] workflows: add `ALLOYDB_PASSWORD` to Precommit Python Transforms [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/09 10:48:27 UTC, 4 replies.
- [PR] Cherry-picking #36092 into release branch [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/09 11:13:13 UTC, 4 replies.
- Re: [PR] [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:16:03 UTC, 1 replies.
- Re: [PR] [Iceberg SQL] Add iceberg CDC table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:46:48 UTC, 0 replies.
- Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:46:54 UTC, 0 replies.
- Re: [I] [Feature Request]: YAML to support creating BQT4AI [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:04 UTC, 1 replies.
- Re: [I] [Bug]: `TestPipeline` Behavior Different on Windows vs Linux [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:07 UTC, 1 replies.
- Re: [I] [Bug]: Request Response IO for python SDK pickle error [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:16 UTC, 0 replies.
- Re: [I] [Failing Test]: testE2EBigtableWriteWith[...]Failures flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:18 UTC, 0 replies.
- Re: [I] [Task]: Fill Runner Metrics support gap in Sources [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:20 UTC, 0 replies.
- Re: [I] [CsvIO]: create CsvIOSplitFile class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 12:47:23 UTC, 0 replies.
- [PR] Fix PostCommit Python job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/09 15:39:29 UTC, 1 replies.
- Re: [I] The PreCommit Python Transforms job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/09 15:41:04 UTC, 1 replies.
- [PR] Kerberos Authentication for KafkaIO [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/09/09 16:54:49 UTC, 4 replies.
- [PR] Remove ORC from Iceberg module [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/09 17:42:09 UTC, 3 replies.
- Re: [I] [Parent issue] Support for Apache Pulsar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/09 18:38:17 UTC, 0 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/09 18:39:36 UTC, 12 replies.
- [I] [Task]: [Tracking]: Beam 3.0.0 Milestone 1 Python SDK breaking changes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/09 18:53:28 UTC, 0 replies.
- [I] [Tracking]: Beam 3.0.0 Milestone 1 Go SDK breaking changes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/09 18:54:28 UTC, 0 replies.
- [PR] Fix JDBC type validation to check for empty strings in Postgres [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/09 19:07:54 UTC, 4 replies.
- [PR] Cherrypick #36098 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/09 19:51:23 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.6 to 2.11.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 04:12:44 UTC, 4 replies.
- Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.6 to 2.11.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 04:12:46 UTC, 1 replies.
- [PR] Fix CVE-2025-48734, CVE-2024-13009 and CVE-2025-24970 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/10 07:24:55 UTC, 0 replies.
- Re: [PR] Fix CVE-2025-48734, CVE-2024-13009, CVE-2025-55163, CVE-2025-58056 and CVE-2025-24970 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 10:07:15 UTC, 5 replies.
- Re: [PR] [Prism]Support after_processing_time trigger [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 11:06:34 UTC, 7 replies.
- Re: [I] [Bug]: Portable runner queryMetrics returns duplicate result [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:48 UTC, 0 replies.
- Re: [I] [Bug]: Failed to restore state on Flink runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:50 UTC, 0 replies.
- Re: [I] [Failing Test]: testRedistributeAfterSlidingWindows incorrect [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:52 UTC, 0 replies.
- Re: [I] [Bug]: Java SDK BigQueryIO's RowMutationInformation class is not backward compatible with previous releases [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:54 UTC, 0 replies.
- Re: [I] [Feature Request]: add support for Datastore Database ID in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:55 UTC, 0 replies.
- Re: [I] [Bug]: CoGroupByKey throws with large (10K+) output groups on Flink runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/10 12:46:57 UTC, 0 replies.
- Re: [PR] Fix CVE-2025-48734, CVE-2024-13009 [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/10 12:59:29 UTC, 2 replies.
- Re: [I] [Feature Request]: CloudSQL Enrichment Handler [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/10 14:04:07 UTC, 0 replies.
- [PR] Revert "Update iceberg to 1.9.2" [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/10 15:16:31 UTC, 5 replies.
- [PR] Pin Avro 1.12 in expansion service container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/10 16:09:23 UTC, 7 replies.
- [PR] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/10 17:56:13 UTC, 4 replies.
- [PR] Upgrade cryptography dep to latest to resolve CVE-2024-12797 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/10 18:37:18 UTC, 5 replies.
- [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/10 18:40:04 UTC, 9 replies.
- [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/09/10 18:42:07 UTC, 45 replies.
- Re: [I] [Feature Request]: Warn users about misspelled pipeline options [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/10 19:11:59 UTC, 0 replies.
- [PR] [Release-2.68] cherry-pick #36108 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/10 19:13:41 UTC, 2 replies.
- Re: [I] [Task]: Tracking cloudpickle issues [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/10 19:56:05 UTC, 0 replies.
- [I] [Feature Request]: Add support for staging specific jars for managed transforms [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/10 21:35:36 UTC, 0 replies.
- Re: [I] [Bug]: WriteToPubSub Sink breaks in batch mode [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/10 22:34:33 UTC, 0 replies.
- [PR] Bump golang.org/x/sync from 0.16.0 to 0.17.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 04:08:54 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.2 to 1.19.6 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 04:15:10 UTC, 3 replies.
- [PR] [Dataflow Java] Support the existing --logMdc option by adding the present mdc values to custom_data json field. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/11 09:16:53 UTC, 4 replies.
- [PR] Adding CMEK support for temp_dataset [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/09/11 10:16:25 UTC, 1 replies.
- Re: [I] [prism] Metrics from runner expanded composites aren't mapped back to user terms. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 12:46:47 UTC, 0 replies.
- Re: [I] [Bug]: `GEOGRAPHY` datatype breaks while using StorageWrite API in Python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 12:46:49 UTC, 2 replies.
- Re: [I] [Feature Request]: Add WriteOption for WriteDisposition in bigqueryio.Write() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 12:46:50 UTC, 0 replies.
- Re: [I] [Bug]: Consider dropping TLS 1.0 support from webhook server [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 12:46:52 UTC, 0 replies.
- [PR] Add ThrottlingSignaler class to the Java SDK [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/11 14:36:37 UTC, 6 replies.
- [PR] Update PubsubIO.java documentation [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/09/11 15:19:03 UTC, 2 replies.
- Re: [I] [Bug]: Dataflow worker container resolved to legacy runner label if not explicitly disable/enable runner v2 in 2.54.0+.dev [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/11 15:34:50 UTC, 4 replies.
- Re: [I] [Distroless] Enable Distroless Java SDK based container images [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/11 17:11:19 UTC, 0 replies.
- [PR] feat(bigquery): add GEOGRAPHY type support for BigQuery I/O [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/11 18:31:08 UTC, 12 replies.
- [PR] infra/security: update project_id and bucket_name to match the correct configuration [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/11 19:28:27 UTC, 2 replies.
- [PR] Upgrade iceberg to 1.10.0 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/11 19:49:10 UTC, 3 replies.
- [PR] Draft: Set default redistribute keys for KafkaIO read. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/09/11 20:35:30 UTC, 0 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/11 21:34:36 UTC, 5 replies.
- [PR] BeamRowWrapper [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/11 22:00:35 UTC, 0 replies.
- [PR] [Prism] Support after-process-time triggers - part 1 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/12 00:33:56 UTC, 3 replies.
- [I] The PreCommit Python Examples job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 00:50:22 UTC, 2 replies.
- Re: [PR] Adding CMEK support for temp_dataset for Python Bigquery [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/09/12 02:52:20 UTC, 5 replies.
- [I] [Bug]: Prism early window pane is not processed immediately downstream [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/12 04:05:28 UTC, 3 replies.
- [PR] Fix flaky GrpcDirectGetWorkStreamTest.testConsumedWorkItems_itemsSplitAcrossResponses [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/12 09:44:20 UTC, 3 replies.
- [PR] Update import gpg action [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/12 12:44:47 UTC, 4 replies.
- Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 12:46:21 UTC, 0 replies.
- Re: [I] [Feature Request]: Emit warnings when pcollection elements approach or exceed 2GB limits. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 12:46:24 UTC, 1 replies.
- Re: [I] [Feature Request]: Auto-detect Schema for Parquet Sink [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 12:46:25 UTC, 1 replies.
- [PR] Update action [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/12 13:26:12 UTC, 2 replies.
- [PR] [IcebergIO] pin ORC 1.9.6 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/12 13:47:36 UTC, 3 replies.
- [PR] Return inputwatermarkAdvanced signal and use it in bundleReady [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/12 13:51:23 UTC, 2 replies.
- [PR] Fix ml gradle [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/12 13:51:45 UTC, 1 replies.
- [PR] [CP] Fix ml gradle (#36134) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/12 13:53:51 UTC, 1 replies.
- [PR] Update Beam website to release 2.68.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/12 14:40:37 UTC, 4 replies.
- [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/12 16:05:26 UTC, 4 replies.
- Re: [PR] Remove no-parallel flag on kafka IO direct precommit [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/09/12 16:12:35 UTC, 1 replies.
- [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/12 16:19:54 UTC, 10 replies.
- Re: [PR] Introduce OutputBuilder in Java SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/12 17:16:34 UTC, 8 replies.
- [PR] Managed Bigquery Java Read&Write Transforms [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/12 18:54:27 UTC, 12 replies.
- Re: [PR] [Prism] Add previousInput watermark and use it in bundleReady [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/12 20:07:01 UTC, 1 replies.
- [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/12 21:22:12 UTC, 11 replies.
- [PR] Fix PulsarIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/13 04:23:26 UTC, 8 replies.
- [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/13 05:15:21 UTC, 4 replies.
- Re: [I] [Task]: Update Python slowly updating side input example [beam] - posted by "Kittu268 (via GitHub)" <gi...@apache.org> on 2025/09/13 08:52:29 UTC, 3 replies.
- Re: [I] [Feature Request]: Add support for `GEOGRAPHY` data type in BigQuery Storge Write API in Python [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/13 12:45:53 UTC, 0 replies.
- Re: [I] Bug in Python SDK-s Enrichment transform client side throttling [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/13 12:45:54 UTC, 0 replies.
- Re: [I] [prism] Support Custom WindowFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/13 12:45:55 UTC, 0 replies.
- Re: [PR] Set default redistribute key limit for KafkaIO read. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/09/13 19:05:04 UTC, 6 replies.
- [PR] Sort output before comparison in enrichment test [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/13 21:19:02 UTC, 2 replies.
- [I] The PostCommit Python ValidatesRunner Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 03:41:20 UTC, 1 replies.
- Re: [I] DoFn.process should raise exception if something other than a List is returned [beam] - posted by "tech-savvy1 (via GitHub)" <gi...@apache.org> on 2025/09/14 07:16:04 UTC, 0 replies.
- Re: [I] [Feature Request]: Fully Support Type Checking Callables [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 12:45:17 UTC, 0 replies.
- Re: [I] [Bug]: ./gradlew checkSetup fails with Java 8 on Docker dev image [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 12:45:25 UTC, 1 replies.
- Re: [I] [Feature Request]: Add A Freature to get bigquery schema dynamically from a POJO class. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 12:45:29 UTC, 1 replies.
- Re: [I] [Bug]: Beam Interactive Tour Mismatch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/14 12:45:30 UTC, 1 replies.
- [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/14 19:33:47 UTC, 5 replies.
- [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.5.3 to 3.5.4 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 01:04:00 UTC, 0 replies.
- [PR] Fix TriggerAlways integration test. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/15 02:36:15 UTC, 0 replies.
- Re: [PR] [Prism] Disable combiner lifting for TriggerAlways [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 03:45:48 UTC, 2 replies.
- [PR] Update dill requirement from <0.3.2,>=0.3.1.1 to >=0.3.1.1,<0.4.1 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 04:09:38 UTC, 10 replies.
- [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/15 04:27:01 UTC, 11 replies.
- [PR] Fix PostCommit Python ValidatesRunner Dataflow job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/15 11:48:06 UTC, 5 replies.
- Re: [PR] raise errors instead of warnings for no iterators [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:46:42 UTC, 2 replies.
- Re: [I] [Bug]: Flink/Samza/Spark Runner could not handle groupby and flatten sharing the same input [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:46:49 UTC, 0 replies.
- Re: [I] [Feature Request]: Support returning back BoundedTrie in metric result [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:46:51 UTC, 2 replies.
- Re: [I] [Bug]: download page problems [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:46:55 UTC, 9 replies.
- Re: [I] [Feature Request]: Add support for tracking lineage with BoundedTrie [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:47:00 UTC, 2 replies.
- Re: [I] [Bug]: Unauthenticated error when running tests on Dataproc using Flink and Docker with private repos [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:47:02 UTC, 1 replies.
- Re: [I] [Bug]: Issue with the script for adding execute task in "Convert from Maven to Gradle" section [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:47:07 UTC, 1 replies.
- [I] The PerformanceTests PubsubIOIT Python Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 12:47:49 UTC, 3 replies.
- Re: [I] [Feature Request]: `kms_key` should be used in making `temp_dataset`'s. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/15 13:34:40 UTC, 0 replies.
- [PR] Allow dependabot to update all actions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/15 13:40:19 UTC, 3 replies.
- Re: [I] [Failing Test]: AttributeError for MaybeReshuffle in Python SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/15 14:14:26 UTC, 7 replies.
- [PR] Bump actions/checkout from 4 to 5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 14:22:47 UTC, 7 replies.
- [PR] Bump actions/stale from 9 to 10 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 14:50:55 UTC, 3 replies.
- [PR] Bump google-github-actions/auth from 2 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 14:55:01 UTC, 2 replies.
- [PR] Bump actions/download-artifact from 4 to 5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 14:56:00 UTC, 3 replies.
- [PR] Set selected library to default before checks [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/15 15:06:25 UTC, 3 replies.
- [PR] Bump actions/github-script from 7 to 8 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 16:03:31 UTC, 3 replies.
- [PR] Add dill dep where tensorflow-transform is used. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/15 16:07:14 UTC, 3 replies.
- [PR] Bump docker/build-push-action from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 16:07:53 UTC, 2 replies.
- Re: [I] [Bug]: PulsarIO.read() is failing with java.lang.RuntimeException: Could not find a way to create AutoValue class class com.idfy.beam.pulsar.PulsarSourceDescriptor [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 16:22:20 UTC, 0 replies.
- Re: [I] [Bug]: PulsarIO write() complains of missing ClientUrl even when provided with withClientUrl [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 16:22:21 UTC, 0 replies.
- Re: [I] PulsarIOTest.testReadFromSimpleTopic is very flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 16:22:21 UTC, 0 replies.
- Re: [I] org.apache.beam.sdk.io.pulsar.PulsarIOTest.testReadFromSimpleTopic flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 16:22:22 UTC, 0 replies.
- [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/15 16:50:05 UTC, 13 replies.
- [PR] Add blog post for Google Summer of Code 25 on improving Apache Beam's infrastructure [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/15 17:50:16 UTC, 6 replies.
- Re: [I] [Feature Request]: Make Pulsar IO connector publish messages asynchronously [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 18:06:14 UTC, 1 replies.
- Re: [I] [Feature Request]: Set option for acknowledge the messages in PulsarIO reader [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/15 18:07:16 UTC, 0 replies.
- [PR] Bump transformers from 4.30.0 to 4.53.0 in /sdks/python/apache_beam/ml/inference [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 18:58:11 UTC, 3 replies.
- Re: [PR] Bump transformers from 4.30.0 to 4.48.0 in /sdks/python/apache_beam/ml/inference [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/15 18:58:13 UTC, 1 replies.
- [PR] Defer unlocking to avoid deadlock [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/15 19:35:04 UTC, 0 replies.
- Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/15 19:47:52 UTC, 6 replies.
- [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/09/15 22:02:39 UTC, 8 replies.
- [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/09/15 23:11:28 UTC, 14 replies.
- [PR] [Prism] Fix potential side-effect in TriggerAfterEach.onFire. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/16 02:40:53 UTC, 1 replies.
- Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] - posted by "dakshing (via GitHub)" <gi...@apache.org> on 2025/09/16 08:41:04 UTC, 1 replies.
- [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/09/16 10:17:06 UTC, 9 replies.
- Re: [PR] [KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/16 12:15:05 UTC, 3 replies.
- [I] [Feature Request]: [Python] Support creating BigLake Iceberg tables in BigQuery [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/16 12:18:28 UTC, 1 replies.
- Re: [I] [Bug]: Errors running Python command can cause Dataflow container to crash with no further details [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/16 12:46:52 UTC, 0 replies.
- Re: [I] [Feature Request]: Support streaming inserts for bounded PCollections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/16 12:46:54 UTC, 0 replies.
- Re: [I] [Task]: Upgrade gcs-connector libraries to 3.x [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/16 12:46:56 UTC, 0 replies.
- [PR] Move Vertex LLM Inference IT Test to new Endpoint [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/16 13:39:19 UTC, 3 replies.
- [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/16 15:25:52 UTC, 4 replies.
- Re: [PR] Bump codecov/codecov-action from 3 to 5 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/16 15:44:59 UTC, 3 replies.
- [PR] docs(downloads): update source code download links to use closer mirror [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/16 17:00:27 UTC, 5 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.2.1 to 2.4.0 [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/16 17:29:22 UTC, 0 replies.
- [PR] workflows: Add `ubuntu-latest` to `beam_PreCommit_Python_Examples` workflow and trigger `require_docker_in_docker` tests [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/16 17:31:21 UTC, 9 replies.
- [I] [Feature Request]: add Milvus Search Enrichment Handler Examples and update the Beam website [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/16 18:20:26 UTC, 1 replies.
- [PR] [WIP] Add image generation code to Gemini Model Handler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/16 19:41:20 UTC, 0 replies.
- [PR] Changes multimap state keys() tests to not care about order. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/09/16 22:01:14 UTC, 3 replies.
- [I] [Feature Request]: BigQuerySource executeExtract() for EXPORT method should use BigQuery project [beam] - posted by "psinghbay1 (via GitHub)" <gi...@apache.org> on 2025/09/16 22:30:46 UTC, 2 replies.
- [PR] Check whether the notebook is running in a colab environment. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/09/16 23:05:20 UTC, 0 replies.
- Re: [PR] Only do the auth if the notebook is running in a colab environment. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/16 23:34:58 UTC, 1 replies.
- [I] The CloudML Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 00:50:00 UTC, 1 replies.
- Re: [PR] [Prism] Avoid firing on-time pane for some triggers. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/17 01:15:27 UTC, 6 replies.
- [PR] Bump actions/setup-node from 4 to 5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 04:10:30 UTC, 2 replies.
- [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 06:42:49 UTC, 2 replies.
- Re: [I] [Bug]: TextIO.read() runs in only one executor when using SparkStructuredStreamingRunner but runs in distributed manner with SparkRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 12:46:55 UTC, 1 replies.
- Re: [I] [Task]: fix a potential bug in TimeRangeTracker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 12:47:06 UTC, 0 replies.
- Re: [I] [CsvIO]: Create CsvIOFileBasedSource class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/17 12:47:08 UTC, 0 replies.
- Re: [I] Upgrade Netty version vulnerable to CVE-2025-24970 [beam] - posted by "joachim-isaksson (via GitHub)" <gi...@apache.org> on 2025/09/17 13:22:32 UTC, 0 replies.
- Re: [PR] fix arbitrary file access during archive extraction ("Zip Slip") [beam] - posted by "odaysec (via GitHub)" <gi...@apache.org> on 2025/09/17 13:22:53 UTC, 0 replies.
- [PR] 1Trivialproperty [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/17 14:25:44 UTC, 0 replies.
- Re: [PR] Add property support to trivial_inference.py [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/17 16:37:09 UTC, 3 replies.
- Re: [PR] Update ClickHouseIO to use the latest version of the ClickHouse JDBC driver (0.6.4) [beam] - posted by "tomnewton (via GitHub)" <gi...@apache.org> on 2025/09/17 18:32:28 UTC, 0 replies.
- [PR] Add empty side_inputs tuple to MaybeReshuffle PTransform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/17 18:59:06 UTC, 11 replies.
- [PR] Add support for PROTO format in YAML Pub/Sub transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/17 19:45:35 UTC, 2 replies.
- Re: [I] Revisit timestamp and duration representation [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/09/17 19:55:31 UTC, 1 replies.
- [PR] Add liferoad to build reviewers list [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/17 20:01:34 UTC, 3 replies.
- [PR] Bump python SDK harness to beam-master-20250917 [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/17 20:44:54 UTC, 2 replies.
- [PR] Fix an issue on pane info being overwritten by different bundles. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 03:20:19 UTC, 0 replies.
- Re: [I] [Bug]: PaneInfo not populated in Go SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 03:57:57 UTC, 3 replies.
- Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 04:03:52 UTC, 12 replies.
- [PR] Bump jlumbroso/free-disk-space from 1.3.0 to 1.3.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/18 04:14:20 UTC, 2 replies.
- [PR] FirestoreV1 - Fix output timestamp to be based on input window, not walltime. [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/18 09:00:45 UTC, 3 replies.
- Re: [I] [Bug]: FirestoreIO writes fail: timer is set to max time (294247-01-09T04:00:54.775Z) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/18 09:16:02 UTC, 1 replies.
- Re: [I] [Bug]: `beam.io.WriteToCsv` ignores `num_shards` argument. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/18 12:46:38 UTC, 0 replies.
- Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/18 12:46:40 UTC, 1 replies.
- [PR] [Go SDK] Propagate paneInfo correctly. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 13:06:02 UTC, 11 replies.
- Re: [PR] Python examples to use IObase IOs sinks in streaming (and batch) [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/09/18 13:12:29 UTC, 3 replies.
- Re: [PR] Remove Vertex LLM Inference Integration Test [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/18 14:25:13 UTC, 7 replies.
- [PR] Add missing format strings to logging calls in the Go SDK [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/18 15:12:37 UTC, 4 replies.
- [I] [Feature Request]: [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 16:11:48 UTC, 0 replies.
- [PR] Only report timeout duration parsing error during harness start. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 17:07:52 UTC, 1 replies.
- Re: [I] [Feature Request]: Reduce log spam from element_processing_timeout parsing [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/18 17:27:32 UTC, 1 replies.
- [PR] Fix a common typo flagged by a checker throughout the codebase. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/09/18 17:32:50 UTC, 3 replies.
- Re: [PR] Bump github.com/fsouza/fake-gcs-server from 1.52.2 to 1.52.3 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/18 17:36:36 UTC, 2 replies.
- [I] [Task]: Capture Build Scans for Typescript Tests [beam] - posted by "clayburn (via GitHub)" <gi...@apache.org> on 2025/09/18 18:00:38 UTC, 1 replies.
- [PR] #36196: Capture build scans from TypeScript tests [beam] - posted by "clayburn (via GitHub)" <gi...@apache.org> on 2025/09/18 18:02:09 UTC, 3 replies.
- [PR] Fix print statement format in symtab package [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/18 18:07:00 UTC, 3 replies.
- Re: [PR] [Prism] Support AfterProcessingTime triggers - part 1 [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/09/18 18:21:14 UTC, 5 replies.
- Re: [PR] Bump torch from 1.13.1 to 2.8.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/18 18:23:32 UTC, 0 replies.
- [PR] Correctly override apache/beam containers for RC on Dataflow runner job submission [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 18:28:46 UTC, 5 replies.
- Re: [I] Beam Zeta SQL docs should call out additional dependency [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:52:48 UTC, 0 replies.
- Re: [I] "SELECT COUNT(1) FROM table" doesn't work [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:53:37 UTC, 1 replies.
- Re: [I] CalciteQueryPlanner breaks ZetaSQLQueryPlanner with setting RelMetadataQuery.THREAD_PROVIDERS [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:53:50 UTC, 1 replies.
- Re: [I] CONCAT function is broken [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:02 UTC, 1 replies.
- Re: [I] FieldAccess in Join is borken [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:10 UTC, 1 replies.
- Re: [I] IndexOutOfBounds in LogicalProject [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:19 UTC, 1 replies.
- Re: [I] CAST Timestamp -> String doesn't properly handle timezones with sub-minute offsets [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:28 UTC, 1 replies.
- Re: [I] LIMIT with negative OFFSET should throw an error [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:37 UTC, 1 replies.
- Re: [I] OFFSET in LIMIT clause only accepts literal or parameter [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:54:55 UTC, 1 replies.
- Re: [I] Throw expected error when LIKE pattern ends with backslash [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:01 UTC, 1 replies.
- Re: [I] Throw exception when truncating nano/micro to millis when creating time literals [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:15 UTC, 1 replies.
- Re: [I] Have a right implementation on nullability of return type of AggregateCall [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:23 UTC, 1 replies.
- Re: [I] Select * FROM pubsub table should not throw exception [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:40 UTC, 1 replies.
- Re: [I] Throw exceptions when overflow or division by 0 in arithmetic operators [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:50 UTC, 1 replies.
- Re: [I] Support STRUCT member field access operator [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:55:59 UTC, 1 replies.
- Re: [I] Support array member accessor [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:10 UTC, 1 replies.
- Re: [I] Support struct type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:16 UTC, 1 replies.
- Re: [I] Support ARRAY type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:23 UTC, 1 replies.
- Re: [I] Support window offset for TUMBLE, HOP and SESSION [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:29 UTC, 1 replies.
- Re: [I] Support STRUCT constructor [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:36 UTC, 1 replies.
- Re: [I] Windowing functions should only accept watermarked timestamp column [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:42 UTC, 1 replies.
- Re: [I] Should validate if String literal is valid UTF-8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:48 UTC, 1 replies.
- Re: [I] Throw error for 1/0 or floating point overflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:56:54 UTC, 1 replies.
- Re: [I] Convert FLOAT64 to NUMERIC in UNION ALL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:04 UTC, 1 replies.
- Re: [I] Throw clear exception when handling unsupported interval time units [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:10 UTC, 1 replies.
- Re: [I] Support Insert statements [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:17 UTC, 1 replies.
- Re: [I] Support AVG(long) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:24 UTC, 0 replies.
- Re: [I] SUM(CASE WHEN xxx THEN 1 ELSE 0) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:30 UTC, 1 replies.
- Re: [I] Allow non ColumnRef nodes in aggregation functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:43 UTC, 0 replies.
- Re: [I] Support INT32 type [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 19:57:51 UTC, 0 replies.
- Re: [I] Don't use ZetaSQL's unimplemented functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:04 UTC, 0 replies.
- Re: [I] Define expected behavior of running ZetaSQL query on tables with unsupported field types [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:11 UTC, 0 replies.
- Re: [I] Add unit tests for ZetaSQL time-related functions that depends on system clock [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:17 UTC, 0 replies.
- Re: [I] [ZetaSQL] Support 4-byte unicode in literal string unparsing [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:26 UTC, 0 replies.
- Re: [I] Gradle command to run example on ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:33 UTC, 0 replies.
- Re: [I] Join re-ordering doesn't work for ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:39 UTC, 0 replies.
- Re: [I] [SQL] ZetaSQL unparsing should produce valid result [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:46 UTC, 0 replies.
- Re: [I] hints should be rejected [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:52 UTC, 0 replies.
- Re: [I] CAST does not work in some cases due to bugs in Calcite unparsing [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:01:59 UTC, 0 replies.
- Re: [I] BeamZetaSqlCalcRel getBoolValue IllegalStateException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:02:09 UTC, 0 replies.
- Re: [I] Forbidden IOException when reading from InputStream [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:02:16 UTC, 0 replies.
- Re: [I] UNION ALL NULL StringUtf8Coder EOFException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:02:24 UTC, 0 replies.
- Re: [I] BeamZetaSqlCalcRel$CalcFn.processElement Unsupported Beam fieldType: LOGICAL_TYPE [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:02:49 UTC, 0 replies.
- Re: [I] BeamZetaSqlCalcRel$CalcFn.processElement Field is not nullable [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:02:56 UTC, 0 replies.
- Re: [I] BeamZetaSqlCalcRel$CalcFn.processElement field is not nullable in Array field $arrayx [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:02 UTC, 0 replies.
- Re: [I] ArrayScanToUncollectConverter Unnest does not support sub-queries [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:08 UTC, 0 replies.
- Re: [I] Support ANY_VALUE in OVER/window clauses. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:16 UTC, 0 replies.
- Re: [I] BeamRelNode with different pipeline options [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:23 UTC, 0 replies.
- Re: [I] Support UNNEST(ARRAY[STRUCT()]) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:34 UTC, 0 replies.
- Re: [I] UNION ALL with double IllegalStateException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:43 UTC, 0 replies.
- Re: [I] BeamSqlUnparseContext SqlBasicCall cast to SqlIdentifier [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:53 UTC, 0 replies.
- Re: [I] ZetaSQLCalcRel should assert types match [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:03:58 UTC, 0 replies.
- Re: [I] Beam ZetaSQL supports pure SQL user-defined aggregation functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:04 UTC, 0 replies.
- Re: [I] Test pure SQL UDF for all data types [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:10 UTC, 0 replies.
- Re: [I] UnionCoder IndexOutOfBoundsException in schema-driven join transform [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:16 UTC, 0 replies.
- Re: [I] zetaSqlTimestampValueToJodaInstant IllegalStateException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:22 UTC, 0 replies.
- Re: [I] Migrate BeamSQL's SET operators to Sets transforms [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:30 UTC, 0 replies.
- Re: [I] Beam ZetaSQL test pure SQL user-defined table functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:38 UTC, 0 replies.
- Re: [I] BeamUncollectRel UncollectDoFn NullPointerException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:44 UTC, 0 replies.
- Re: [I] Support ZetaSQL DataTimePart "week with weekday" in EXTRACT and TRUNC [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:51 UTC, 0 replies.
- Re: [I] IntegrationTest is flaky for CurrentTime [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:04:57 UTC, 0 replies.
- Re: [I] SESSION TVF Optimizations [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:03 UTC, 0 replies.
- Re: [I] Lost of precision when casting ZetaSQL time with microsecond-precision [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:10 UTC, 0 replies.
- Re: [I] Update solution for ZetaSQL DOUBLE NaN equals checks. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:17 UTC, 0 replies.
- Re: [I] [Umbrella] Improve Beam ZetaSQL type system [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:28 UTC, 0 replies.
- Re: [I] Add zeta SQL GREATEST support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:33 UTC, 0 replies.
- Re: [I] ZetaSQL OFFSET support for retrieving Array Values [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:39 UTC, 0 replies.
- Re: [I] Support micro-second ZetaSQL TIMESTAMP in BeamSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:45 UTC, 0 replies.
- Re: [I] Implement VARIANCE, VAR_POP, VAR_SAMP for Beam SQL ZetaSQL dialect as CombineFn [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:51 UTC, 0 replies.
- Re: [I] Implement STDDEV, STDDEV_POP, STDDEV_SAMP for Beam SQL ZetaSQL dialect as CombineFn [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:05:58 UTC, 0 replies.
- Re: [I] Implement missing ZETA_SQL Functions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:06 UTC, 0 replies.
- Re: [I] Implement the LOGICAL_AND function for Beam SQL ZetaSQL dialect, as CombineFn. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:23 UTC, 0 replies.
- Re: [I] Improve type checking in ZetaSQL Java UDF. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:29 UTC, 0 replies.
- Re: [I] Use new ZetaSQL PreparedExpression features in ZetaSQL Calc [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:36 UTC, 0 replies.
- Re: [I] Implement the LOGICAL_OR function for Beam SQL ZetaSQL dialect, as CombineFn. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:50 UTC, 0 replies.
- Re: [I] Support COVAR_SAMP function in Beam ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:06:55 UTC, 0 replies.
- Re: [I] Support ARRAY_CONCAT_AGG fn for Zetasql dialect [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:02 UTC, 0 replies.
- Re: [I] Large doubles become "Invalid integer literal" in BeamZetaSqlCalcRel. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:08 UTC, 0 replies.
- Re: [I] Support COVAR_POP function in Beam ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:22 UTC, 0 replies.
- Re: [I] Support overloaded UDF definitions. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:28 UTC, 0 replies.
- Re: [I] Support DATETIME type in BeamJavaUdfCalcRule. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:34 UTC, 0 replies.
- Re: [I] Support STRUCT type in BeamJavaUdfCalcRule. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:39 UTC, 0 replies.
- Re: [I] Support TIME type in BeamJavaUdfCalcRule. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:45 UTC, 0 replies.
- Re: [I] OVER clause converted from ZetaSQL to Logical SQL plan [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:53 UTC, 0 replies.
- Re: [I] AggregateFn: only accumulator types with default coders are supported. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:07:58 UTC, 0 replies.
- Re: [I] Artifacts that use vendored calcite 1.28.0 fail with annotation processing error in :compileJava [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:08:04 UTC, 0 replies.
- Re: [I] ZetaSQL: support aggregations of literal values [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:08:11 UTC, 0 replies.
- Re: [I] Support Structs referencing other tables [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:08:17 UTC, 0 replies.
- Re: [I] Support params for STRING_AGG in BeamSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:08:23 UTC, 0 replies.
- [PR] Timeout execution tree creation for SDK worker ops. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:09:50 UTC, 11 replies.
- Re: [I] BigqueryIO BigNumeric Datatype Support [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:22:43 UTC, 0 replies.
- Re: [I] PubsubMessageWithAttributesCoder should not produce null attributes map [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:23:16 UTC, 0 replies.
- Re: [I] Keep python library version synced between setup.py and base_image_requirements.txt [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:23:47 UTC, 0 replies.
- Re: [I] Remove windowStrategy deserialization exception handling [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:24:01 UTC, 1 replies.
- Re: [I] Support passing stateBackend through pipeline options in python sdks [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:24:23 UTC, 0 replies.
- Re: [I] Remove experimental annotation from stable transforms in Java HBaseIO connector [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:24:35 UTC, 0 replies.
- Re: [I] Make HBaseIO write return so it can be composed (e.g. used with Wait.on) [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:24:51 UTC, 0 replies.
- Re: [I] Improve health signal for StreamingDataflowWorker [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:25:06 UTC, 0 replies.
- Re: [I] Documentation for word count example is unclear about inputFile vs pom.xml [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:25:20 UTC, 0 replies.
- Re: [I] Stop job service when pipeline execution finishes [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:25:36 UTC, 0 replies.
- Re: [I] Clean tests after Python 2 deprecation [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:25:51 UTC, 0 replies.
- Re: [I] Fedora 30: ImportError: libnsl.so.1 when importing apache_beam in Python 3 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:26:04 UTC, 0 replies.
- Re: [I] PGBKCVOperation is undocumented [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:26:16 UTC, 0 replies.
- Re: [I] Pipeline context manager calls wait_until_finish on streaming pipelines [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:26:28 UTC, 0 replies.
- Re: [I] PubsubIO (Java) write batch size can exceed request payload limit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:26:41 UTC, 0 replies.
- Re: [I] Implementing getTableStatistics for HCatalogTable [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:26:53 UTC, 0 replies.
- Re: [I] Add ReadAll transform for MongoDBIO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:27:07 UTC, 0 replies.
- Re: [I] Tagging python transform class as experimental breaks tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:27:20 UTC, 0 replies.
- Re: [I] Pycharm debugger for apache_beam/*_test.py broken [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:27:33 UTC, 0 replies.
- Re: [I] bundle_processor log spam using python SDK on dataflow runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:27:50 UTC, 0 replies.
- Re: [I] GcsFileSystem should validate directories and file names for \n chars [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:28:08 UTC, 0 replies.
- Re: [I] Example of DoFn.setup() [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:28:21 UTC, 0 replies.
- Re: [I] Dynamic Writer - combining computed shards' number for late events with window's [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:28:34 UTC, 0 replies.
- Re: [I] Cannot import InteractiveRunner as IPython.display is no longer a valid symbol. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:28:51 UTC, 0 replies.
- Re: [I] Multiple Instances of Beam Table During Query Planning [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:29:03 UTC, 0 replies.
- Re: [I] Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:29:20 UTC, 0 replies.
- Re: [I] Support additional configuration in BigQueryServices.insertAll() [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:29:40 UTC, 0 replies.
- Re: [I] Document Gradle usage with Nemo in Java quickstart [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:32:47 UTC, 0 replies.
- Re: [I] Document Gradle usage for Samza in Java quickstart [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:33:10 UTC, 0 replies.
- Re: [I] Gradle Precommits fail with a NoSuchFileException [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:39:23 UTC, 0 replies.
- Re: [I] Flink portable ValidatesRunner tests continuously run on Jenkins [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:39:45 UTC, 0 replies.
- Re: [I] Experiment with Jenkins Worker VM Sizes and # executors [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/18 20:40:46 UTC, 0 replies.
- [I] Beam Python PubSubIO Does Not Support Ordered Key Publishing [beam] - posted by "mohamed-ali24 (via GitHub)" <gi...@apache.org> on 2025/09/18 21:28:51 UTC, 0 replies.
- [PR] Allow parquet import to be None [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/18 23:45:24 UTC, 4 replies.
- [PR] Bump google.golang.org/grpc from 1.75.0 to 1.75.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:08:28 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.56.1 to 1.56.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:08:40 UTC, 2 replies.
- [PR] Bump golang.org/x/oauth2 from 0.30.0 to 0.31.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:08:43 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.85.0 to 1.85.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:08:57 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.248.0 to 0.249.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:09:04 UTC, 2 replies.
- [PR] Bump docker/setup-qemu-action from 1 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 04:13:53 UTC, 2 replies.
- Re: [I] [Bug]: PrismRunner fails to execute pipeline that DirectRunner succeeds at [beam] - posted by "pritamdodeja (via GitHub)" <gi...@apache.org> on 2025/09/19 08:00:30 UTC, 5 replies.
- Re: [I] [Bug]: Registering DoFns and CombineFns Seems Excessively Slow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 12:46:37 UTC, 0 replies.
- Re: [I] [Bug]: withOutputTags (aka side output) requires ParDo to run on each output separately [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 12:46:43 UTC, 1 replies.
- Re: [I] [Feature Request]: Implement JAR caching in the Beam YAML Provider [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 12:46:45 UTC, 0 replies.
- Re: [I] [Feature Request]: Exclusive DataFrame API for Java SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 12:46:49 UTC, 1 replies.
- [PR] Fix Null Pointer Exception in BigQueryIO [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/19 15:00:06 UTC, 4 replies.
- [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 15:36:02 UTC, 3 replies.
- [PR] [TEST ONLY] Enable unsafe trigger tests for prism [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/19 15:42:47 UTC, 0 replies.
- [PR] Kerberos auth python [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/09/19 15:46:26 UTC, 1 replies.
- [PR] Fix PreCommit Python Examples job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/19 16:14:01 UTC, 3 replies.
- [PR] Add GroupByEncryptedKey transform [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/19 16:17:34 UTC, 20 replies.
- [I] [Feature Request]: Add GroupByEncryptedKey transform [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/19 16:19:28 UTC, 7 replies.
- Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/09/19 16:48:17 UTC, 1 replies.
- [PR] Infra iam enforcer service accounts [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/19 18:25:19 UTC, 5 replies.
- [I] The PostCommit Java Hadoop Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/19 18:40:48 UTC, 4 replies.
- [PR] Revert "Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/19 18:49:42 UTC, 4 replies.
- [PR] [WIP] Java GBEK (AI generated) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/19 19:54:20 UTC, 0 replies.
- [PR] Adds Multimap support to JAVA FnApi [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/09/19 21:30:02 UTC, 17 replies.
- [PR] Support injecting trigger bundle for a batch of elements. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 00:03:55 UTC, 0 replies.
- Re: [PR] [Prism] Support injecting trigger bundle for a batch of elements. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/09/20 03:43:49 UTC, 0 replies.
- [PR] add test and potential fix for composite transforms that output dooutputtuple [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/20 10:41:35 UTC, 0 replies.
- Re: [I] [Feature Request]: Generate Beam YAML managed I/O config parameters from the schema [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/20 12:46:03 UTC, 0 replies.
- Re: [I] [Bug]: Improve the validation error when both chain and input are given for Beam YAML [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/20 12:46:05 UTC, 0 replies.
- Re: [I] [Bug]: Iceberg integration tests are flaky due to stuck pipelines in HiveCatalogIT and BigQueryMetastoreCatalogIT [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/20 12:46:07 UTC, 0 replies.
- Re: [I] [Feature Request]: Add keyed data to `KafkaReadSchemaTransformProvider` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/20 12:46:13 UTC, 1 replies.
- Re: [PR] [Prism] Support injecting triggered bundle for a batch of elements. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 13:52:08 UTC, 4 replies.
- [PR] Install go for python unit tests to use prism runner. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 14:20:16 UTC, 4 replies.
- [I] Python Unit Tests is getting much slower since 2.67.0 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 17:33:10 UTC, 4 replies.
- [PR] Revert "Install go for python unit tests to use prism runner." [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 18:34:45 UTC, 2 replies.
- [I] [Failing Test]: TestDynamicSplit/BlockOnSplit in Go Precommit Test in Flaky [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/20 23:23:12 UTC, 1 replies.
- [PR] feat(bigquery): add BigLake configuration support for Storage Write API [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/21 00:20:51 UTC, 13 replies.
- [PR] Fix a deadlock situation for BlockOnSplit test case. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/21 04:00:17 UTC, 4 replies.
- Re: [I] [Task]: Remove plumbing of cache to state backed iterable. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/21 12:46:01 UTC, 0 replies.
- Re: [I] Write-Warning -Verbose "Installation failed! (msiexec error code $($process.ExitCode))" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/21 12:46:13 UTC, 1 replies.
- [PR] Fix panic in teststream [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/21 19:36:05 UTC, 1 replies.
- Re: [PR] [Prism] Fix panic in teststream [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/21 20:07:08 UTC, 1 replies.
- [PR] Use singleton prism server by default. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/22 03:25:02 UTC, 4 replies.
- [PR] Bump google.golang.org/protobuf from 1.36.8 to 1.36.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 04:07:12 UTC, 1 replies.
- [PR] Bump github.com/docker/docker from 28.3.3+incompatible to 28.4.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 04:07:22 UTC, 2 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.38.0 to 0.39.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 04:07:33 UTC, 2 replies.
- [PR] Bump docker/login-action from 2 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 04:08:07 UTC, 2 replies.
- Re: [I] [Bug]: [Python SDK] Beam.FlatMap doesn't correctly parse TypeVar typehints [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 12:46:49 UTC, 0 replies.
- Re: [I] [Feature Request]: Yaml JdbcIO partitioning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 12:47:00 UTC, 1 replies.
- [PR] blog: GSoC 2025 - Beam YAML, Kafka and Iceberg User Accessibility [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/09/22 13:44:45 UTC, 20 replies.
- Re: [PR] [python] Fix output pcollections of composite transforms that return DoOutputsTuple [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/22 14:08:10 UTC, 4 replies.
- [PR] Remove (inactive) key from example [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/22 14:45:05 UTC, 4 replies.
- Re: [I] TextIO (and others) should provide more informative messages when encountering RVP [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/22 15:20:54 UTC, 1 replies.
- [PR] Fix race condition that causes the test flaky. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/22 20:10:43 UTC, 7 replies.
- [PR] Add Charles to the list of Website authors [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/22 22:15:09 UTC, 4 replies.
- [PR] Clarify release-guide.md [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/09/22 23:00:46 UTC, 8 replies.
- [PR] fix(pipeline): Handle missing side_inputs in AppliedPTransform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/23 00:30:21 UTC, 3 replies.
- [PR] Bump org.apache.maven.plugins:maven-compiler-plugin from 3.14.0 to 3.14.1 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 01:03:58 UTC, 1 replies.
- [PR] Bump org.apache.beam:beam-runners-direct-java from 2.67.0 to 2.68.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 01:04:05 UTC, 3 replies.
- [PR] Bump org.apache.beam:beam-sdks-java-core from 2.67.0 to 2.68.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 01:04:09 UTC, 3 replies.
- [PR] Add liferoad to go reviewwer. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 01:17:26 UTC, 1 replies.
- Re: [PR] Add liferoad to go reviewer. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 01:21:57 UTC, 0 replies.
- [PR] Update description.md [beam] - posted by "GreenStarMatter (via GitHub)" <gi...@apache.org> on 2025/09/23 02:21:54 UTC, 4 replies.
- [I] [Task]: Change sendState to handle state transition in a state machine [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 02:54:22 UTC, 0 replies.
- [PR] Improve logging messages. No functional changes. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 03:55:41 UTC, 2 replies.
- Re: [PR] [Prism] Improve logging messages and levels. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 04:02:20 UTC, 5 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.9 to 2.12.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 04:08:19 UTC, 2 replies.
- [PR] Bump golang.org/x/text from 0.28.0 to 0.29.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 04:08:25 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.43.0 to 0.44.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 04:08:30 UTC, 1 replies.
- Re: [I] [Bug]: package google-apitools missing when using PDM package manager [beam] - posted by "pineapple-pokopo (via GitHub)" <gi...@apache.org> on 2025/09/23 07:23:38 UTC, 1 replies.
- Re: [I] BigQueryAvroUtils unable to convert field with record [beam] - posted by "jeanwisser (via GitHub)" <gi...@apache.org> on 2025/09/23 08:02:35 UTC, 0 replies.
- [PR] Bump to Beam 2.68.0 [beam-starter-java] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/23 10:14:53 UTC, 1 replies.
- [PR] Bump apache-beam from 2.67.0 to 2.68.0 [beam-starter-python] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 12:05:18 UTC, 1 replies.
- Re: [I] [Feature Request]: Enabling long-running jobs to use federated STS assume role authentication for AWS resources [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 12:46:41 UTC, 1 replies.
- Re: [I] [Feature Request]: Enable AWS SQS reads for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 12:46:43 UTC, 1 replies.
- Re: [I] Bug: Beam not populating "googclient_deliveryattempt" attribute in attributes map [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 12:46:55 UTC, 0 replies.
- Re: [PR] [WIP] [Prism] Improve logging messages and levels. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/23 14:22:19 UTC, 0 replies.
- [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/09/23 14:32:41 UTC, 0 replies.
- [PR] Make BQ docs consistent [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/23 15:38:21 UTC, 5 replies.
- Re: [I] [Bug]: BigQuerySourceBase does not propagate a Coder to AvroSource [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/23 15:46:06 UTC, 0 replies.
- [PR] Expire snapshots poc with ApacheBeam [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/23 16:38:29 UTC, 1 replies.
- [PR] Solution for #19968, python sdk justs stage up-to-date versions on the required files [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/23 18:13:25 UTC, 7 replies.
- [PR] Bump transformers from 4.36.0 to 4.53.0 in /sdks/python/apache_beam/examples/inference/large_language_modeling [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 18:14:22 UTC, 1 replies.
- [PR] fix(sdk:python): Avoid AttributeError for transforms without hints [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/23 18:17:10 UTC, 24 replies.
- [PR] Bump transformers from 4.38.0 to 4.53.0 in /sdks/python/apache_beam/examples/inference/runinference_metrics [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/23 18:20:07 UTC, 1 replies.
- [I] [Feature Request]: Implement Native Java Remote Inference [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/09/23 18:51:36 UTC, 1 replies.
- [PR] This PR fixes a critical JUnit 5 compatibility issue where `TestPipeline.run()` would throw an `IllegalStateException` about missing `@Rule` annotation even when using the proper `TestPipelineExtension` for JUnit 5. [beam] - posted by "chennu2020 (via GitHub)" <gi...@apache.org> on 2025/09/23 22:14:21 UTC, 6 replies.
- [PR] Fix Build Issues with Iceberg Upgrade [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/23 22:54:41 UTC, 10 replies.
- [PR] Increase expansion service connection timeout to 30 sec. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/23 23:53:19 UTC, 5 replies.
- [PR] Revert "Bump actions/checkout from 4 to 5" [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/24 01:11:41 UTC, 5 replies.
- [PR] Fix JUnit 5 module [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/24 04:02:20 UTC, 7 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.39.0 to 1.39.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 04:10:32 UTC, 2 replies.
- [PR] Bump docker/setup-buildx-action from 1 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 04:10:34 UTC, 1 replies.
- [PR] Bump actions/setup-go from 5 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 04:10:39 UTC, 2 replies.
- [PR] Bump actions/setup-java from 4 to 5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 04:10:44 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.56.2 to 1.57.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 04:10:47 UTC, 2 replies.
- [PR] Allow manually running code_completion_plugin_tests.yml [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/24 11:32:25 UTC, 3 replies.
- [PR] Bump python SDK harness [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/24 12:03:36 UTC, 7 replies.
- Re: [I] [Task]: Improve README.md for https://github.com/apache/beam-starter-java-provider [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 12:46:50 UTC, 1 replies.
- Re: [I] [CsvIO]: Create CsvIOParseKV::withCustomRecordParsing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 12:47:07 UTC, 0 replies.
- Re: [I] [CsvIO]: Implement CsvIOParse::parseCell method [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/24 12:47:08 UTC, 0 replies.
- [I] [Feature Request]: Implement histogram metrics for the python SDK [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/24 13:06:17 UTC, 0 replies.
- Re: [PR] run bomupgrader.py to update Google Cloud-related dependency [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/24 14:45:21 UTC, 1 replies.
- [PR] Fix Managed I/O link in the blog [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/09/24 16:35:14 UTC, 3 replies.
- [PR] Fix CloudML Benchmarks Dataflow job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/24 19:13:35 UTC, 6 replies.
- [PR] Revert "Update dill requirement from <0.3.2,>=0.3.1.1 to >=0.3.1.1,<0.4.1 in /sdks/python" [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/24 19:52:38 UTC, 4 replies.
- Re: [PR] Add BigTableRead connector and new feature implemented [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:34:04 UTC, 1 replies.
- Re: [PR] feat(yaml): Add BigTable write connector [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:34:45 UTC, 0 replies.
- Re: [I] [yaml]: Normalize BigtableIO [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:36:40 UTC, 1 replies.
- Re: [I] [Feature Request]: Support for BigTable from YAML [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:37:58 UTC, 1 replies.
- Re: [PR] [YAML] Basic integration testing framework. [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:43:01 UTC, 0 replies.
- Re: [I] [YAML] Integration testing framework for YAML [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:43:17 UTC, 1 replies.
- [PR] Save Logical Type Registry and Schema Registry on cloudpickle save main session [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/24 20:47:09 UTC, 2 replies.
- Re: [I] [yaml] Normalize RunInference transform [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 20:58:29 UTC, 0 replies.
- Re: [I] [Bug]: YAML provider fails on Windows due to 'which' command not available [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/24 21:00:52 UTC, 0 replies.
- Re: [I] [yaml] Normalize MLTransform transform [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 21:01:04 UTC, 1 replies.
- Re: [I] [Failing Test]: YAML integration tests are flaky as a result of failing to start expansion service [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 21:07:20 UTC, 1 replies.
- Re: [I] [Failing Test]: beam_PreCommit_Yaml_Xlang_Direct fails with with external bigquery write [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/24 21:12:13 UTC, 0 replies.
- Re: [I] [Feature Request]: Add the ability to cancel timers in methods annotated with @onWindowExpiration [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/24 21:40:14 UTC, 2 replies.
- [I] CassandraIO::ReadFn needs to quote column name with "" to handle columns with reserved keyword like `true` [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2025/09/24 22:16:31 UTC, 0 replies.
- [I] The Playground CI Nightly job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 03:42:11 UTC, 1 replies.
- Re: [I] [Bug]: Dataflow keeps retrying to obtain an already deleted BigQuery dataset [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/25 03:42:47 UTC, 1 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.2.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:07:23 UTC, 3 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.0.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:07:44 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.0.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:07:48 UTC, 1 replies.
- [PR] Bump actions/setup-python from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:08:40 UTC, 1 replies.
- [PR] Bump gradle/wrapper-validation-action from 1.0.6 to 3.5.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:08:44 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.31.8 to 1.31.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:08:49 UTC, 2 replies.
- [PR] Bump google-github-actions/setup-gcloud from 2 to 3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:08:56 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.18.12 to 1.18.14 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 04:09:56 UTC, 3 replies.
- [PR] Fix PostCommit Java Hadoop Versions job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/25 06:20:11 UTC, 12 replies.
- [PR] [Dataflow Streaming] Move functionality creating windmill tags to a common class. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/09/25 07:56:34 UTC, 7 replies.
- Re: [PR] Fix: Handle invalid bucket path warning in Beam Python SDK [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/25 11:52:47 UTC, 0 replies.
- Re: [I] [Bug]: Bigtable - You have reached the limit of total mutations in your queue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 12:46:49 UTC, 0 replies.
- Re: [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/25 12:46:59 UTC, 1 replies.
- Re: [I] [Feature Request]: Beam Protobuf Schema (Java) [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/09/25 15:09:35 UTC, 0 replies.
- [I] [Bug]: KafkaIO: Setup failures in downstream DoFn cause message loss with manual offset management [beam] - posted by "jaagupku (via GitHub)" <gi...@apache.org> on 2025/09/25 15:37:56 UTC, 2 replies.
- Re: [I] [Task]: Add Python AfterSynchronizedProcessingTime trigger and add an Iceberg CDC streaming read test [beam] - posted by "marianobrc (via GitHub)" <gi...@apache.org> on 2025/09/25 15:59:49 UTC, 1 replies.
- [PR] Add AftersynchronizedProcessing Time as continuation trigger [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/25 16:06:30 UTC, 10 replies.
- Re: [I] [Bug]: ReadFromKafka YAML transform cannot specify JSON schema [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/09/25 17:18:44 UTC, 2 replies.
- Re: [PR] Save Logical Type and Coder Registry on cloudpickle save main session [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/25 19:04:07 UTC, 22 replies.
- Re: [I] Better filesystem discovery mechanism in Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/25 19:20:21 UTC, 0 replies.
- [PR] Fix changes whitespace [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/25 19:56:14 UTC, 5 replies.
- [PR] Add Iceberg Streaming Write example with Beam SQL [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/25 21:42:31 UTC, 0 replies.
- [PR] Revert "Update Beam Protobuf Schema (Java) (#35150)" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/25 22:25:55 UTC, 3 replies.
- [PR] Adds some extra logging to GCP Spanner Changestream Source [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/09/25 22:57:11 UTC, 3 replies.
- [PR] Adds logging to DetectNewPartitionsAction in spanner changestream source. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/09/25 23:32:05 UTC, 4 replies.
- Re: [I] [Feature Request]: Support Beam Python on macos arm64. [beam] - posted by "hauntsaninja (via GitHub)" <gi...@apache.org> on 2025/09/25 23:52:05 UTC, 0 replies.
- [PR] Bump golangci/golangci-lint-action from 3 to 8 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 04:10:07 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.88.1 to 1.88.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 04:10:28 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.6 to 1.19.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 04:11:38 UTC, 3 replies.
- Re: [I] [Bug]: Beam SDK throws `NoClassDefFoundError` using SparkRunner in Dataproc 2.1 (Java 11) [beam] - posted by "DoctorCatCodes (via GitHub)" <gi...@apache.org> on 2025/09/26 04:42:31 UTC, 0 replies.
- [PR] [WIP] Fix integration test broken by #35150 [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/26 06:56:55 UTC, 1 replies.
- [PR] Enforce deterministic field order in Schema generated from KafkaIO classes. [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/26 08:12:55 UTC, 4 replies.
- [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] - posted by "Suvrat1629 (via GitHub)" <gi...@apache.org> on 2025/09/26 11:54:44 UTC, 3 replies.
- Re: [PR] [WIP] Fix broken PreCommit YAML Xlang Direct [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/26 12:31:30 UTC, 1 replies.
- Re: [I] [Feature Request]: Support caching ReadFromBigQuery between runs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 12:46:35 UTC, 0 replies.
- Re: [I] [Bug]: The ":runners:flink:1.19:runQuickstartJavaFlinkLocal" gradle command does not work now [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 12:46:42 UTC, 1 replies.
- [PR] Fix broken PreCommit YAML Xlang Direct [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/09/26 12:54:06 UTC, 4 replies.
- Re: [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/26 13:43:19 UTC, 0 replies.
- [PR] Set latest tag based on branch in sdk and docker snapshots [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/26 14:44:35 UTC, 6 replies.
- Re: [I] [Task]: Build a cleaner for assets in the GCP test environment [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/26 15:01:47 UTC, 0 replies.
- [PR] Fix typevar reduce for PYPI. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/26 16:44:44 UTC, 7 replies.
- [PR] Add option to pickle relative filepaths in cloudpickle. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/26 16:52:29 UTC, 7 replies.
- Re: [I] [Task]: Manage Infra privileges via Infra-as-code [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/09/26 17:01:29 UTC, 0 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 18:40:36 UTC, 1 replies.
- Re: [I] [Bug]: Only mark snapshots as latest if published from master [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/26 19:09:22 UTC, 0 replies.
- [PR] [GSoC 25][Blog Post]: Google Summer of Code 2025 - Beam ML Vector DB/Feature Store [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/26 20:52:51 UTC, 2 replies.
- Re: [PR] [GSoC 25][Blog Post]: Beam ML Vector DB/Feature Store Project [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 20:55:52 UTC, 10 replies.
- [PR] Fix BigQuery Batch write Integration tests [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/26 20:58:54 UTC, 8 replies.
- [PR] CONTRIBUTING.md: include workflows README doc reference [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/09/26 21:06:42 UTC, 3 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 21:34:50 UTC, 3 replies.
- [I] The PostCommit XVR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 21:34:53 UTC, 3 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 21:34:56 UTC, 3 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 21:34:59 UTC, 3 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/26 22:14:01 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Support for Python 3.13 [beam] - posted by "johncarney (via GitHub)" <gi...@apache.org> on 2025/09/26 23:08:57 UTC, 2 replies.
- [PR] beam-sql.sh, a standalone launcher for Beam SQL Shell [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/09/27 07:02:29 UTC, 15 replies.
- Re: [PR] Default getUseStorageApiConnectionPool to true instead of false [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/27 12:45:53 UTC, 1 replies.
- [I] [Bug]: TensorRT 10.x compatibility issues in TensorRTEngineHandlerNumPy [beam] - posted by "SaiShashank12 (via GitHub)" <gi...@apache.org> on 2025/09/27 18:53:31 UTC, 4 replies.
- [I] The Update Python Depedencies job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/28 03:44:04 UTC, 1 replies.
- Re: [I] [CsvIO]: Implement CsvIOParseKV::expand() and finalize CsvIOParseKV class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/28 12:46:23 UTC, 0 replies.
- [I] The PerformanceTests Cdap job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/28 12:47:05 UTC, 1 replies.
- [I] The PerformanceTests HadoopFormat job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/28 12:47:06 UTC, 2 replies.
- [I] The PerformanceTests JDBC job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/28 12:47:14 UTC, 1 replies.
- [PR] Fix TensorRT compatibility with version 10.x [beam] - posted by "SaiShashank12 (via GitHub)" <gi...@apache.org> on 2025/09/29 04:15:11 UTC, 3 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.2.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 04:22:49 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.6 to 1.19.9 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 04:34:02 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.45.0 to 1.46.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 04:34:15 UTC, 2 replies.
- [PR] [wip] cache encoded key [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/09/29 09:11:14 UTC, 0 replies.
- Re: [PR] Update GitHub Actions to run Python 3.13 Tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 12:46:49 UTC, 0 replies.
- Re: [I] [Feature Request]: make some of the dependencies optional/behind a feature flag [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 12:46:51 UTC, 0 replies.
- Re: [I] [Bug]: Dataflow worker shuts down without creating dump file in GO sdk [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 12:46:58 UTC, 1 replies.
- Re: [I] [Bug][Prism]: Prism gets stuck when trying to flatten 2 unbounded pcollections [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 12:47:00 UTC, 1 replies.
- Re: [I] [Bug]: Support error handling in PyTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 12:47:03 UTC, 0 replies.
- [PR] Fix PerformanceTests jobs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/29 13:47:57 UTC, 8 replies.
- Re: [PR] JUnit5 support [beam] - posted by "idc101 (via GitHub)" <gi...@apache.org> on 2025/09/29 13:56:26 UTC, 1 replies.
- [PR] Add ability for coders to set version tags for update compat checks. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/09/29 14:44:35 UTC, 10 replies.
- [PR] increase timeout for "Publish Beam SDK Snapshots" [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/29 15:16:37 UTC, 9 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/29 16:34:08 UTC, 1 replies.
- [PR] Fix Update Python Dependencies job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/09/29 16:39:09 UTC, 4 replies.
- [I] [Bug]: Missing BigTable Yaml docs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/29 16:53:25 UTC, 0 replies.
- [PR] Add pipeline option to enforce gbek [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/29 17:37:20 UTC, 4 replies.
- Re: [PR] [WIP] Java GBEK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/29 20:36:08 UTC, 0 replies.
- Re: [PR] Java GBEK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/09/29 20:48:01 UTC, 1 replies.
- [PR] Upgrade sqlline from 1.4.0 to 1.12.0 [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/09/30 02:55:32 UTC, 5 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.39.1 to 1.39.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 04:09:12 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.19.6 to 1.19.10 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 04:10:34 UTC, 2 replies.
- [PR] Add Apache Iceberg support and Catalog support to Beam SQL documentation [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/09/30 07:48:39 UTC, 5 replies.
- Re: [I] [Feature Request]: hover effect on Apache community development [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 12:47:00 UTC, 1 replies.
- [I] The PreCommit Python PVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 12:47:57 UTC, 0 replies.
- [I] The PreCommit Prism Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 12:48:03 UTC, 0 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 12:48:04 UTC, 1 replies.
- [PR] fix license script [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/09/30 13:22:22 UTC, 4 replies.
- Re: [I] [Bug]: WriteToPubSub silently failing to publish messages [beam] - posted by "clementmangin (via GitHub)" <gi...@apache.org> on 2025/09/30 13:31:49 UTC, 0 replies.
- Re: [I] [Feature Request]: Allow users to pass service name for profiler for java [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/30 13:37:33 UTC, 0 replies.
- [I] The PreCommit Java Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:00 UTC, 1 replies.
- [I] The PreCommit Java Examples Dataflow Java21 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:09 UTC, 0 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:10 UTC, 1 replies.
- [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:14 UTC, 1 replies.
- [I] The PreCommit Java PVR Flink Docker job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:23 UTC, 0 replies.
- [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/09/30 15:36:24 UTC, 1 replies.
- [PR] Add schema provider support for Kafka redistribute options [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/09/30 16:34:20 UTC, 5 replies.
- [PR] [Prism] Support AfterProcessingTime triggers - part 2 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/30 16:55:47 UTC, 3 replies.
- [PR] Update python metrics example in programming guide [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/30 17:33:36 UTC, 0 replies.
- [PR] Histogram [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/09/30 17:42:12 UTC, 0 replies.
- [PR] Add temp_location to all BigQuery Write examples and integration tests [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/30 18:17:11 UTC, 8 replies.
- [PR] Check the existence of _fields instead of __annotations__ for NamedTuple. [beam] - posted by "yilei (via GitHub)" <gi...@apache.org> on 2025/09/30 19:04:31 UTC, 2 replies.
- [I] [Task]: Support more ways than Maven Central to download jars for Python x-lang use cases [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/09/30 19:31:34 UTC, 0 replies.
- [PR] Minor changes on Managed JDBCIO [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/09/30 19:42:25 UTC, 0 replies.
- [I] [Bug]: Iceberg managed connector upgrade failed in GCP Dataflow [beam] - posted by "marianobrc (via GitHub)" <gi...@apache.org> on 2025/09/30 20:18:51 UTC, 2 replies.
- [PR] Update python SDK container image [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2025/09/30 20:18:52 UTC, 11 replies.
- [PR] Set user agent when downloading jars with local_jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/09/30 21:29:21 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/09/30 22:16:51 UTC, 0 replies.