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

---

- Re: [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_load_model_latency_milli_secs:mean_load_model_latency_milli_secs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/01 07:25:04 UTC, 0 replies.
- Re: [PR] [Dataflow Streaming] Cache StateNamespace encoded keys using SoftReference [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/01 09:30:19 UTC, 1 replies.
- Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/01 09:31:11 UTC, 0 replies.
- Re: [PR] [Dataflow] Remove unused PhysicalElementCount Counter [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/04/01 09:40:16 UTC, 0 replies.
- Re: [PR] [Java]Add Map Type Support to JsonToRow Transformer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:12 UTC, 5 replies.
- Re: [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:17 UTC, 5 replies.
- Re: [PR] Add support for top-level table properties table creation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:26 UTC, 4 replies.
- Re: [PR] Rethrowing Exception from CassandraIO's ReadFn [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:35 UTC, 4 replies.
- Re: [PR] Add support for collections.abc.Mapping [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:42 UTC, 1 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:45 UTC, 5 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:15:52 UTC, 5 replies.
- Re: [PR] Bump net.researchgate.release from 2.8.1 to 3.1.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:46:30 UTC, 2 replies.
- Re: [PR] Fix flaky test suite beam_PostCommit_XVR_Direct [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 12:46:35 UTC, 0 replies.
- [PR] Update reviewers to more accurately match current state of repo [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/01 12:49:41 UTC, 3 replies.
- Re: [PR] Support Time Partitioned Test Tables in BigqueryResourceManager [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 13:00:38 UTC, 0 replies.
- Re: [I] [Feature Request]: Support Time Partitioned Test Tables in BigqueryResourceManager [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 13:00:39 UTC, 0 replies.
- Re: [PR] Attempt to repro grpc issue with debugging [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/01 13:12:19 UTC, 0 replies.
- Re: [I] [Feature Request]: Add support for AWS session/temporary credentials in AwsOptions [beam] - posted by "Avi-Sikirov (via GitHub)" <gi...@apache.org> on 2025/04/01 13:31:10 UTC, 0 replies.
- Re: [PR] Fix looker metrics [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/01 13:40:32 UTC, 3 replies.
- [PR] minor doc updates [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 13:44:10 UTC, 2 replies.
- [PR] ✨ Upgrade extension to JupyterLab 4.x compatibility [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/04/01 13:55:42 UTC, 0 replies.
- [PR] Updated the discussion doc up to Beam 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 15:33:59 UTC, 2 replies.
- Re: [PR] ✨ Upgrade sidepanel extension to JupyterLab 4.x compatibility [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 15:37:58 UTC, 3 replies.
- Re: [PR] Fn Runner Watermark issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/01 15:38:01 UTC, 7 replies.
- Re: [PR] Add vendored cloudpickle [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/04/01 15:41:00 UTC, 1 replies.
- [PR] Bump GoogleAdsIO to v19 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/01 15:53:18 UTC, 5 replies.
- [I] [Bug]: Dataflow worker shuts down without creating dump file in GO sdk [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/01 16:18:28 UTC, 0 replies.
- [PR] Updated the republished workflow to 2.64.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 16:24:13 UTC, 2 replies.
- Re: [PR] Add 3 examples in playground SQL transform, schema transform and Composite Combine [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/01 16:43:11 UTC, 6 replies.
- Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 16:43:14 UTC, 1 replies.
- [PR] plumb grpc flow control settings via UserWorkerRunnerV1Settings [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/01 17:11:59 UTC, 3 replies.
- Re: [PR] Auto-enable allowDuplicates for Redistribute with ALO streaming mode [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/04/01 17:50:04 UTC, 3 replies.
- [PR] Update Beam to 2.64.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:00:04 UTC, 1 replies.
- Re: [PR] do not block other threads from health checking if a stream is blocked [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/01 18:29:21 UTC, 9 replies.
- [PR] Update the python deps [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:54:53 UTC, 2 replies.
- Re: [PR] Bump org.hamcrest:hamcrest from 2.2 to 3.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:12 UTC, 3 replies.
- Re: [PR] Bump actions/setup-java from 3 to 4 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:12 UTC, 1 replies.
- Re: [PR] Bump org.apache.maven.plugins:maven-assembly-plugin from 3.6.0 to 3.7.1 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:13 UTC, 1 replies.
- Re: [PR] Bump org.apache.maven.plugins:maven-compiler-plugin from 3.10.1 to 3.13.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:13 UTC, 1 replies.
- Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.59.0 to 2.60.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:14 UTC, 1 replies.
- Re: [PR] Bump org.apache.beam:beam-sdks-java-core from 2.59.0 to 2.60.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:14 UTC, 3 replies.
- Re: [PR] Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.5.0 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:16 UTC, 1 replies.
- Re: [PR] Bump actions/checkout from 3.5.3 to 4.2.2 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:17 UTC, 1 replies.
- Re: [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.5.2 [beam-starter-java] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 18:56:17 UTC, 1 replies.
- Re: [PR] [Go] Fix reshuffle implementation to use the global window for gbk output [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/01 19:15:57 UTC, 0 replies.
- Re: [PR] Bump golang.org/x/net from 0.37.0 to 0.38.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/01 19:18:25 UTC, 0 replies.
- [PR] Skip TestOomParDo for Dataflow [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/01 19:59:18 UTC, 5 replies.
- Re: [PR] add vendor to manually shutdown and restart GetWorkerMetadataStream to prevent DEADLINE_EXCEEDED errors [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/01 20:06:50 UTC, 13 replies.
- Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/01 20:34:42 UTC, 31 replies.
- Re: [I] The PostCommit Go job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/01 21:01:30 UTC, 0 replies.
- Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] - posted by "jyemin (via GitHub)" <gi...@apache.org> on 2025/04/01 21:08:02 UTC, 4 replies.
- Re: [I] The PostCommit Go Dataflow ARM job is flaky [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/01 21:24:49 UTC, 0 replies.
- [I] [Bug]: download page problems [beam] - posted by "sebbASF (via GitHub)" <gi...@apache.org> on 2025/04/01 22:19:27 UTC, 2 replies.
- Re: [PR] ✨ Upgrade sidepanel extension to JupyterLab 4.x compatibility [DO NOT MERGE] [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/01 22:27:26 UTC, 9 replies.
- [PR] fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2025/04/02 00:59:20 UTC, 0 replies.
- [I] [Bug]: ReadFromKafkaViaSDF does not set coder when using withValueDeserializerAndCoder [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2025/04/02 01:19:36 UTC, 3 replies.
- [PR] Bump org.apache.maven.plugins:maven-compiler-plugin from 3.10.1 to 3.14.0 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 01:30:26 UTC, 1 replies.
- [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.1.2 to 3.5.3 [beam-starter-java] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 01:30:31 UTC, 1 replies.
- Re: [I] [Feature Request]: Record Aggregation option in Kinesis Writer [beam] - posted by "Nakachi-S (via GitHub)" <gi...@apache.org> on 2025/04/02 03:26:49 UTC, 0 replies.
- Re: [PR] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2025/04/02 03:44:05 UTC, 15 replies.
- [PR] Bump github.com/go-sql-driver/mysql from 1.9.0 to 1.9.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 04:13:07 UTC, 2 replies.
- Re: [PR] Bump org.sonarqube from 3.0 to 6.1.0.5360 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 12:14:27 UTC, 5 replies.
- Re: [PR] Clickhouse IT RM JDBC fix + ClickHouseRowsCheck [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 12:14:29 UTC, 5 replies.
- Re: [PR] [DO NOT MERGE] Prototype RemoteModelHandler base class [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 12:14:31 UTC, 0 replies.
- [I] The PostCommit Java SingleStoreIO IT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 12:49:54 UTC, 2 replies.
- [PR] Fix CVE-2025-25193 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 13:26:41 UTC, 2 replies.
- [PR] Remove social media pieces from release guide [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/02 13:49:51 UTC, 6 replies.
- [PR] Label managed transform [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 14:57:52 UTC, 0 replies.
- Re: [I] [Feature Request]: OpenTelemetry Support [beam] - posted by "natanascimento (via GitHub)" <gi...@apache.org> on 2025/04/02 15:01:06 UTC, 2 replies.
- [PR] JDBCIO - handly empty driverjars argument [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/04/02 15:17:44 UTC, 1 replies.
- [PR] Fix link typo [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 15:19:08 UTC, 0 replies.
- Re: [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/02 15:47:39 UTC, 12 replies.
- [PR] Add the ability to unit test YAML pipelines. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/02 15:52:08 UTC, 4 replies.
- [PR] fix [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/04/02 15:59:55 UTC, 0 replies.
- Re: [PR] JDBCIO - handle empty driverjars argument [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/02 16:32:47 UTC, 4 replies.
- Re: [PR] Fix link typos [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 16:41:22 UTC, 6 replies.
- Re: [PR] Passing in key metadata when Reading From Kafka [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 16:49:17 UTC, 1 replies.
- [PR] Add native Beam schematransform autogen snippet [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 17:02:15 UTC, 11 replies.
- Re: [PR] [DO NOT MERGE] Add support for collections dict subclasses [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/02 17:05:42 UTC, 1 replies.
- Re: [PR] Introduce RemoteModelHandler abstract base class [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/02 17:07:37 UTC, 11 replies.
- [I] [Feature Request]: hover effect on Apache community development [beam] - posted by "N0tstgr (via GitHub)" <gi...@apache.org> on 2025/04/02 17:34:56 UTC, 0 replies.
- [PR] Update beam-master image. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/02 17:51:45 UTC, 2 replies.
- [PR] Add rc00 tag [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/02 18:25:10 UTC, 2 replies.
- [PR] Revert "Add rc00 tag" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/02 18:26:01 UTC, 1 replies.
- [PR] Keyed kafka sink [beam] - posted by "eyaskevich26 (via GitHub)" <gi...@apache.org> on 2025/04/02 18:29:00 UTC, 1 replies.
- [PR] Upgrade Iceberg BQMS version [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 18:30:21 UTC, 4 replies.
- [I] The PostCommit Java InfluxDbIO Integration Test job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 18:49:27 UTC, 3 replies.
- [PR] Add an v-2.XX.0-RC00 when release branch is cut to enable git describe [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/02 19:00:25 UTC, 1 replies.
- Re: [PR] Add an v-2.XX.0-RC00 tag to master when release branch is cut to enable git describe [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/02 19:02:38 UTC, 1 replies.
- Re: [PR] Add STRING format to ReadFromKafka schema transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/02 19:04:02 UTC, 0 replies.
- [PR] Fix PostCommit Java SingleStoreIO IT job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/02 19:09:53 UTC, 1 replies.
- [PR] Remove build label exclusion and just use workflows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/02 19:11:01 UTC, 3 replies.
- [PR] [ManagedIO] Fail expansion when encountering extra or unknown configuration [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/02 19:37:53 UTC, 8 replies.
- [PR] Update illustration for cut_release_branch workflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/02 20:48:31 UTC, 8 replies.
- [PR] dummy change [beam] - posted by "yuhrichard (via GitHub)" <gi...@apache.org> on 2025/04/02 21:23:23 UTC, 1 replies.
- [PR] Add a link to the Beam yaml examples. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/02 22:08:42 UTC, 3 replies.
- [PR] Add new resource hints: max active dofn per worker [beam] - posted by "AMOOOMA (via GitHub)" <gi...@apache.org> on 2025/04/02 23:34:10 UTC, 0 replies.
- [PR] Add Drain mode to PaneInfo [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/03 00:43:55 UTC, 4 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 00:49:39 UTC, 3 replies.
- [PR] Fix FanOutStreamingEngineWorkerHarnessTest - testOnNewWorkerMetadata_redistributesBudget [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/03 01:25:37 UTC, 8 replies.
- [PR] sdks/python: Integrate open ai embedded generator [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/04/03 01:55:18 UTC, 0 replies.
- [PR] sdks/python: integrate Weaviate vector database I/O connector [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/04/03 02:12:42 UTC, 0 replies.
- [PR] Avoid calling getStackTrace when results are cached in RowCoderGenerator.generate [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/03 02:49:07 UTC, 5 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.48.0 to 1.48.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 05:05:31 UTC, 3 replies.
- [PR] Fix postcommit python flaky tests [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/03 11:13:14 UTC, 10 replies.
- Re: [PR] 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/04/03 12:14:34 UTC, 5 replies.
- Re: [PR] sdks/python: enrich data with CloudSQL [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 12:14:36 UTC, 8 replies.
- Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 12:14:38 UTC, 5 replies.
- Re: [PR] Bump @octokit/plugin-paginate-rest, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 12:14:40 UTC, 5 replies.
- Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/03 12:14:46 UTC, 6 replies.
- [PR] Add reducers for threading.Lock and EnumDescriptor. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/03 15:26:22 UTC, 3 replies.
- Re: [PR] Fix incorrect nullness in FlinkJobInvoker and JobInvoker [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/03 15:36:31 UTC, 4 replies.
- Re: [PR] Interpolate console URL properly in error case [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/03 15:44:13 UTC, 1 replies.
- Re: [I] Add support for side inputs in Spark portable streaming [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/04/03 16:05:44 UTC, 0 replies.
- Re: [I] Add support for state in Spark portable streaming [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/04/03 16:06:24 UTC, 0 replies.
- [PR] [IcebergIO] Add dataflow tests with and without managed experiment [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/03 16:27:00 UTC, 5 replies.
- Re: [PR] Normalize tf record io [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/03 18:18:58 UTC, 31 replies.
- Re: [PR] Clean up GCP Resources (Pubsub) [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2025/04/03 21:03:55 UTC, 0 replies.
- Re: [I] [Task]: Update the minor version of cloudpickle library prior to Beam release. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/04/03 22:01:09 UTC, 1 replies.
- [PR] consume flow control settings updates from job settings [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/03 22:37:40 UTC, 35 replies.
- [PR] [JdbcIO] add customizable validation query [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/03 22:39:16 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.39.1 to 1.41.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 04:46:30 UTC, 2 replies.
- Re: [PR] Bump github.com/nats-io/nats.go from 1.39.1 to 1.40.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 04:46:32 UTC, 1 replies.
- Re: [I] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2025/04/04 05:21:11 UTC, 2 replies.
- [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2025/04/04 06:36:54 UTC, 17 replies.
- [I] [Bug]: Security vulnerability in parquet serialization and deserialization [beam] - posted by "iamadhee (via GitHub)" <gi...@apache.org> on 2025/04/04 07:27:46 UTC, 4 replies.
- Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.0.2 to 2.2.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:28 UTC, 2 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/04/04 12:14:30 UTC, 5 replies.
- Re: [PR] [Java] Ensure Pipeline Execution Requires Configuration Options or Logs Warning [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:52 UTC, 6 replies.
- Re: [PR] [Java] Added tests for S3ReadableSeekableByteChannel [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:54 UTC, 1 replies.
- Re: [PR] [Java] Add parsedData to Hl7v2Message and Update HL7v2IO Docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:55 UTC, 5 replies.
- Re: [PR] [DO NOT MERGE] Removed < 1.66 for grpcio [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:58 UTC, 5 replies.
- Re: [PR] Switch to use registerFileSystemsOnce for SerializablePipelineOptions constructor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:14:59 UTC, 4 replies.
- Re: [PR] Newtypes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 12:46:16 UTC, 1 replies.
- Re: [PR] [KafkaIO] Update tracker and watermark for non-visible progress [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2025/04/04 14:04:07 UTC, 9 replies.
- Re: [I] Add unit tests for S3ReadableSeekableByteChannel [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/04 14:32:21 UTC, 0 replies.
- Re: [PR] Fix the error for directory separator [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/04 16:37:50 UTC, 7 replies.
- Re: [I] [Bug][Python] dataflow_runner.py doesn't substitute variables for console link [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/04 16:44:59 UTC, 0 replies.
- [PR] [WIP] Open Telemetry Tracing for java worker [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/04/04 16:49:13 UTC, 0 replies.
- Re: [PR] Improve varint encoding throughput with unrolled loop [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/04 16:52:00 UTC, 1 replies.
- Re: [PR] [WIP] Open Telemetry Tracing for java sdk [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/04 17:04:41 UTC, 5 replies.
- Re: [I] Make withDataSourceConfiguration and withDataSourceProviderFn exclusive in JdbcIO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/04 17:31:07 UTC, 0 replies.
- Re: [PR] Issue warnings when dataSourceConfiguration and dataSourceProviderFn are set [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/04 17:31:07 UTC, 0 replies.
- [PR] Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/04 19:37:39 UTC, 5 replies.
- [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/04 22:11:40 UTC, 4 replies.
- Re: [PR] [AnomalyDetection] Add a notebook for anomaly detection with Z-Score [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:17 UTC, 3 replies.
- Re: [PR] Add ability to specify partition bounds via jdbc xlang. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:18 UTC, 4 replies.
- Re: [PR] Key by paneindex and reshuffle before loading files. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:19 UTC, 6 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/04/05 12:14:21 UTC, 5 replies.
- Re: [PR] [KafkaIO] Remove duplicate offset in range check [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:23 UTC, 4 replies.
- Re: [PR] Bump @octokit/plugin-paginate-rest and @octokit/rest in /scripts/ci/issue-report [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:25 UTC, 4 replies.
- Re: [PR] Fix Docker build error by adding fallback for python3.12-distutils [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:27 UTC, 4 replies.
- Re: [PR] Tour of Beam: update GroupByKey example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:14:29 UTC, 4 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/05 12:45:58 UTC, 3 replies.
- Re: [PR] Add the simple RC workflow to validate Go SDK with wordcount [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/05 13:21:52 UTC, 3 replies.
- [PR] updated the release guide [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/05 16:56:05 UTC, 3 replies.
- Re: [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/06 12:14:17 UTC, 7 replies.
- Re: [PR] Revert "Updated the python dependencies (targeted for Beam 2.63.0)" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/06 12:45:20 UTC, 1 replies.
- Re: [PR] [docs] Add new Python multi-lang quickstart using the SchemaTransform framework [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/06 12:45:22 UTC, 2 replies.
- [I] [Task]: Make Prism default [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:42:29 UTC, 0 replies.
- [I] [Task]: Default option changes for IO connectors (e.g., BigQuery IO), Runners (e.g., SA vs SE) [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:49:22 UTC, 1 replies.
- [I] [Task]: Enrich YAML supports for IOs, turnkey transforms [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:52:35 UTC, 0 replies.
- [I] [Task]: Enrich Managed IO by onboarding more IOs and making Iceberg feature complete [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:54:38 UTC, 0 replies.
- [I] [Task]: Enrich ML features such as RAG, Anomaly Detection [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:57:30 UTC, 1 replies.
- [I] [Task]: Consider reducing dependencies in core [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 14:59:36 UTC, 2 replies.
- [I] [Task]: Ensure the effective communications during the Beam 3.0.0 development process [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 15:02:28 UTC, 0 replies.
- [PR] added the Beam 3.0.0 highlights to the release template [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/06 15:26:23 UTC, 2 replies.
- [PR] [DO NOT MERGE] add more logs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/07 01:12:45 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] add more logs for artifact retrieving [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/07 02:34:31 UTC, 0 replies.
- [I] When will Flink 2.0 and above be supported? [beam] - posted by "loulouloulouren (via GitHub)" <gi...@apache.org> on 2025/04/07 03:35:57 UTC, 0 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/07 03:42:25 UTC, 2 replies.
- Re: [I] Add ability to Write to GCP PubSub with an orderingKey [beam] - posted by "aprochko (via GitHub)" <gi...@apache.org> on 2025/04/07 07:17:12 UTC, 1 replies.
- [PR] Fix PostCommit Python Dependency and PreCommit Python ML tests [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/07 10:59:08 UTC, 4 replies.
- Re: [PR] Request to use BASIC enum when calling tables.get() in BigQuery #34075 [beam] - posted by "tamannakakkar93 (via GitHub)" <gi...@apache.org> on 2025/04/07 11:27:49 UTC, 3 replies.
- Re: [PR] Bump github.com/docker/docker from 28.0.1+incompatible to 28.0.4+incompatible in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/07 12:14:54 UTC, 2 replies.
- Re: [PR] Update CHANGES.md to include streaming NPE issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/07 12:46:29 UTC, 1 replies.
- [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/04/07 14:53:14 UTC, 13 replies.
- [I] [Bug]: ProtoCoder does not return correctly encoded TypeDescriptor [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2025/04/07 14:59:52 UTC, 1 replies.
- [PR] [extensions-proto] Return correct TypeDescriptor for ProtoCoder (#34561) [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2025/04/07 15:01:55 UTC, 11 replies.
- [PR] Deprecate ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/07 16:29:35 UTC, 7 replies.
- [I] [Bug]: Prism raises error when running a Python SDK pipeline with Create transform [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/07 17:06:35 UTC, 2 replies.
- [PR] Add the ability to fix and automatically create yaml pipeline tests. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/07 18:13:33 UTC, 2 replies.
- [PR] Fix Prism on handling empty and identity transforms [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/07 18:16:24 UTC, 7 replies.
- [PR] Bump @octokit/request and @octokit/rest in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/07 18:28:40 UTC, 2 replies.
- [PR] Handle pickling top-level enums. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/07 20:36:34 UTC, 8 replies.
- [PR] Add documentation for Beam YAML testing. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/07 21:57:52 UTC, 5 replies.
- [PR] Update link in yaml-providers.md [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/04/07 22:20:32 UTC, 4 replies.
- [I] [Bug]: Writing to a BigQuery partition requires clustering info to succeed if destination table has clustered fields [beam] - posted by "pricealexandra (via GitHub)" <gi...@apache.org> on 2025/04/07 22:51:42 UTC, 0 replies.
- [PR] Avoid use of deprecated datetime.utcnow(). [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/07 23:05:43 UTC, 3 replies.
- [PR] [DO NOT MERGE] try parquet_version 1.51.1 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/08 00:53:41 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] try parquet_version 1.15.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 02:33:19 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.48.0 to 1.49.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 04:33:15 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 7.0.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 04:59:40 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.0.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 04:59:44 UTC, 1 replies.
- [PR] Add PyTorch DistilBERT Sentiment Analysis streaming pipeline for Benchmarks [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/08 11:25:52 UTC, 1 replies.
- Re: [PR] SnowflakeIO: filter on db and schema when searching for existing table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 12:15:00 UTC, 4 replies.
- Re: [PR] Preserve pane index through reshuffle. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 12:15:09 UTC, 16 replies.
- Re: [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 12:15:11 UTC, 2 replies.
- Re: [PR] Bump @octokit/request-error, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 12:15:23 UTC, 3 replies.
- Re: [PR] Switch to parquet_version 1.15.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 13:13:54 UTC, 1 replies.
- [PR] Migrate Vertex AI Model Handler to new base class [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/08 14:32:59 UTC, 4 replies.
- Re: [I] [Feature Request]: Enable to capture Kafka errors like JMSWriteResult [beam] - posted by "the0ninjas (via GitHub)" <gi...@apache.org> on 2025/04/08 14:53:35 UTC, 0 replies.
- [PR] Add correct typehints before flatten in cogbk. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/08 15:22:29 UTC, 1 replies.
- [PR] Bump BQMS version [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/08 16:20:44 UTC, 4 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 18:40:51 UTC, 2 replies.
- [PR] Python PTransform wrapper for AWS SQS [beam] - posted by "prodriguezdefino (via GitHub)" <gi...@apache.org> on 2025/04/08 18:54:53 UTC, 12 replies.
- [PR] Fix coder corruption in prism while handling flatten [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/08 20:31:08 UTC, 6 replies.
- [PR] More eagerly merge compatible environments. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/08 20:58:09 UTC, 4 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/08 21:35:38 UTC, 6 replies.
- [PR] Update run_rc_validation_go_wordcount.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/08 23:54:07 UTC, 5 replies.
- Re: [I] [Bug]: Bigquery python streaming insertAll SSLError leads to stuck streaming job [beam] - posted by "quentin-sommer (via GitHub)" <gi...@apache.org> on 2025/04/09 00:13:51 UTC, 9 replies.
- [PR] Bump golang.org/x/net from 0.38.0 to 0.39.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/09 04:47:25 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.0 to 2.11.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/09 04:47:38 UTC, 2 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.66.2 to 1.67.0 in /sdks [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/09 12:14:26 UTC, 2 replies.
- [I] [Bug]: Prism overwrites coders while handling flatten [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/09 13:25:29 UTC, 2 replies.
- [PR] Add beam summit/college banners [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/09 14:40:29 UTC, 4 replies.
- [PR] Remove runtime check in generated test proto stubs to fix internal te… [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/09 14:45:45 UTC, 2 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/09 15:38:30 UTC, 2 replies.
- Re: [I] [Bug]: Python TypeError when converting Avro `logicalType` `timestamp-millis` to Beam Schema [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2025/04/09 16:01:01 UTC, 0 replies.
- [PR] Remove ZetaSQL from nexmark and tpcds benchmark suites [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/09 17:33:06 UTC, 3 replies.
- [PR] Upgrade some go dependencies and remove excludes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/09 17:37:23 UTC, 2 replies.
- [PR] Copy sys.module.items() in case it changes during iteration. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/09 18:37:02 UTC, 4 replies.
- Re: [PR] test commit [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/09 18:56:45 UTC, 4 replies.
- [PR] Fix sql:jdbc tests and shell entry [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/09 19:05:39 UTC, 6 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/09 21:34:50 UTC, 2 replies.
- [I] [Bug]: External transforms cannot be instantiated with LOOPBACK mode. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/09 22:24:32 UTC, 0 replies.
- [PR] Properly propagate schemas of Beam YAML Partition transform. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/09 22:51:20 UTC, 4 replies.
- [PR] Add YamlTransform to the Java SDK. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/09 22:56:04 UTC, 7 replies.
- [I] The PreCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/10 00:49:40 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.13 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/10 04:13:21 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.78.2 to 1.79.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/10 04:14:05 UTC, 2 replies.
- Re: [I] [Task]: Add documentation for the Go Direct runner. [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/04/10 06:59:52 UTC, 2 replies.
- [PR] Add documentation for the Go Direct Runner to Direct Runner guide Fixes: #21904 [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/04/10 07:04:27 UTC, 1 replies.
- Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] - posted by "mpiraino (via GitHub)" <gi...@apache.org> on 2025/04/10 11:37:14 UTC, 0 replies.
- [I] [Bug]: SpannerIO does not use correct endpoint when specified host is null or blank [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2025/04/10 14:12:29 UTC, 3 replies.
- [PR] Ensure SpannerConfig uses correct default when host set to null [beam] - posted by "nielm (via GitHub)" <gi...@apache.org> on 2025/04/10 14:18:55 UTC, 8 replies.
- [PR] Fix a flatten flaky test when two flattens are used sequentially. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/10 14:30:23 UTC, 3 replies.
- [PR] Disable logical type cast of fastavro [beam] - posted by "DKER2 (via GitHub)" <gi...@apache.org> on 2025/04/10 14:49:23 UTC, 11 replies.
- [PR] [#20489] Add support for re.Pattern and re.Match type checking [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/10 17:44:50 UTC, 2 replies.
- [PR] Sql transform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/10 19:26:04 UTC, 3 replies.
- [PR] Fix coder parsing for any non-standard composite coder types [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/10 19:29:02 UTC, 5 replies.
- [PR] [IcebergIO] Apply delete/update filter when reading [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/10 19:38:53 UTC, 3 replies.
- Re: [I] Python type hints: support typing.Pattern [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/10 19:42:36 UTC, 0 replies.
- Re: [PR] Add PyTorch DistilBERT Sentiment Analysis streaming pipeline for ML Benchmarks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/10 20:35:05 UTC, 6 replies.
- Re: [I] [prism] Python Validates Runner (test_pack_combiners) - Unknown Coder not being processed (tuple) [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/04/11 00:10:09 UTC, 0 replies.
- [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] - posted by "bitnahian (via GitHub)" <gi...@apache.org> on 2025/04/11 00:15:40 UTC, 2 replies.
- [I] The Playground CI Nightly job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/11 03:42:04 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.78.0 to 1.79.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/11 05:03:23 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.14 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/11 05:07:38 UTC, 4 replies.
- Re: [I] [RRIO]: Create and update website examples using RequestResponseIO using the Python SDK [beam] - posted by "MichaelGruschke (via GitHub)" <gi...@apache.org> on 2025/04/11 10:01:50 UTC, 0 replies.
- [I] [Task]: Improve Yaml Integration test coverage for top 5 transformers missing [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/11 14:25:23 UTC, 1 replies.
- [PR] Enable prism by default (where supported) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/11 19:52:14 UTC, 0 replies.
- [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/11 20:35:02 UTC, 5 replies.
- [PR] added ddl to SqlTransform [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/11 20:36:25 UTC, 5 replies.
- Re: [PR] [KafkaIO] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] - posted by "yyfhust (via GitHub)" <gi...@apache.org> on 2025/04/12 01:47:04 UTC, 7 replies.
- [PR] Use component coder when decoding with nullable coder in prism. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/12 02:42:57 UTC, 0 replies.
- Re: [PR] Use component coder when handling nullable coder in prism. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/12 03:17:38 UTC, 1 replies.
- [PR] Use cached prism binary without re-unzipping by default. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/12 05:00:53 UTC, 3 replies.
- [PR] use the script when validating the BQ table [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/12 14:17:46 UTC, 2 replies.
- [PR] Minor fixes to yaml testing docs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/12 14:57:39 UTC, 3 replies.
- [PR] Fix: Deduplicate mutations in flushBatch to prevent Datastore commit … [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/04/12 17:01:51 UTC, 4 replies.
- Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/13 08:20:33 UTC, 2 replies.
- Re: [I] [Task]: Create RC validation workflows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/13 12:27:11 UTC, 0 replies.
- [PR] Update run_rc_validation_python_mobile_gaming.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/13 13:42:34 UTC, 2 replies.
- [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] - posted by "NopAngel (via GitHub)" <gi...@apache.org> on 2025/04/13 13:53:04 UTC, 4 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/13 22:13:40 UTC, 0 replies.
- [PR] Make prism server a singleton [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/14 02:15:41 UTC, 0 replies.
- [PR] Fix GCP auth step for GitHub Actions workflows [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/14 10:58:17 UTC, 5 replies.
- Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/14 12:40:17 UTC, 5 replies.
- Re: [PR] Upgrade to hive 4.0.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/14 12:46:26 UTC, 2 replies.
- [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] - posted by "dasphillipbrau (via GitHub)" <gi...@apache.org> on 2025/04/14 13:04:50 UTC, 7 replies.
- [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/14 13:33:33 UTC, 13 replies.
- [PR] Activate service account for Publish Beam SDK Snapshots workflow [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/14 14:42:25 UTC, 3 replies.
- [PR] Fix The PostCommit XVR Flink job [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/14 14:49:09 UTC, 4 replies.
- [I] [Bug]: KafkaIO unbounded read requires kafka connection on pipeline submission time [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/14 15:01:03 UTC, 2 replies.
- [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/14 15:34:20 UTC, 4 replies.
- [PR] Bump golang.org/x/crypto from 0.21.0 to 0.35.0 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/14 18:09:50 UTC, 3 replies.
- [PR] Bump golang.org/x/crypto from 0.31.0 to 0.35.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/14 19:04:04 UTC, 2 replies.
- Re: [I] [yaml] Normalize TFRecordIO [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/14 19:29:41 UTC, 0 replies.
- [I] [Feature Request]: Support returning back BoundedTrie in metric result [beam] - posted by "evelyn97 (via GitHub)" <gi...@apache.org> on 2025/04/14 21:05:37 UTC, 2 replies.
- Re: [PR] Add an experiment to make prism server a singleton [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/14 21:06:42 UTC, 7 replies.
- Re: [I] [prism] Java FlattenTest.testFlattenMultipleCoders - worker crash [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/15 02:44:12 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.64 to 1.17.67 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/15 04:46:38 UTC, 2 replies.
- Re: [I] [Bug][Prism]: Prism gets stuck when trying to flatten 2 unbounded pcollections [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/15 12:18:24 UTC, 7 replies.
- [PR] Add changes note about TFRecord support in beam yaml and rename integration test. [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/15 13:42:07 UTC, 2 replies.
- [PR] add contributing dev doc for yaml integration tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/15 13:53:31 UTC, 2 replies.
- [I] [Task]: Deduplicate Coders [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/15 15:36:37 UTC, 0 replies.
- [PR] Fix new flaky postcommit python tests [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/15 15:48:14 UTC, 5 replies.
- Re: [PR] create helper function [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/15 16:07:53 UTC, 2 replies.
- Re: [PR] Adding Google Storage Requester pays feature to Golang SDK. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/15 16:09:27 UTC, 2 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/15 16:10:53 UTC, 0 replies.
- Re: [PR] Making setServiceFactory public in SpannerConfig for Failure injection testing in Dataflow templates [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/15 16:12:02 UTC, 2 replies.
- Re: [PR] Add new resource hints: max active bundles per worker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/15 16:40:21 UTC, 5 replies.
- [PR] Update CHANGES.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/15 17:58:00 UTC, 5 replies.
- Re: [PR] Fallback Implementation [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/15 18:09:53 UTC, 3 replies.
- [PR] Update contributor doc reflecting #33954 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/15 21:44:03 UTC, 5 replies.
- [PR] Inject SDK-side flattens while handling coder mismatch in flattens. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/16 03:26:16 UTC, 1 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.35.0 to 0.36.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/16 04:07:45 UTC, 2 replies.
- Re: [PR] [IcebergIO] load tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/16 12:46:30 UTC, 2 replies.
- [I] [Bug]: Prism crashed when a pipeline when flatten and groupby connect to the same upstream transform [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/16 14:48:44 UTC, 1 replies.
- [I] [Feature Request]: Fully Support Type Checking Callables [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/16 15:33:41 UTC, 0 replies.
- [PR] Restore previous handling of Callables, fix bare collections types [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/16 15:49:19 UTC, 2 replies.
- [I] [Bug]: Beam YAML provider docs show unsupported provider configuration [beam] - posted by "ryanmadden-google (via GitHub)" <gi...@apache.org> on 2025/04/16 16:42:38 UTC, 7 replies.
- Re: [PR] Inject SDK-side flattens while handling input/output coder mismatch in flattens. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/16 17:56:19 UTC, 6 replies.
- [I] [Bug]: Flink Runner could not handle groupby and flatten sharing the same input [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/16 18:53:22 UTC, 0 replies.
- [I] [Task]: Add Validates Runner Yaml Suite (or add to existing suites) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/04/16 19:13:49 UTC, 1 replies.
- [PR] ignore [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/16 19:27:11 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.36.0 to 0.38.0 in /learning/katas/go [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/16 19:37:36 UTC, 2 replies.
- Re: [I] [Bug]: Prism crashed if Flatten and GroupByKey share the same input [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/04/16 21:22:41 UTC, 0 replies.
- [PR] Bump golang.org/x/net from 0.33.0 to 0.38.0 [beam-starter-go] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/16 22:58:40 UTC, 2 replies.
- [PR] Make validation for BQ export source configurable [beam] - posted by "elzino (via GitHub)" <gi...@apache.org> on 2025/04/16 23:01:58 UTC, 5 replies.
- [PR] init commit [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/04/17 00:22:01 UTC, 1 replies.
- [PR] use WindmillChannelFactory to control what types of channels to generate [beam] - posted by "m-trieu (via GitHub)" <gi...@apache.org> on 2025/04/17 00:42:32 UTC, 3 replies.
- [PR] Add top transformers for yaml integration testing [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/17 02:07:20 UTC, 7 replies.
- [PR] Skip rewriting internal pcollection coders [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/17 03:11:22 UTC, 0 replies.
- Re: [PR] Skip rewriting internal pcollection coders in a stage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/17 04:39:38 UTC, 2 replies.
- Re: [I] [Bug]: FileIO.matchAll() injects a Reshuffle step which in some case is not useful and might break desirable fusion with more CPU intensive steps [beam] - posted by "s3847243 (via GitHub)" <gi...@apache.org> on 2025/04/17 09:41:19 UTC, 2 replies.
- [PR] Get rid of unnecessary cogbk when running offline detector. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/17 10:08:13 UTC, 6 replies.
- Re: [I] The PostCommit Python job is flaky [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/17 11:57:41 UTC, 1 replies.
- [PR] Add reshuffle before triggering load jobs. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/17 14:24:33 UTC, 18 replies.
- Re: [I] [prism] org.apache.beam.sdk.transforms.ParDoSchemaTest - UserCoder not a row coder exceptions. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/17 15:39:48 UTC, 0 replies.
- [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster. [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/04/17 16:00:45 UTC, 1 replies.
- Re: [I] [Failing Test]: AttributeError for MaybeReshuffle in Python SDK [beam] - posted by "smblsm (via GitHub)" <gi...@apache.org> on 2025/04/17 16:57:17 UTC, 3 replies.
- [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster. [beam] - posted by "fozzie15 (via GitHub)" <gi...@apache.org> on 2025/04/17 18:21:00 UTC, 8 replies.
- [I] [Task]: Add Prism to runner capability matrix [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/17 18:39:25 UTC, 1 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/17 22:13:45 UTC, 1 replies.
- [PR] Add adapters to address output conversion for OfflineDetector. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/18 00:47:21 UTC, 6 replies.
- [I] The PostCommit Python ValidatesRunner Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/18 03:42:13 UTC, 3 replies.
- [I] The PostCommit Python ValidatesRunner Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/18 03:42:17 UTC, 3 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/18 03:57:00 UTC, 6 replies.
- [PR] Ignore test_flatten_and_gbk for spark and samza runners. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/18 11:57:09 UTC, 3 replies.
- [PR] Remove unnecessary checkNotNull [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/18 12:47:13 UTC, 3 replies.
- [PR] do not raise errors when venv cannot be created [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/18 13:25:09 UTC, 2 replies.
- [PR] Regenerate Python requirement [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/18 13:37:31 UTC, 4 replies.
- [PR] Back port virtualenv-clone to 2.64 Python SDK container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/18 15:31:29 UTC, 2 replies.
- [PR] Bump torch from 1.13.1 to 2.6.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/18 16:03:50 UTC, 3 replies.
- [PR] Kafka Unbounded Reader: always provide reader to checkpoint mark. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/04/18 16:39:22 UTC, 9 replies.
- Re: [I] [Bug]: Support error handling in PyTransform [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/04/18 17:40:19 UTC, 0 replies.
- [PR] Added run_rc_validation_python_yaml to validate the Beam YAML RC [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/18 19:41:47 UTC, 4 replies.
- [I] [Task]: Scope the work about improving Beam Python Typehints [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/18 19:48:01 UTC, 1 replies.
- [I] [Task]: Improve the schema support for Beam 3.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/18 19:49:37 UTC, 0 replies.
- Re: [PR] Provide kafka unbounded reader to checkpoint mark when offset based deduplication is supported. [beam] - posted by "tomstepp (via GitHub)" <gi...@apache.org> on 2025/04/18 21:24:32 UTC, 1 replies.
- [I] Google cloud Console[Bug]: report [beam] - posted by "Balmasexy (via GitHub)" <gi...@apache.org> on 2025/04/18 21:36:15 UTC, 2 replies.
- [I] [Bug]: [beam] - posted by "Balmasexy (via GitHub)" <gi...@apache.org> on 2025/04/18 21:49:54 UTC, 3 replies.
- [PR] Update run_rc_validation_python_yaml.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/18 21:54:21 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/18 22:16:51 UTC, 1 replies.
- [PR] Add withReshuffle(boolean) option to FileIO.matchAll() [beam] - posted by "s3847243 (via GitHub)" <gi...@apache.org> on 2025/04/20 04:52:01 UTC, 1 replies.
- [PR] Fix loopback [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 13:39:49 UTC, 4 replies.
- [PR] Fix: Remove duplicate mutations in flushBatch to prevent Datastore commit [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/04/20 14:43:42 UTC, 5 replies.
- Re: [I] [Failing Test]: org.apache.beam.runners.dataflow.worker.streaming.harness.FanOutStreamingEngineWorkerHarnessTest.testOnNewWorkerMetadata_redistributesBudget [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/20 17:23:05 UTC, 1 replies.
- [I] [Bug]: Iceberg integration tests are flaky due to stuck pipelines in HiveCatalogIT and BigQueryMetastoreCatalogIT [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/20 17:38:16 UTC, 1 replies.
- [PR] Update release-guide.md [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 18:25:40 UTC, 2 replies.
- [PR] Updated the container doc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 18:59:16 UTC, 2 replies.
- [PR] Add some more cloudpickle tests. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/20 19:24:03 UTC, 4 replies.
- Re: [I] [Feature Request]: VertexAIImageEmbeddings adding the ability to send in contextual text too [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 19:27:47 UTC, 0 replies.
- [PR] fix the doc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 19:28:05 UTC, 2 replies.
- Re: [I] [Bug]: Python Unit Tests are flaky on windows [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 19:28:56 UTC, 0 replies.
- Re: [I] [Bug]: `beam.io.WriteToCsv` ignores `num_shards` argument. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 19:42:14 UTC, 0 replies.
- [PR] Update beam_PreCommit_Java.yml [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 20:58:48 UTC, 6 replies.
- [PR] Skip HiveCatalogIT and BigQueryMetastoreCatalogIT in Iceberg ITs [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/20 21:34:43 UTC, 2 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_multiple_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/20 22:13:49 UTC, 1 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/04/20 22:13:53 UTC, 1 replies.
- Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/20 23:09:20 UTC, 0 replies.
- [PR] [DO NOT MERGE] tried to add artifactApiService [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/21 02:06:18 UTC, 0 replies.
- Re: [PR] [DO NOT MERGE] Experimental Iceberg sharding runs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/21 12:46:17 UTC, 2 replies.
- [I] [Bug]: Improve the validation error when both chain and input are given for Beam YAML [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/21 13:57:51 UTC, 4 replies.
- Re: [I] It should be an error to run a Pipeline without ever specifying options [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/04/21 15:20:45 UTC, 1 replies.
- [PR] Update py container [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/21 15:27:21 UTC, 2 replies.
- [PR] Phase 1 - more yaml integration tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/21 15:44:27 UTC, 0 replies.
- [I] [Bug]: Registering DoFns and CombineFns Seems Excessively Slow [beam] - posted by "JonathanHopeDMRC (via GitHub)" <gi...@apache.org> on 2025/04/21 17:01:50 UTC, 2 replies.
- Re: [I] [Feature Request]: Implement JAR caching in the Beam YAML Provider [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/21 17:36:36 UTC, 0 replies.
- Re: [I] [Feature Request]: Support for BigTable from YAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/21 17:37:21 UTC, 0 replies.
- [I] [Bug]: Beam YAML documentation not reflecting full parameters. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/21 18:58:26 UTC, 7 replies.
- Re: [PR] Enable cloudpickle default [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/21 19:57:50 UTC, 0 replies.
- [PR] Enable cloudpickle by default [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/21 19:58:02 UTC, 6 replies.
- [PR] Update REVIEWERS.yml - remove lostluck from fallback [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/04/21 20:05:44 UTC, 2 replies.
- [PR] Update code-change-guide.md [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/04/21 20:09:47 UTC, 6 replies.
- [PR] Add option to pickler dumps() for best-effort determinism [beam] - posted by "AdrS (via GitHub)" <gi...@apache.org> on 2025/04/21 21:37:09 UTC, 10 replies.
- [PR] Support customizing how built-in types are pickled for cloudpickle [beam] - posted by "AdrS (via GitHub)" <gi...@apache.org> on 2025/04/21 22:35:30 UTC, 5 replies.
- [PR] complete implementation of open ai text embedding with test #new [beam] - posted by "aditya0yadav (via GitHub)" <gi...@apache.org> on 2025/04/21 23:00:52 UTC, 19 replies.
- [PR] Fix input validation for non-chain YAML-provider transforms. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/21 23:31:11 UTC, 5 replies.
- [PR] Improve the validation error for YAML chain transforms [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/04/21 23:37:11 UTC, 3 replies.
- [I] [Feature Request]: Improve failure message when passing Pipeline object / PBegin objects [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/22 00:29:53 UTC, 3 replies.
- [PR] fixed jdbc io [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/22 01:00:48 UTC, 2 replies.
- Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] - posted by "sarthakbhutani (via GitHub)" <gi...@apache.org> on 2025/04/22 10:09:13 UTC, 9 replies.
- [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/04/22 11:11:58 UTC, 1 replies.
- [PR] Fix handling of collections.Counter types [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/22 14:50:44 UTC, 8 replies.
- Re: [PR] Add core and missing transformers for yaml integration testing - phase 2sh [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/22 14:57:13 UTC, 4 replies.
- [PR] [BigQueryIO] support MicrosInstant type (for xlang) [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/22 15:01:52 UTC, 1 replies.
- [PR] Improve validation error message for chain transform [beam] - posted by "shubham-j-sde (via GitHub)" <gi...@apache.org> on 2025/04/22 17:36:32 UTC, 24 replies.
- [PR] Add support and unit test for PyOD models [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/22 17:50:19 UTC, 17 replies.
- [PR] Add schema definition for yaml test specs. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/22 19:43:16 UTC, 3 replies.
- Re: [I] [Bug]: Docker worker containers are confusingly named. [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/22 20:19:31 UTC, 5 replies.
- [PR] [KafkaIO] Fix concurrent consumer bug in KafkaIOIT [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/04/22 20:23:28 UTC, 2 replies.
- Re: [PR] Phase 1sh - more yaml integration tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/22 20:50:31 UTC, 5 replies.
- [PR] Update AlloyDB colab to use language connector. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/22 22:37:26 UTC, 1 replies.
- [PR] Use language connector in alloydb colab. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/22 22:46:30 UTC, 3 replies.
- [I] [Feature Request]: Generate Beam YAML managed I/O config parameters from the schema [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/23 00:47:49 UTC, 1 replies.
- [PR] Allow setting prism location to a path of GCS (or other filesystem). [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/23 02:52:02 UTC, 0 replies.
- [PR] Improve failure message when passing Pipeline object / PBegin objects… [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/04/23 04:52:10 UTC, 4 replies.
- Re: [PR] Add a md5sum check before overwriting a cached prism file [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/23 05:07:27 UTC, 1 replies.
- Re: [PR] Fix Iceberg Integration tests [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/23 10:24:34 UTC, 9 replies.
- Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 7.0.2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/23 12:46:37 UTC, 0 replies.
- Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.0.2 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/23 12:46:39 UTC, 0 replies.
- Re: [PR] Bump github.com/avast/retry-go/v4 from 4.6.0 to 4.6.1 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/23 15:27:57 UTC, 1 replies.
- [I] [Task]: Remove plumbing of cache to state backed iterable. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/23 18:43:35 UTC, 0 replies.
- [PR] Remove caching for remainders of state backed iterables. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/23 18:58:40 UTC, 4 replies.
- [PR] Update RunInference type hints to PEP 585 standards [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/23 19:29:13 UTC, 5 replies.
- [PR] [ManagedIO] Single source of truth for ManagedIO configs [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/24 00:09:18 UTC, 6 replies.
- [PR] Attempt prism for pipelines with unbounded PCollections. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/24 00:40:12 UTC, 6 replies.
- [I] [Bug]: Pipeline Options are changed after pipeline execution [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/24 03:03:31 UTC, 0 replies.
- [PR] Deep copy PipelineOptions and keep the input intact. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/24 03:08:27 UTC, 5 replies.
- [I] The pr-bot-new-prs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 03:43:48 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Flink Java8 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 03:43:49 UTC, 2 replies.
- [PR] Revert "Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot" [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/04/24 04:43:14 UTC, 3 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.41.0 to 1.41.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 05:00:07 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.67 to 1.17.73 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 05:00:49 UTC, 3 replies.
- [PR] Bump github.com/golang-cz/devslog from 0.0.11 to 0.0.12 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 05:00:55 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.71.1 to 1.72.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 05:01:00 UTC, 3 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.36.0 to 1.37.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 05:01:12 UTC, 3 replies.
- [I] The pr-bot-pr-updates job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 09:37:33 UTC, 3 replies.
- [I] [Bug]: [Python SDK] Beam.FlatMap doesn't correctly parse TypeVar typehints [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/24 12:58:43 UTC, 1 replies.
- Re: [I] [Bug]: The python Flatten example shows an empty line 31 and nothing else [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/24 13:03:35 UTC, 0 replies.
- Re: [PR] [WIP] Upgrade version of io.debezium [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/24 13:51:10 UTC, 0 replies.
- Re: [PR] Update gcp bom to 26.50.0 [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/24 13:57:43 UTC, 0 replies.
- [PR] [WIP] Upgrade io.debezium using #33526 as a blueprint [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/24 15:20:06 UTC, 1 replies.
- [PR] [WIP] Flink watermark emission [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2025/04/24 15:48:03 UTC, 3 replies.
- Re: [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/24 17:03:42 UTC, 3 replies.
- [PR] Bump github.com/go-jose/go-jose/v4 from 4.0.4 to 4.0.5 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 18:05:19 UTC, 2 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/24 18:09:43 UTC, 1 replies.
- Re: [PR] Fix IndexOutOfBoundsException invoking expansion service [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/24 18:28:29 UTC, 1 replies.
- Re: [I] [Feature Request]: Include job name in GCS custom audit info [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/24 18:56:58 UTC, 0 replies.
- [I] [Failing Test]: TestGCSIORetry.test_retry_on_throttling failed due to unknown reasons [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/24 19:08:00 UTC, 0 replies.
- [PR] Skip this failed test until further investigation is done. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/24 19:13:44 UTC, 2 replies.
- [PR] [Do not merge] Parse struct returned from Dataflow API to BoundedTrieData [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/24 21:18:44 UTC, 0 replies.
- [I] The PreCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/24 21:36:00 UTC, 2 replies.
- [PR] Only declare state backed iterables on code channel. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/24 23:57:07 UTC, 4 replies.
- [PR] Remove myself from java reviewers and focus on python and go. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/25 01:22:10 UTC, 2 replies.
- Re: [I] [Bug]: class org.apache.logging.slf4j.SLF4JLoggerContext cannot be cast to class org.apache.logging.log4j.core.LoggerContext (org.apache.logging.slf4j.SLF4JLoggerContext and org.apache.logging.log4j.core.LoggerContext are in unnamed module of loader 'app') [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/25 01:46:39 UTC, 0 replies.
- Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/25 03:19:46 UTC, 0 replies.
- Re: [I] [Bug]: Dataflow option validation fails in VSCode Jupyter notebook [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/25 03:27:17 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.51.0 to 1.52.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/25 04:33:36 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.229.0 to 0.230.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/25 04:33:51 UTC, 3 replies.
- [PR] Bump github.com/docker/docker from 28.0.4+incompatible to 28.1.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/25 04:34:03 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.79.0 to 1.80.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/25 04:34:12 UTC, 2 replies.
- Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/04/25 13:44:49 UTC, 19 replies.
- Re: [I] [BUG] | Not able to Read compressed csv file without passing any size limit [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/25 13:55:59 UTC, 1 replies.
- Re: [I] [Bug]: Pipeline Options changed after pipeline execution [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/25 15:31:38 UTC, 0 replies.
- Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] - posted by "cyberbeam524 (via GitHub)" <gi...@apache.org> on 2025/04/25 18:12:10 UTC, 0 replies.
- [PR] Streamline non-cached state backed iterable. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/25 19:40:10 UTC, 3 replies.
- [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/25 22:48:37 UTC, 1 replies.
- [PR] Fix sigint handler for StopOnExitJobServer [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/26 02:14:53 UTC, 0 replies.
- Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/26 03:03:27 UTC, 7 replies.
- [I] [Bug]: AvroCoder uses a lot of memory because it keeps instantiating the same DatumReader and DatumWriter [beam] - posted by "wollowizard (via GitHub)" <gi...@apache.org> on 2025/04/26 07:38:14 UTC, 2 replies.
- Re: [PR] Add Triton Inference Server Support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/26 12:14:17 UTC, 1 replies.
- Re: [I] Add documentation in Portable Runner to submit job in Java SDK [beam] - posted by "gayatrikate04 (via GitHub)" <gi...@apache.org> on 2025/04/26 14:17:06 UTC, 0 replies.
- [PR] 34749 reflect datum factory cache [beam] - posted by "wollowizard (via GitHub)" <gi...@apache.org> on 2025/04/27 06:16:15 UTC, 2 replies.
- [PR] Use Java 17 for Debezium IO #34747 [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/27 09:09:36 UTC, 9 replies.
- Re: [PR] Implement a `Top` partitioner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/27 12:46:00 UTC, 0 replies.
- [I] The PreCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/27 15:35:30 UTC, 1 replies.
- [PR] Bigquery embedding colab [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/27 16:35:59 UTC, 1 replies.
- [PR] BigQuery embeddings colab [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/27 16:41:55 UTC, 5 replies.
- [PR] Add option to create metedata filter with function. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/27 20:42:50 UTC, 2 replies.
- [PR] Updates YAML SDK to replace Kafka read/write transforms with equivalent managed transforms [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/28 01:57:37 UTC, 12 replies.
- [I] [Feature Request]: Cap number of keys in Reshuffle.viaRandomKey [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/28 02:31:38 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.1 to 2.11.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/28 04:44:46 UTC, 2 replies.
- [PR] Bump github.com/golang-cz/devslog from 0.0.11 to 0.0.13 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/28 04:44:57 UTC, 1 replies.
- [PR] Bump github.com/go-sql-driver/mysql from 1.9.1 to 1.9.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/28 04:45:44 UTC, 1 replies.
- Re: [PR] Update pypi documentation 30145 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/04/28 06:52:41 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/04/28 07:06:11 UTC, 0 replies.
- [I] [Bug]: Bigtable - You have reached the limit of total mutations in your queue [beam] - posted by "nguymin4 (via GitHub)" <gi...@apache.org> on 2025/04/28 08:02:04 UTC, 0 replies.
- [PR] Support configuring flush_count and max_row_bytes of WriteToBigTable [beam] - posted by "nguymin4 (via GitHub)" <gi...@apache.org> on 2025/04/28 09:47:47 UTC, 14 replies.
- [PR] Fix PreCommit YAML Xlang Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/04/28 11:01:45 UTC, 1 replies.
- [PR] Update Debezium in DebeziumIO to 3.1.1 [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/04/28 14:58:30 UTC, 1 replies.
- [PR] Drain Mode as WindowedValue extension [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/04/28 15:30:16 UTC, 6 replies.
- [PR] Fix The PostCommit Java ValidatesRunner Flink Java8 job [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/28 16:52:39 UTC, 2 replies.
- [I] [Bug]: Iceberg sink field number ordering may make tables incompatible with other tools/systems [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/28 16:56:31 UTC, 8 replies.
- [I] [Feature Request]: Automatically replace Beam YAML Kafka source/sink with managed I/O [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/28 17:03:13 UTC, 7 replies.
- [I] [Bug]: Prism isn't correctly used as the default for streaming pipelines. [beam] - posted by "robertwb (via GitHub)" <gi...@apache.org> on 2025/04/28 18:15:39 UTC, 0 replies.
- Re: [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/28 19:57:44 UTC, 5 replies.
- [PR] Make dill optional and fix coders. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/04/28 20:53:34 UTC, 2 replies.
- [I] [Bug]: YAML examples don't render emojis [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/28 22:06:34 UTC, 2 replies.
- [I] [Feature Request]: Support caching ReadFromBigQuery between runs [beam] - posted by "mattalbr (via GitHub)" <gi...@apache.org> on 2025/04/28 22:33:11 UTC, 0 replies.
- [I] [Feature Request]: Generalize generate_yaml_docs [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/28 22:39:39 UTC, 1 replies.
- [PR] [IcebergIO] Fetch source schema directly from the table [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/28 22:40:57 UTC, 8 replies.
- [PR] pin pip==25.0.1 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/29 00:20:00 UTC, 4 replies.
- [PR] Skip deep copying runner instance in pipeline options. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/29 01:16:59 UTC, 14 replies.
- [PR] unbounded PCollections writes to files support in iobase derived IOs: AvroIO, ParquetIO , TextIO, TFRecordIO [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/04/29 13:11:37 UTC, 17 replies.
- [PR] Fixing Typo on Blog Post [beam] - posted by "talatuyarer (via GitHub)" <gi...@apache.org> on 2025/04/29 14:08:13 UTC, 2 replies.
- [PR] Modernize Anomaly Detection type hints [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/04/29 14:23:15 UTC, 2 replies.
- [PR] Improve the apache beam type system to handle TypedDict. [beam] - posted by "LukeGT (via GitHub)" <gi...@apache.org> on 2025/04/29 15:33:57 UTC, 2 replies.
- Re: [PR] Parse struct returned from Dataflow API to BoundedTrieData [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/04/29 18:09:18 UTC, 0 replies.
- [PR] Raise an exception/warning when using BatchElements on a streaming case. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/29 18:20:00 UTC, 0 replies.
- [PR] Yaml IT - Phase 3a [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/04/29 20:10:52 UTC, 2 replies.
- [I] [Task]: Document `extra_transforms` block for `chain` type pipelines [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/04/29 20:43:59 UTC, 0 replies.
- Re: [PR] [WIP] Raise an exception/warning when using BatchElements on a streaming case. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/04/30 02:33:13 UTC, 0 replies.
- [PR] Bump google.golang.org/api from 0.229.0 to 0.231.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/30 04:29:51 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.73 to 1.17.74 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/04/30 04:30:59 UTC, 1 replies.
- [PR] Fix test retry on throttling [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/04/30 13:37:02 UTC, 6 replies.
- [PR] [Dataflow Streaming] BoundedQueueExecutor: Add an experiment to use fair monitor [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/04/30 14:21:16 UTC, 5 replies.
- Re: [I] Support streaming side-inputs in the Spark runner. [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/30 15:01:00 UTC, 0 replies.
- Re: [PR] [WIP] Update Debezium in DebeziumIO to 3.1.1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/30 15:19:40 UTC, 1 replies.
- [PR] [Do not merge] Test Fork Option compile [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/30 15:44:07 UTC, 1 replies.
- [I] [IcebergIO][Feature Request]: Add support for query filters and projection [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/04/30 19:06:01 UTC, 0 replies.
- [PR] Adjusting the YAML Kafka Managed I/O compat version [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/04/30 19:17:04 UTC, 1 replies.
- [I] [Bug]: apache_beam.io.gcp.bigquery.ReadFromBigQuery with EXPORT is slow when handling large amount of data [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/04/30 21:08:01 UTC, 0 replies.
- [PR] Update CHANGES.md after 2.64 release cut [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/04/30 21:17:23 UTC, 2 replies.