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

---

- [I] [Feature Request]: Slowness in WriteToJson step in streaming jobs [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2025/06/01 11:20:10 UTC, 1 replies.
- Re: [PR] Pass max_writers_per_bundle=0 in textio.writeToJson [beam] - posted by "sharan-malyala (via GitHub)" <gi...@apache.org> on 2025/06/01 11:26:42 UTC, 5 replies.
- Re: [PR] unbounded PCollections writes to files support in iobase derived IOs: AvroIO, ParquetIO , TextIO, TFRecordIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 12:14:26 UTC, 1 replies.
- Re: [PR] Do not overwrite class states if a cached dynamic class is returned in cloudpickle.load [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/06/01 12:28:07 UTC, 9 replies.
- Re: [PR] Refactor per worker counter metrics [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 12:46:17 UTC, 1 replies.
- Re: [I] [Failing Test]: Integrating SQL file with YAML for transformation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 12:46:29 UTC, 0 replies.
- Re: [I] [Bug]: Python type statement unsupported [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 12:46:30 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a flag to disable emission of lineage from IOs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/01 12:46:31 UTC, 0 replies.
- Re: [PR] update test your pipeline with TestPipeline and Rule [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 00:57:53 UTC, 1 replies.
- Re: [PR] Fix for issue 34772 to include user provided providers [beam] - posted by "Bhargavkonidena (via GitHub)" <gi...@apache.org> on 2025/06/02 02:34:58 UTC, 1 replies.
- Re: [I] [Failing Test]: Precommit Yaml Xlang Direct [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/02 02:39:35 UTC, 2 replies.
- Re: [PR] Deprecate Java 8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/02 02:42:00 UTC, 1 replies.
- Re: [PR] Add timer tests to make sure event-time timer firing at the right time. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/06/02 05:06:50 UTC, 8 replies.
- [PR] Bump github.com/docker/docker from 28.0.4+incompatible to 28.2.2+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 05:32:30 UTC, 2 replies.
- Re: [PR] Bump github.com/docker/docker from 28.0.4+incompatible to 28.2.1+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 05:32:32 UTC, 1 replies.
- [PR] Bump google.golang.org/grpc from 1.72.0 to 1.72.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 05:33:53 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.52.0 to 1.55.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 05:39:40 UTC, 2 replies.
- Re: [PR] Bump cloud.google.com/go/storage from 1.52.0 to 1.54.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 05:39:42 UTC, 1 replies.
- [PR] prepare IObase for streaming compatibility [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/06/02 07:23:27 UTC, 3 replies.
- Re: [PR] fix user metrics in @OnTimer [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/02 10:55:47 UTC, 5 replies.
- [PR] Fix PostCommit Python ValidatesContainer Dataflow With RC job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/02 11:02:46 UTC, 2 replies.
- Re: [PR] Update Python container tag [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/02 11:44:45 UTC, 0 replies.
- Re: [PR] Add filter to GetMinUnfinishedWatermark queryAdd filter tester [beam] - posted by "dedocibula (via GitHub)" <gi...@apache.org> on 2025/06/02 12:08:54 UTC, 18 replies.
- [I] Move precommit test to post commit [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/02 12:15:15 UTC, 0 replies.
- Re: [PR] Update google-bigquery.md to direct to Storage Write API as the inges… [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:15:46 UTC, 4 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/06/02 12:15:50 UTC, 4 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/06/02 12:15:55 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/06/02 12:15:59 UTC, 1 replies.
- Re: [PR] Switch to use registerFileSystemsOnce for SerializablePipelineOptions constructor [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:16:00 UTC, 2 replies.
- Re: [PR] [Website] add akvelon case study [beam] - posted by "bullet03 (via GitHub)" <gi...@apache.org> on 2025/06/02 12:44:32 UTC, 5 replies.
- Re: [PR] sdks/python: integrate OpenAI embedded generator [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:46:44 UTC, 1 replies.
- Re: [PR] Label managed transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:46:46 UTC, 2 replies.
- Re: [PR] Passing in key metadata when Reading From Kafka [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:46:48 UTC, 2 replies.
- Re: [I] [Bug]: Reading Kinesis' stream shards fails when the number of shards is greater than 1000 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:46:55 UTC, 0 replies.
- Re: [I] [Bug]: Gauge metrics are not extracted in metrics result. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 12:46:56 UTC, 0 replies.
- Re: [I] Globbing asterisk cannot be escaped in file reads. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/02 12:48:00 UTC, 0 replies.
- Re: [PR] Add checkpoint during progress reporting. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/02 12:49:02 UTC, 4 replies.
- [PR] Update dataflow containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 13:16:54 UTC, 2 replies.
- Re: [PR] Add warning if temp location bucket has soft delete enabled for Go SD… [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/02 13:21:09 UTC, 6 replies.
- Re: [PR] Improve failure message when passing Pipeline object / PBegin objects… [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 13:28:40 UTC, 0 replies.
- Re: [PR] Adding project and database support in write transform for firestoreIO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/02 13:48:20 UTC, 12 replies.
- Re: [I] "/test-your-pipeline" example code results in an exception [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 13:51:59 UTC, 0 replies.
- Re: [I] The PostCommit Python ValidatesContainer Dataflow With RC job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/02 14:29:49 UTC, 0 replies.
- [PR] move precommit yaml xlang to postcommit [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/02 14:42:31 UTC, 2 replies.
- [PR] Add dataflow option [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/02 15:41:18 UTC, 44 replies.
- [PR] test [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/02 15:55:40 UTC, 3 replies.
- Re: [PR] Force show dataflow job URL! [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/02 16:06:22 UTC, 3 replies.
- Re: [I] [Bug]: RuntimeError: No dataflow job was found when running the python file. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/02 16:07:51 UTC, 5 replies.
- Re: [PR] Fallback Implementation [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/02 16:41:17 UTC, 8 replies.
- Re: [PR] Enable prism by default (where supported) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 19:11:30 UTC, 3 replies.
- Re: [I] The PostCommit Java Jpms Dataflow Java17 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/02 19:16:53 UTC, 1 replies.
- Re: [I] The PostCommit Java Jpms Dataflow Java11 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/02 19:17:00 UTC, 1 replies.
- [I] [Bug]: YAML JDBC sources broken in Beam 2.65 [beam] - posted by "ryanmadden-google (via GitHub)" <gi...@apache.org> on 2025/06/02 19:58:02 UTC, 3 replies.
- Re: [PR] added the rate test for GenerateSequence [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/02 20:00:30 UTC, 0 replies.
- Re: [I] [Bug]: GenerateSequence Python SDK constructor does not support period parameter [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/02 20:00:31 UTC, 0 replies.
- [PR] Remove beam college banners [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 20:00:51 UTC, 1 replies.
- Re: [PR] Re-enable logging after importing vllm. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/02 20:03:02 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/06/02 20:12:12 UTC, 0 replies.
- [PR] [Java] Explicitly handle singleton iterators instead of using helper and catching exceptions which may be from fetching the iterable. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/02 20:14:08 UTC, 6 replies.
- Re: [PR] [IcebergIO] load tests [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/02 20:16:55 UTC, 2 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/02 21:37:28 UTC, 11 replies.
- [PR] Remove Java 8 container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/02 22:17:21 UTC, 2 replies.
- [I] [Bug]: NPE on Java SDK harness startup on Dataflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/02 22:25:31 UTC, 11 replies.
- Re: [PR] upgrade org.apache.parquet:parquet-avro to to 1.15.2 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/03 01:08:25 UTC, 6 replies.
- [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] - posted by "jonathaningram (via GitHub)" <gi...@apache.org> on 2025/06/03 02:33:05 UTC, 7 replies.
- Re: [I] [Bug]: colab does not work with `pip install apache-beam[interactive]` [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/03 04:29:34 UTC, 1 replies.
- [I] [GSOC 25] Enhanced Interactive Pipeline Development Environment for JupyterLab [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/03 05:06:13 UTC, 0 replies.
- [I] [Bug]: Python Interactive Beam show() does not work [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/03 05:21:17 UTC, 1 replies.
- Re: [I] [Feature Request]: Make `Neo4jIO.WriteUnwind` output write statistics. [beam] - posted by "fbiville (via GitHub)" <gi...@apache.org> on 2025/06/03 09:39:40 UTC, 0 replies.
- [PR] [Website] u[date akvelon case study: update text [beam] - posted by "bullet03 (via GitHub)" <gi...@apache.org> on 2025/06/03 11:15:31 UTC, 0 replies.
- Re: [PR] [Website] update akvelon case study: update text [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 12:11:52 UTC, 2 replies.
- Re: [PR] [learning-content] Fix typos in leaning materials [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 12:15:46 UTC, 4 replies.
- Re: [PR] Report total backlog in unbounded source sdf wrapper [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 12:46:50 UTC, 1 replies.
- Re: [I] [Distroless] Publish Python distroless variants [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 12:47:03 UTC, 0 replies.
- [PR] Fix PostCommit Python Xlang IO Dataflow job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/03 13:24:54 UTC, 3 replies.
- Re: [I] [YAML][Feature Request]: Integration and Usage of GCP Secret Manager with the different Apache Beam IOs [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/03 13:36:35 UTC, 0 replies.
- Re: [PR] [WIP] Update Debezium in DebeziumIO to 3.1.1 [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/06/03 13:51:33 UTC, 1 replies.
- Re: [PR] Update Custom Remote Inference example to use RemoteModelHandler [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/06/03 14:00:21 UTC, 1 replies.
- [PR] [YAML] Add a specifiable transform provider for transforms taking specifiable arguments [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/03 14:11:15 UTC, 0 replies.
- [PR] [Website] update akvelon case study: update text and fix landing page [beam] - posted by "bullet03 (via GitHub)" <gi...@apache.org> on 2025/06/03 14:40:15 UTC, 3 replies.
- Re: [I] [Task]: Enable to set timeout for Python TestPipeline [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/03 14:55:45 UTC, 0 replies.
- [PR] Main [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2025/06/03 15:06:06 UTC, 1 replies.
- Re: [PR] Feedback requested: introduce OutputBuilder in Java SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/03 15:43:35 UTC, 1 replies.
- [PR] Fix data race ExecutionStateSampler.java:491 in ExecutionStateImpl.reset() [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/03 15:44:51 UTC, 10 replies.
- Re: [PR] add extra_transforms block documentation to chain transform documentation [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/03 15:54:05 UTC, 0 replies.
- Re: [I] [Task]: Document `extra_transforms` block for `chain` type pipelines [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/03 16:16:39 UTC, 0 replies.
- Re: [PR] add note about testing for yaml examples [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 16:43:01 UTC, 1 replies.
- Re: [PR] sdks/python: enrich data with CloudSQL [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/03 16:55:09 UTC, 21 replies.
- [PR] rename WindowedValue.getPane() to WindowedValue.getPaneInfo() in preparation for making it public [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/03 17:08:54 UTC, 6 replies.
- [PR] add streaming support to iobased [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/06/03 17:36:46 UTC, 2 replies.
- [PR] Add known issues. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/03 17:49:39 UTC, 3 replies.
- [PR] Move non-dill specific code out of dill_pickler.py [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2025/06/03 17:51:40 UTC, 14 replies.
- [PR] Introduce ValueWithMetadata and its receivers [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/03 17:51:41 UTC, 1 replies.
- [PR] fix jdbc transform validation [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/06/03 18:02:36 UTC, 6 replies.
- [PR] Build last snapshot against RC00 tag instead of release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/03 18:22:58 UTC, 3 replies.
- Re: [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/06/03 18:27:54 UTC, 0 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.67.0 to 1.69.0 in /sdks [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/06/03 18:29:15 UTC, 0 replies.
- [PR] Bump nodemailer from 6.7.5 to 6.9.9 in /scripts/ci/issue-report [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/03 19:17:35 UTC, 2 replies.
- [PR] Allow Dofn Input/Output Typing [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2025/06/03 19:37:15 UTC, 3 replies.
- [PR] Fix tests affected by Java 8 container turn down [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/03 20:21:16 UTC, 2 replies.
- Re: [I] [Feature Request]: Typescript async user functions [beam] - posted by "dermasmid (via GitHub)" <gi...@apache.org> on 2025/06/03 21:54:56 UTC, 0 replies.
- [I] The PostCommit Go VR Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 00:49:51 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.79.3 to 1.80.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 04:25:07 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.42.0 to 1.43.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 04:25:13 UTC, 2 replies.
- [PR] Fix the beam interactive install problem when on Google Colab [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/04 05:53:00 UTC, 3 replies.
- [PR] Fix Playground CI Nightly job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/04 07:42:25 UTC, 6 replies.
- Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/04 09:44:59 UTC, 1 replies.
- Re: [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/04 09:45:09 UTC, 1 replies.
- Re: [PR] Add filter to GetMinUnfinishedWatermark query [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:15:42 UTC, 1 replies.
- Re: [PR] Add Git commit SHA to artifacts using buildnumber-maven-plugin (#18227) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:15:53 UTC, 4 replies.
- Re: [PR] Drain Mode as WindowedValue extension [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:15:55 UTC, 4 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/06/04 12:15:58 UTC, 3 replies.
- Re: [PR] chore: test beam against protobuf 3.25 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:46:47 UTC, 1 replies.
- Re: [PR] Added 'How to Build the Sources' section to README.md and Contribute pages fixes #19820 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:46:49 UTC, 1 replies.
- Re: [PR] Support sharding in WriteToFiles (tested for to_csv) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:46:52 UTC, 3 replies.
- Re: [PR] Fix: Replace deprecated DataFrame.applymap with map for compatibility [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 12:46:54 UTC, 1 replies.
- Re: [PR] Support configuring flush_count and max_row_bytes of WriteToBigTable [beam] - posted by "andre-sampaio (via GitHub)" <gi...@apache.org> on 2025/06/04 14:02:49 UTC, 5 replies.
- [PR] [WIP] Update Beam Protobuf Schema (Java) [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/06/04 14:03:37 UTC, 0 replies.
- [PR] Add more YAML examples involving Kafka and Iceberg [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/04 14:05:22 UTC, 17 replies.
- [PR] Extending WindowedValue with ElementMetadata [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/06/04 14:15:02 UTC, 7 replies.
- Re: [PR] Constrain DequeCoder type correctly, as it does not support nulls [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/04 16:04:46 UTC, 1 replies.
- Re: [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/04 16:05:35 UTC, 5 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 18:42:52 UTC, 4 replies.
- [PR] Replace usages of deprecated pkg_resources package [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2025/06/04 19:15:47 UTC, 5 replies.
- [PR] Fix Java Example ARM PostCommit [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/04 20:06:09 UTC, 3 replies.
- Re: [PR] Add postcommit yaml xlang workflow and split tests accordingly [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/06/04 20:10:24 UTC, 7 replies.
- [PR] Test PR, need some help/advice on what to do [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2025/06/04 20:30:41 UTC, 1 replies.
- Re: [PR] small filesystem fixes [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/04 20:46:24 UTC, 3 replies.
- [PR] Pipeline errmsg [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/04 21:19:22 UTC, 0 replies.
- [PR] Cloudpickle setstate [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/04 21:56:44 UTC, 2 replies.
- [I] Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet101-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/06/04 22:14:45 UTC, 3 replies.
- Re: [PR] Improve error message when accidentally using PBegin/Pipeline [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/04 22:41:43 UTC, 4 replies.
- Re: [PR] Make WindowedValue a public interface, and receivers for it [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/05 00:59:03 UTC, 1 replies.
- [PR] Make WindowedValue a public interface [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/05 01:38:14 UTC, 6 replies.
- [PR] add friendly error message for when transform is applied to no output [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/05 02:43:49 UTC, 7 replies.
- [I] The Clean Up GCP Resources job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 03:47:56 UTC, 4 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.3 to 2.11.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 04:16:42 UTC, 2 replies.
- Re: [I] [yaml] Normalize SpannerIO [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/05 06:32:17 UTC, 1 replies.
- [I] The PostCommit Java Examples Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 06:43:53 UTC, 5 replies.
- [PR] Update workflows categories [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/05 09:09:54 UTC, 3 replies.
- Re: [I] [yaml] Normalize DebeziumIO [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/05 09:12:43 UTC, 1 replies.
- Re: [PR] Update Beam Protobuf Schema (Java) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 09:38:05 UTC, 15 replies.
- [PR] [Website] update akvelon case study text [beam] - posted by "bullet03 (via GitHub)" <gi...@apache.org> on 2025/06/05 11:03:19 UTC, 3 replies.
- Re: [PR] fix arbitrary file access during archive extraction ("Zip Slip") [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 12:15:53 UTC, 10 replies.
- Re: [PR] [IcebergIO] Create tables with a partition spec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 12:15:55 UTC, 6 replies.
- Re: [PR] Fix PreCommit YAML Xlang Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/05 12:26:55 UTC, 0 replies.
- Re: [PR] [Java]Add Support for Named Schemas in SpannerIO.Write by Enhancing Schema Retrieval [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 12:46:45 UTC, 1 replies.
- Re: [I] [Bug]: PostRelease Nightly workflow flaky for release candidate validation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 12:46:57 UTC, 0 replies.
- Re: [I] [Bug]: UnsupportedOperationException when spin up beam-examples-multi-language expansion service [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 12:46:59 UTC, 0 replies.
- [PR] Fix incorrect typehints generated by FlatMap with default identity function [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/05 13:28:11 UTC, 7 replies.
- [I] [Bug]: JMSIO.Write should better handle connection issues [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2025/06/05 13:33:23 UTC, 2 replies.
- Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/05 14:11:47 UTC, 0 replies.
- Re: [I] [Bug]: Spanner schemas with ARRAY fail to parse [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/05 14:16:30 UTC, 1 replies.
- Re: [I] [Task]: Support more Beam portable schema types as Python types [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/05 14:19:11 UTC, 2 replies.
- [PR] Add cloudpickle coder. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/05 14:45:37 UTC, 3 replies.
- Re: [PR] enable setting max_writer_per_bundle for avroIO and other IO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/05 15:18:07 UTC, 7 replies.
- [PR] Fix IntelliJ sync project failure due to circular Beam dependency [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/05 15:35:40 UTC, 6 replies.
- [I] [Bug]: FnApiRunner does not handle event timer correctly. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/05 15:39:17 UTC, 0 replies.
- [PR] Update postgres it test and readme [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 15:51:27 UTC, 0 replies.
- Re: [I] [Bug]: FnApiRunner does not handle event-time timer correctly. [beam] - posted by "lostluck (via GitHub)" <gi...@apache.org> on 2025/06/05 16:26:18 UTC, 0 replies.
- Re: [I] [Feature Request]: Improve failure message when passing Pipeline object / PBegin objects [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/05 16:43:29 UTC, 0 replies.
- [PR] Bump Java beam-master container [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/05 16:57:57 UTC, 6 replies.
- Re: [PR] Update postgres IT test and readme [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 17:33:52 UTC, 1 replies.
- [PR] add more doc strings for yaml integration tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 17:38:43 UTC, 0 replies.
- Re: [I] [Task]: Make "Postcommit Yaml Xlang Direct" workflow and then organize tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 17:49:07 UTC, 0 replies.
- Re: [I] [Feature Request]: Add warning if temp location bucket has soft delete enabled for Go SDK. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/05 17:57:56 UTC, 1 replies.
- [PR] Fix beam_PostCommit_Java_Examples_Dataflow_V2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/05 18:17:32 UTC, 4 replies.
- Re: [PR] [YAML]: Update postgres IT test and readme [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 18:31:08 UTC, 3 replies.
- [PR] Make SDK harness change effective on Iceberg Dataflow test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/05 18:44:30 UTC, 4 replies.
- Re: [PR] [YAML]: add more doc strings for yaml integration tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/05 19:08:25 UTC, 6 replies.
- [I] [Feature Request]: Beam Configurable SDK Restart Proposal [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/05 19:09:25 UTC, 1 replies.
- Re: [PR] Fix nullability in ByteBuddyDoFnInvokerFactory and DoFnOutputReceivers [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/05 19:30:56 UTC, 1 replies.
- Re: [I] [Bug]: cloudpickle overwrites class states every time loading a same object of dynamic class [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/05 19:48:48 UTC, 0 replies.
- Re: [PR] [WIP] Upgrade io.debezium using #33526 as a blueprint [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/06/05 20:04:25 UTC, 0 replies.
- Re: [PR] [IO] Update Debezium in DebeziumIO to 3.1.1 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/05 21:36:23 UTC, 22 replies.
- Re: [PR] Extend Schema Registry Support on Managed Kafka I/O to Google's Managed Schema Registry Solution [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/05 21:46:12 UTC, 4 replies.
- [PR] test: check for incompatibility for versions selected for LTS 9 [beam] - posted by "jinseopkim0 (via GitHub)" <gi...@apache.org> on 2025/06/05 21:55:17 UTC, 0 replies.
- [I] [Bug]: FlinkRunner not handling event-time timers correctly [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/05 22:43:30 UTC, 0 replies.
- [PR] Introduce WindowedValue receivers and consolidate runner code to them [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/06 02:09:50 UTC, 4 replies.
- Re: [I] [Bug]: Python event-time timers clearing behavior not consistent on different bundle sizes [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/06 04:06:37 UTC, 2 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.2.1 to 2.3 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 04:13:05 UTC, 1 replies.
- [I] [Feature Request]: Allow schema fields that might be null or missing [beam] - posted by "jonathaningram (via GitHub)" <gi...@apache.org> on 2025/06/06 06:26:55 UTC, 1 replies.
- Re: [PR] [KafkaIO] Report unknown backlog size when latest offset lags behind next offset [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 12:15:10 UTC, 3 replies.
- Re: [PR] Bump setuptools from 70.0.0 to 78.1.1 in /.test-infra/mock-apis [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 12:15:11 UTC, 2 replies.
- Re: [I] [prism] Using Real Time, when operating in "production" mode. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 12:46:53 UTC, 2 replies.
- Re: [I] [Feature Request]: Provide the Python equivalent to Java's BigQueryIO `writeProtos` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 12:46:54 UTC, 0 replies.
- Re: [I] SVN removed from GitHub ubuntu-latest causing build_release_candidate workflow failure [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 12:46:55 UTC, 0 replies.
- [PR] Use staged SDK harness & Dataflow worker jar in JPMS tests [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/06 12:56:42 UTC, 7 replies.
- [PR] [YAML]: change to ubuntu-20.04 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/06 13:48:09 UTC, 0 replies.
- Re: [PR] [YAML]: postcommit IT - change to ubuntu-20.04 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/06 13:52:56 UTC, 0 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/06 15:09:13 UTC, 5 replies.
- [PR] Fix null check when fetching driverJars from value provider [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/06 15:36:34 UTC, 4 replies.
- [I] [Bug]: Concurrent exception with ReadFromKafka YAML transform on PrismRunner [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/06 15:43:36 UTC, 3 replies.
- [I] [Bug]: ReadFromKafka YAML transform cannot specify schema [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/06 15:51:22 UTC, 1 replies.
- Re: [PR] [YAML] Add a spec provider for transforms taking specifiable arguments [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/06 16:25:37 UTC, 4 replies.
- [I] [Bug]: ReadFromIceberg YAML transform cannot run with --runner DataflowRunner flag [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/06 17:30:04 UTC, 1 replies.
- [I] [Bug]: WriteToIceberg YAML transform on PrismRunner not working [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/06 17:41:23 UTC, 1 replies.
- Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.74 to 1.17.77 in /sdks [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/06 17:42:43 UTC, 1 replies.
- [I] [Bug]: ReadFromKafka YAML transform and STRING format [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/06 17:49:20 UTC, 3 replies.
- Re: [I] [Feature Request]: Interactive Beam supports asynchronous computations. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/06 18:09:16 UTC, 0 replies.
- [PR] fix postcommit oracle test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/06 18:13:42 UTC, 0 replies.
- [I] [Feature Request]: Support for KafkaIO Dynamic Read in Python SDK [beam] - posted by "rajkgupt (via GitHub)" <gi...@apache.org> on 2025/06/06 18:54:02 UTC, 1 replies.
- [PR] Fix some lints introduced in a recent PR. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/06 19:31:33 UTC, 3 replies.
- Re: [PR] [YAML]: fix postcommit oracle test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/06 19:35:02 UTC, 0 replies.
- Re: [PR] add streaming support to iobase (python) [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/06 19:38:52 UTC, 17 replies.
- [I] The LoadTests Java PubsubIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 00:52:37 UTC, 1 replies.
- [PR] Update JupyterLab Sidepanel yarn.lock file [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/07 09:31:37 UTC, 6 replies.
- Re: [PR] Use now + 2mins as the end timestamp for change stream read API if the connector endTimestamp is omitted [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:14:20 UTC, 13 replies.
- Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:14:23 UTC, 3 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/06/07 12:14:24 UTC, 3 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/06/07 12:46:10 UTC, 2 replies.
- Re: [PR] [WIP] Open Telemetry Tracing for java sdk [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:46:11 UTC, 0 replies.
- Re: [PR] improve yaml schema validation error message [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:46:13 UTC, 1 replies.
- Re: [PR] Safeguard boundedtrie result [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:46:15 UTC, 1 replies.
- Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 12:46:16 UTC, 1 replies.
- [I] [Feature Request]: Support for Storage Read API Enrichment Handler [beam] - posted by "pandasanjay (via GitHub)" <gi...@apache.org> on 2025/06/07 15:01:16 UTC, 0 replies.
- [PR] Add BigQuery Storage Read API Enrichment Handler [beam] - posted by "pandasanjay (via GitHub)" <gi...@apache.org> on 2025/06/07 15:08:11 UTC, 18 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 15:36:09 UTC, 8 replies.
- [I] [Bug]: IcebergIO fails to convert an array of structs [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/06/07 16:03:49 UTC, 2 replies.
- [I] The PostCommit Python ValidatesRunner Samza job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/07 21:34:57 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/06/07 21:35:00 UTC, 6 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/06/07 22:13:05 UTC, 3 replies.
- Re: [PR] Update pypi documentation 30145 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/08 06:37:22 UTC, 5 replies.
- Re: [I] [Bug]: IcebergIO - Write performance issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/08 12:46:32 UTC, 0 replies.
- Re: [I] [Bug][Prism]: Unsupported feature Create/MaybeReshuffle (Python SDK) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/08 12:46:34 UTC, 0 replies.
- Re: [I] [Bug]: Processing time timers are fired after the window closed in Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/08 12:46:35 UTC, 0 replies.
- [I] [Task]: Add YAML examples using Cloud SQL [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/08 12:59:34 UTC, 2 replies.
- Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/08 14:08:53 UTC, 2 replies.
- [PR] Add a new experiment flag to enable real-time clock as processing time. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/09 04:16:36 UTC, 2 replies.
- [PR] Bump golang.org/x/text from 0.25.0 to 0.26.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 04:46:51 UTC, 3 replies.
- [PR] Bump golang.org/x/sync from 0.14.0 to 0.15.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 04:47:23 UTC, 3 replies.
- [PR] Bump github.com/linkedin/goavro/v2 from 2.13.1 to 2.14.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 04:47:55 UTC, 3 replies.
- [PR] Bump golang.org/x/net from 0.40.0 to 0.41.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 04:49:39 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.74 to 1.17.78 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 04:50:06 UTC, 3 replies.
- [PR] Bump com.google.cloud.tools:dependencies from 1.5.6 to 1.5.15 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 05:11:43 UTC, 3 replies.
- [PR] Update state doc 34905 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/09 06:00:37 UTC, 22 replies.
- Re: [I] [Bug]: The beam task consumes Kafka, and then the runner is Flinkrunner. After the job recovers from the checkpoint, it repeatedly consumes Kafka messages [beam] - posted by "doc-laowu (via GitHub)" <gi...@apache.org> on 2025/06/09 08:05:14 UTC, 0 replies.
- [PR] Fix PostCommit Python ValidatesRunner Samza / Spark jobs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/09 11:46:52 UTC, 7 replies.
- Re: [PR] Fix out of range [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 12:15:41 UTC, 3 replies.
- Re: [I] Timeout handling in JdbcIO with Oracle java driver [beam] - posted by "j1cs (via GitHub)" <gi...@apache.org> on 2025/06/09 12:45:22 UTC, 0 replies.
- Re: [PR] [WIP] Add correct typehints before flatten in cogbk. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 12:46:42 UTC, 2 replies.
- Re: [I] OrderedListState [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/09 13:32:18 UTC, 0 replies.
- [I] [Failing Test]: :sdks:python:test-suites:tox:py39:testPython39 can be flaky [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/09 14:45:41 UTC, 0 replies.
- [PR] wip [beam] - posted by "quentin-sommer (via GitHub)" <gi...@apache.org> on 2025/06/09 15:09:14 UTC, 0 replies.
- [PR] Remove WindowedValue.getPane() in preparation for making WindowedValue a user-facing interface [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/09 15:57:24 UTC, 2 replies.
- [PR] Allow STRING format in Kafka config [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/09 16:11:58 UTC, 6 replies.
- [PR] Cloudsql enrich [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/09 17:25:40 UTC, 0 replies.
- [PR] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/09 17:33:11 UTC, 30 replies.
- Re: [PR] Parse values returned from Dataflow API to BoundedTrieData [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 17:36:59 UTC, 5 replies.
- [PR] Fix nullness for schemas/logicaltypes [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/09 18:15:58 UTC, 6 replies.
- Re: [PR] Cloudsql postgres embeddings. [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/06/09 20:25:46 UTC, 0 replies.
- [PR] Evaluate namedTuples as equivalent to rows [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/09 20:25:52 UTC, 3 replies.
- [PR] Force FnApiRunner in cases where prism can't handle use case [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/09 20:50:26 UTC, 4 replies.
- [PR] Bump requests from 2.31.0 to 2.32.4 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/10 04:15:09 UTC, 4 replies.
- Re: [I] [Task]: Improve project documentation on apache-beam pypi page. [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/10 06:02:49 UTC, 2 replies.
- Re: [I] [Task]: Update Trivial Inference documentation [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/10 06:17:30 UTC, 0 replies.
- Re: [I] [Task]: Enrich ML features such as RAG, Anomaly Detection [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/10 06:22:56 UTC, 0 replies.
- [I] [Feature Request]: [IcebergIO] Create namespaces dynamically [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/10 11:42:15 UTC, 1 replies.
- Re: [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/06/10 11:55:13 UTC, 0 replies.
- [PR] Fix Clean Up GCP Resources job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/10 12:24:38 UTC, 2 replies.
- Re: [I] [Feature Request]: Add ClickHouse Resource Manager for Integration Tests [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/06/10 13:38:49 UTC, 0 replies.
- [PR] [Beam SQL] Implement Catalog and CatalogManager [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/10 13:55:57 UTC, 12 replies.
- [PR] Remove breaking PDone change [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/10 14:01:48 UTC, 7 replies.
- Re: [PR] Generic Postgres + Cloudsql postgres embeddings. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/10 14:22:09 UTC, 11 replies.
- Re: [I] [Task]: Deprecate ZetaSQL [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/10 14:42:16 UTC, 0 replies.
- [I] [API Update]: AlloyDBVectorWriterConfig Changes [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/10 16:26:05 UTC, 0 replies.
- Re: [I] [Feature Request]: Modernize content on supplying a pipeline as a package [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/10 16:28:24 UTC, 1 replies.
- Re: [I] [Bug]: Cannot write to Kafka with YAML SDK [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/10 16:31:50 UTC, 1 replies.
- [PR] Update code_object_pickler.py to include only open source code [beam] - posted by "kristynsmith (via GitHub)" <gi...@apache.org> on 2025/06/10 20:21:14 UTC, 3 replies.
- [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] - posted by "sjvanrossum (via GitHub)" <gi...@apache.org> on 2025/06/10 20:23:26 UTC, 3 replies.
- [PR] [IcebergIO] Create namespaces if needed [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/10 20:24:16 UTC, 11 replies.
- [PR] Adds support for updating Schema state fields. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2025/06/10 20:37:09 UTC, 5 replies.
- [PR] [IcebergIO] Fix conversion logic for arrays of structs and maps of structs; fix output Schema resolution with column pruning [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/10 21:01:09 UTC, 10 replies.
- [PR] Unpin antlr in BeamModulePlugins [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/10 21:18:54 UTC, 4 replies.
- [PR] Install JDK 21 in release build [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/10 21:37:08 UTC, 2 replies.
- [I] [Bug]: [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/11 01:01:05 UTC, 0 replies.
- Re: [I] [Bug]: [Python] Respect BigQuery insert byte size limit when writing batched rows [beam] - posted by "quentin-sommer (via GitHub)" <gi...@apache.org> on 2025/06/11 01:08:40 UTC, 1 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/06/11 01:09:05 UTC, 4 replies.
- Re: [PR] Estimate req size in BQ streaming when auto sharding is true [beam] - posted by "quentin-sommer (via GitHub)" <gi...@apache.org> on 2025/06/11 01:10:23 UTC, 8 replies.
- [PR] Allow only one thread at a time to start the VLLM server. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/11 01:16:16 UTC, 10 replies.
- Re: [I] [Feature Request]: Add Spanner change stream support to python. [beam] - posted by "flpablo (via GitHub)" <gi...@apache.org> on 2025/06/11 04:08:38 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.14 to 1.29.16 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 05:00:10 UTC, 3 replies.
- [PR] Bump google.golang.org/grpc from 1.72.2 to 1.73.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 05:00:15 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.67 to 1.17.69 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 05:01:16 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.74 to 1.17.79 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 05:02:28 UTC, 3 replies.
- Re: [PR] [IcebergIO] Support filter pushdown during reads [beam] - posted by "barunkumaracharya (via GitHub)" <gi...@apache.org> on 2025/06/11 10:07:59 UTC, 0 replies.
- Re: [PR] Fn Runner Watermark issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 12:46:42 UTC, 2 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/06/11 12:46:44 UTC, 2 replies.
- Re: [I] [Bug]: beam-starter-typescript: npm run build: TypeError: Cannot set property constructor of [object Object] which has only a getter [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 12:46:47 UTC, 0 replies.
- [PR] Remove internal code. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/11 13:56:04 UTC, 3 replies.
- [PR] [IcebergIO] Change writer open/close logs to debug [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/11 14:32:56 UTC, 1 replies.
- [PR] Adding error handler for SpannerReadSchemaTransformProvider and missi… [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/11 15:34:01 UTC, 7 replies.
- Re: [PR] [YAML]: fix postcommit oracle bug and reorganize postcommit tests [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/11 15:36:40 UTC, 9 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 15:38:49 UTC, 3 replies.
- [PR] Update CHANGES.md [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2025/06/11 16:06:06 UTC, 5 replies.
- [PR] Fix a logical type issue about JdbcDateType [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/11 16:46:39 UTC, 5 replies.
- [I] [Bug]: Python JDBCIO failed to handle DATE fields [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/11 16:53:32 UTC, 2 replies.
- Re: [PR] GCP Access Control [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/06/11 16:59:54 UTC, 5 replies.
- Re: [I] [Bug]: Iceberg record conversion utils do not handle collections of structs correctly [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/11 19:00:57 UTC, 0 replies.
- Re: [PR] [IcebergIO] Integrate with Beam SQL [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/11 19:10:13 UTC, 5 replies.
- [PR] Add Async Dofn and Test to BEAM [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2025/06/11 19:11:33 UTC, 6 replies.
- [PR] fix long_description when the md file cannot be found [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/11 19:13:09 UTC, 2 replies.
- Re: [PR] Fix a logical type issue about JdbcDateType and JdbcTimeType [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/11 19:44:45 UTC, 16 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to specify a partition spec when creating tables [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/11 21:59:01 UTC, 0 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 22:17:05 UTC, 1 replies.
- [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/11 22:17:08 UTC, 3 replies.
- [PR] Fix typo java-dependencies.md [beam] - posted by "baeminbo (via GitHub)" <gi...@apache.org> on 2025/06/12 01:51:30 UTC, 2 replies.
- [PR] [Java FnApi] Fix race in BeamFnStatusClient by initializing all fields before starting rpc. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/12 08:42:45 UTC, 10 replies.
- [PR] Iobase streaming textio [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/06/12 09:13:35 UTC, 0 replies.
- Re: [PR] Iobase streaming support in FileBasedSink, exposed in TextIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 10:40:38 UTC, 5 replies.
- Re: [I] [Task]: Utilize Managed Service for Apache Kafka resources for testing purposes. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 12:46:53 UTC, 0 replies.
- Re: [PR] [Java Harness] Improve heap dump support by configuring JVM to dump heap on OOM exceptions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 13:43:40 UTC, 7 replies.
- Re: [I] [Bug]: Reading from BigQuery provides inconsistent schemas [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/12 14:10:24 UTC, 0 replies.
- Re: [I] [Feature Request]: enable setting max_writer_per_bundle for avroIO and other IO [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/12 15:09:23 UTC, 0 replies.
- [I] [Task]: Add more info on setting up alloy db instance in notebook [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/12 15:30:25 UTC, 1 replies.
- Re: [PR] Support Java 17+ compiled Beam components for build, release, and xlang tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/12 15:31:28 UTC, 6 replies.
- [I] [Task] [IcebergIO]: Add RESTCatalog tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/12 17:52:28 UTC, 0 replies.
- [PR] [IcebergIO] update hadoop prefix [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/12 19:19:59 UTC, 6 replies.
- [PR] Add change stream new record models and tests. [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/12 19:42:42 UTC, 16 replies.
- [PR] Document BQ Storage API pipeline options [beam] - posted by "VeronicaWasson (via GitHub)" <gi...@apache.org> on 2025/06/12 19:45:47 UTC, 5 replies.
- [PR] [yaml]: add free disk space step for post commit yaml workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/12 20:04:36 UTC, 3 replies.
- [PR] Set go version 1.24.4 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/12 20:16:49 UTC, 7 replies.
- [PR] Support runners other than DirectRunner for :examples:java:execute [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/12 20:34:47 UTC, 11 replies.
- [PR] Run flaky test on prism [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/12 20:47:25 UTC, 22 replies.
- [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 22:14:47 UTC, 1 replies.
- [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 22:14:52 UTC, 3 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 22:15:07 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/12 22:15:29 UTC, 1 replies.
- [PR] [IcebergIO] extend table partitioning to Beam SQL [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/12 23:08:52 UTC, 5 replies.
- [I] [Task]: Migrate from archived kaniko for building SDK container images [beam] - posted by "RyuSA (via GitHub)" <gi...@apache.org> on 2025/06/13 02:15:27 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.235.0 to 0.236.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/13 04:15:13 UTC, 3 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/06/13 13:27:39 UTC, 11 replies.
- [I] [Task]: Yaml - fix kafka post commit test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/13 14:19:21 UTC, 3 replies.
- [PR] [yaml]: Fix post commit yaml once more [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/13 14:21:01 UTC, 1 replies.
- [PR] Suppress Findbugs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/13 14:37:39 UTC, 6 replies.
- [PR] Speed up StreamingDataflowWorkerTest by removing 10 second wait from shutdown path. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/13 14:49:14 UTC, 4 replies.
- [PR] (DO NOT MERGE) Revert "Parse values returned from Dataflow API to BoundedTrieData" [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/13 15:24:16 UTC, 1 replies.
- [PR] [yaml]: uncomment kafka test and see if it runs with self hosted runner [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/13 15:57:58 UTC, 0 replies.
- [PR] Polish anomaly detection notebook and get ready to be imported in public devsite. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/13 16:49:58 UTC, 1 replies.
- Re: [PR] [yaml]: uncomment WriteToKafka portion of test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/13 18:30:52 UTC, 3 replies.
- [PR] [yaml]: Phase2 High Usage Yaml examples [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/13 20:21:26 UTC, 6 replies.
- [PR] [Release-2.66] cherry-pick #35274 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/13 20:59:19 UTC, 4 replies.
- [PR] V2 record parser [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/13 21:18:43 UTC, 0 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/13 22:13:33 UTC, 1 replies.
- [PR] remove unnecessary output_hint inferring logic [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/14 00:30:30 UTC, 0 replies.
- [PR] added timeout for Direct_Read with Bigquery IO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/14 02:09:33 UTC, 9 replies.
- [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 03:46:47 UTC, 1 replies.
- Re: [PR] sdks/python: integrate Weaviate vector database I/O connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 12:46:10 UTC, 1 replies.
- Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 12:46:12 UTC, 1 replies.
- Re: [I] [Feature Request]: Add the ability to cancel timers in methods annotated with @onWindowExpiration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 12:46:15 UTC, 1 replies.
- Re: [I] [Dataflow Streaming] Micro Optimizations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 12:46:16 UTC, 0 replies.
- Re: [I] [Bug]: Can't build and deploy dataflow-runner with readFromPubSubWithAttributes (but can with readFromPubSub) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 12:46:17 UTC, 0 replies.
- [I] Getting error while using JdbcIO.ReadWithPartitions [beam] - posted by "umeshPathak (via GitHub)" <gi...@apache.org> on 2025/06/14 13:19:39 UTC, 1 replies.
- [PR] feat: Add option to control resource cleanup failure for IT [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/14 15:41:49 UTC, 2 replies.
- [PR] Fix(yaml): Handle missing optional fields in JSON parsing [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/14 19:30:26 UTC, 12 replies.
- [PR] try buildah to replace kaniko [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/14 20:28:09 UTC, 5 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 22:13:32 UTC, 2 replies.
- [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/14 22:13:40 UTC, 1 replies.
- [PR] Add dynamic read support to KafkaIO in Python SDK [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/14 22:31:12 UTC, 6 replies.
- [PR] Update Python Dependencies [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 00:42:00 UTC, 2 replies.
- [PR] use Median Absolute Deviation for the perf alerts [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/15 01:33:15 UTC, 2 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 06:41:34 UTC, 4 replies.
- Re: [I] [Feature Request]: managed IO connector for Apache Iceberg to offer Configurable Write Options for Target Table [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 12:46:17 UTC, 0 replies.
- Re: [I] [Feature Request]: Provide error log for troubleshooting newJarGetter function [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/15 12:46:21 UTC, 0 replies.
- [I] [Bug]: pubsubio in Go SDK incorrectly sets Topic when Subscription is specified [beam] - posted by "tgw-thirdfort (via GitHub)" <gi...@apache.org> on 2025/06/15 18:53:42 UTC, 1 replies.
- [PR] Add dataflow option python [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/15 20:40:11 UTC, 6 replies.
- [PR] BEAM-9626: Make Pymongo package optional - 20259 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/15 21:05:07 UTC, 5 replies.
- Re: [I] pymongo should be an optional requirement [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/15 21:05:31 UTC, 0 replies.
- Re: [PR] Fix `beam.Filter` type hints for case where filter_fn specifies output type hint but not input type hint [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/16 00:54:32 UTC, 3 replies.
- [PR] Python dataflow option [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/16 01:31:12 UTC, 7 replies.
- [PR] add back-off retry for JMS write [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/16 02:13:27 UTC, 12 replies.
- [PR] Add PeriodicStream in the new time series folder. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/16 03:14:24 UTC, 4 replies.
- [PR] Bump org.ajoberstar.grgit:grgit-gradle from 4.1.1 to 5.3.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 04:22:44 UTC, 8 replies.
- [PR] Bump google.golang.org/api from 0.235.0 to 0.237.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 04:41:39 UTC, 3 replies.
- [PR] Fix PreCommit Java Solace IO Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/16 09:29:58 UTC, 4 replies.
- [I] [Bug]: Error in SolaceIO during autoscaling events ("Tried to start a closed message consumer") [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2025/06/16 12:44:45 UTC, 0 replies.
- Re: [I] [Feature Request]: Dynamic partition key in WriteToKinesis [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 12:47:00 UTC, 0 replies.
- [PR] Revert "Bump org.ajoberstar.grgit:grgit-gradle from 4.1.1 to 5.3.2" [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/16 14:58:42 UTC, 3 replies.
- [PR] Fix PreCommit Java workflow [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/06/16 17:00:13 UTC, 7 replies.
- [PR] [IcebergIO] create custom java container image for tests [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/16 17:18:22 UTC, 4 replies.
- [PR] Bump reqeusts version. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/16 18:24:14 UTC, 4 replies.
- [PR] [TEST] sdks/python: update testcontainer container [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/16 18:52:09 UTC, 0 replies.
- [PR] [WIP] Get minimal repro of flaky prism test [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/16 19:19:51 UTC, 2 replies.
- [PR] Fix unstable output of periodic sequence due to precision error. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/16 20:01:06 UTC, 7 replies.
- [I] [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/16 20:20:48 UTC, 1 replies.
- Re: [PR] [TEST] sdks/python/setup.py: update testcontainer version [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/16 20:38:20 UTC, 3 replies.
- [PR] Fix Spotbugs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/16 21:41:52 UTC, 7 replies.
- Re: [PR] Refactor: separate SplittableTruncateSizedRestrictions [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/16 22:22:20 UTC, 8 replies.
- Re: [PR] Introduce OutputBuilder in Java SDK [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/16 22:39:51 UTC, 0 replies.
- [PR] [Beam SQL] Change SET CATALOG to USE CATALOG [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/16 23:13:57 UTC, 7 replies.
- [PR] Blog: My Experience at Beam College 2025 (3rd Place Hackathon Winner) [beam] - posted by "msugar (via GitHub)" <gi...@apache.org> on 2025/06/16 23:43:50 UTC, 6 replies.
- [PR] [Spark runner] Support for ProcessingTime Timer for Spark Runner [beam] - posted by "twosom (via GitHub)" <gi...@apache.org> on 2025/06/17 03:39:23 UTC, 10 replies.
- [PR] Bump protobuf from 5.29.4 to 5.29.5 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 03:57:11 UTC, 3 replies.
- [I] [Bug]: Got error 'ValueError: Schema with id has encoding_positions_set=True, but not all fields have encoding_position set' for no apparent reason [beam] - posted by "jonathaningram (via GitHub)" <gi...@apache.org> on 2025/06/17 04:05:03 UTC, 9 replies.
- [PR] Bump protobuf from 5.29.4 to 5.29.5 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 04:06:24 UTC, 4 replies.
- [PR] Bump protobuf from 4.21.12 to 4.25.8 in /playground/infrastructure [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 04:07:30 UTC, 2 replies.
- [PR] Bump protobuf from 4.25.0 to 4.25.8 in /.test-infra/mock-apis [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 04:13:57 UTC, 2 replies.
- [PR] Bump github.com/golang-cz/devslog from 0.0.13 to 0.0.15 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 04:32:28 UTC, 2 replies.
- [PR] Bump go.mongodb.org/mongo-driver from 1.17.3 to 1.17.4 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 04:32:34 UTC, 2 replies.
- [I] [Bug]: [Dataflow] Don't suppress OutOfMemoryError or other Errors. [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2025/06/17 06:32:18 UTC, 1 replies.
- Re: [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] - posted by "ppawel (via GitHub)" <gi...@apache.org> on 2025/06/17 06:34:24 UTC, 2 replies.
- Re: [I] [Feature Request]: Vertex AI Triton Inference Server Support [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/06/17 08:25:23 UTC, 0 replies.
- Re: [I] [Feature Request]: [IcebergIO] Allow users to pass table properties to be set when creating a table [beam] - posted by "SaumilPatel03 (via GitHub)" <gi...@apache.org> on 2025/06/17 08:26:44 UTC, 0 replies.
- [I] [Bug]: BigTable client "One or more TimeSeries could not be written" Java 2.65.0 [beam] - posted by "aprochko (via GitHub)" <gi...@apache.org> on 2025/06/17 09:06:49 UTC, 1 replies.
- [PR] [Dataflow Streaming] Modify AbstractWindmillStream to separate logical stream from physical streams. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/17 11:46:09 UTC, 4 replies.
- Re: [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/06/17 12:34:19 UTC, 4 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/06/17 12:46:47 UTC, 2 replies.
- Re: [I] [Task]: Modernize Protos to Editions, with minimal SDK code changes due to code generation. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 12:46:51 UTC, 0 replies.
- Re: [I] [Feature Request]: Support ProcessingTime Timer in Spark Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 12:46:51 UTC, 0 replies.
- [I] CVE-2025-4565 in protobuf<6.31.1 used by Python SDK [beam] - posted by "tpwo2 (via GitHub)" <gi...@apache.org> on 2025/06/17 13:21:05 UTC, 1 replies.
- [I] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] - posted by "ng-oliver (via GitHub)" <gi...@apache.org> on 2025/06/17 14:15:15 UTC, 0 replies.
- [PR] Unbreak Playground CI nightly suite [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/17 15:12:16 UTC, 3 replies.
- [PR] Fix link to beam_Playground_CI_Nightly [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/17 15:19:57 UTC, 3 replies.
- Re: [I] Make it easier to run seed job against open PRs [beam] - posted by "pabloem (via GitHub)" <gi...@apache.org> on 2025/06/17 15:37:00 UTC, 0 replies.
- [I] The IcebergIO Unit Tests job is permared [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 15:39:06 UTC, 4 replies.
- [I] The PreCommit Java Jms IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 15:39:15 UTC, 2 replies.
- [I] The PreCommit Integration and Load Test Framework job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 15:39:16 UTC, 3 replies.
- [PR] Cherrypicking #35314 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/17 16:34:27 UTC, 11 replies.
- Re: [PR] add generics support to AutoValueUtils helpers [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:36:49 UTC, 0 replies.
- Re: [PR] BigQueryIO uniformize direct and export reads [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:37:37 UTC, 0 replies.
- Re: [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:37:57 UTC, 0 replies.
- Re: [PR] Add ability to specify partition bounds via jdbc xlang. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:38:24 UTC, 0 replies.
- Re: [PR] create helper function [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:39:50 UTC, 2 replies.
- Re: [PR] [Java]Add Map Type Support to JsonToRow Transformer [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:40:59 UTC, 0 replies.
- Re: [PR] [Java] Ensure Pipeline Execution Requires Configuration Options or Logs Warning [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:41:56 UTC, 0 replies.
- [PR] Allow running TFT benchmarks from pr [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/17 16:52:53 UTC, 3 replies.
- [PR] Adjust runners/local-java so constructor does not throw exception [beam] - posted by "kennknowles (via GitHub)" <gi...@apache.org> on 2025/06/17 17:04:26 UTC, 6 replies.
- Re: [I] [Bug]: Flaky Prism Runner unit tests in Java PreCommit [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 17:50:40 UTC, 1 replies.
- [PR] Fix 35202 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 18:25:49 UTC, 2 replies.
- [PR] Dont exit execution loop before bundle is done [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/17 18:39:39 UTC, 12 replies.
- Re: [PR] Fix flaky precommit java test on prism caused by PR 35202 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 19:28:53 UTC, 0 replies.
- Re: [PR] Cherrypick PR 35306 and 35336 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 19:47:24 UTC, 1 replies.
- [PR] Fix Beam SQL shell doc [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/17 19:54:56 UTC, 3 replies.
- [PR] Cherry pick 35306 35336 second attempt [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 19:56:44 UTC, 0 replies.
- Re: [PR] Cherry pick PR 35306 and 35336 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/17 20:04:26 UTC, 1 replies.
- [PR] [IcebergIO SQL] create real iceberg table [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/17 20:54:32 UTC, 5 replies.
- [I] [Bug]: relax dill version [beam] - posted by "mhyatt000 (via GitHub)" <gi...@apache.org> on 2025/06/17 21:20:39 UTC, 2 replies.
- [PR] [Cherry-pick] Dont exit execution loop before bundle is done (#35337) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/17 21:30:25 UTC, 3 replies.
- [I] The PreCommit Java InfluxDb IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 21:37:08 UTC, 2 replies.
- [I] The PreCommit Java File-schema-transform IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/17 21:37:14 UTC, 2 replies.
- Re: [PR] BEAM-9626: Move out optional packages from core dependencies - 20259 [beam] - posted by "rakeshcusat (via GitHub)" <gi...@apache.org> on 2025/06/17 22:27:12 UTC, 5 replies.
- [PR] Blog: Add time and zone to value of date field in metadata [beam] - posted by "msugar (via GitHub)" <gi...@apache.org> on 2025/06/17 22:41:57 UTC, 3 replies.
- [I] [Bug]: WriteToPubSub silently failing to publish messages [beam] - posted by "pricealexandra (via GitHub)" <gi...@apache.org> on 2025/06/17 23:37:47 UTC, 0 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.14 to 1.29.17 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/18 04:43:15 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.74 to 1.17.80 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/18 04:44:18 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.67 to 1.17.70 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/18 04:46:57 UTC, 3 replies.
- Re: [I] [Bug]: cassandraIO ReadAll does not let a pipeline handle or retry exceptions [beam] - posted by "VardhanThigle (via GitHub)" <gi...@apache.org> on 2025/06/18 06:20:56 UTC, 1 replies.
- [PR] Fix The PostCommit Python job [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/06/18 07:08:34 UTC, 2 replies.
- [I] [Task]: Sliding window ptransform for time series data [beam] - posted by "AshokDevireddy (via GitHub)" <gi...@apache.org> on 2025/06/18 12:47:25 UTC, 0 replies.
- [PR] Cherrypick #35341 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/18 13:22:26 UTC, 6 replies.
- [PR] Clear space before generating the beam site pr - it seems this takes … [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/18 14:16:00 UTC, 5 replies.
- [I] [Bug]: BigQuery failures logged as warning even [beam] - posted by "gariepyalex (via GitHub)" <gi...@apache.org> on 2025/06/18 15:17:45 UTC, 0 replies.
- [PR] Updates Dataflow Python container [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2025/06/18 15:58:13 UTC, 3 replies.
- [I] The LoadTests Go GBK Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/18 18:42:47 UTC, 2 replies.
- [PR] Use splitAsStream for wordcount [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/18 18:52:15 UTC, 4 replies.
- [PR] Update Beam website to release 2.66.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/18 18:57:54 UTC, 1 replies.
- [PR] [IcebergIO] Add ITs for RESTCatalog using BLMS [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2025/06/18 19:22:38 UTC, 1 replies.
- [PR] Fix buildx always enabled [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/18 21:52:12 UTC, 6 replies.
- [PR] WIP - fix Debezium xlang test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/18 23:03:50 UTC, 0 replies.
- [I] How do I compress the output of using the WriteToFiles method? [beam] - posted by "serratedserenade (via GitHub)" <gi...@apache.org> on 2025/06/18 23:45:43 UTC, 6 replies.
- Re: [I] [Bug]: BigQuery failures logged as warning even when the rows won't be retried [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/19 03:58:45 UTC, 0 replies.
- [PR] Bump cloud.google.com/go/profiler from 0.4.2 to 0.4.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 04:59:15 UTC, 2 replies.
- [PR] Bump github.com/go-sql-driver/mysql from 1.9.2 to 1.9.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 04:59:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.80.3 to 1.81.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 05:00:21 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.81 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 05:01:24 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.237.0 to 0.238.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 05:01:30 UTC, 2 replies.
- [PR] Exactly one of Topic or Subscription must be set in pubsubio.go [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/19 05:22:13 UTC, 6 replies.
- [PR] Bump urllib3 from 2.4.0 to 2.5.0 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 05:28:47 UTC, 4 replies.
- [I] [Feature Request]: Is KafkaIO compatible with Apache Kafka 4.0 [beam] - posted by "DuanHen (via GitHub)" <gi...@apache.org> on 2025/06/19 06:54:24 UTC, 4 replies.
- [PR] Fix PubsubIOLT [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/06/19 08:53:10 UTC, 4 replies.
- [PR] Distinguishing bigquery logging failures severities [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/19 09:34:57 UTC, 2 replies.
- Re: [PR] Add withReshuffle(boolean) option to FileIO.matchAll() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/19 12:46:41 UTC, 0 replies.
- [PR] Fix broad suppression of dataflow worker windmill package. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/19 12:53:01 UTC, 0 replies.
- [PR] [YAML] A Streaming Inference Pipeline - YouTube Comments Sentiment Analysis [beam] - posted by "charlespnh (via GitHub)" <gi...@apache.org> on 2025/06/19 14:51:42 UTC, 3 replies.
- [PR] added defaultQueryTimeout for jdbc io [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/19 17:24:38 UTC, 3 replies.
- [PR] try kafka-clients 4.0.0 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/19 20:28:29 UTC, 2 replies.
- [I] The PostCommit Python Xlang IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 03:47:57 UTC, 3 replies.
- Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] - posted by "TanuSharma2511 (via GitHub)" <gi...@apache.org> on 2025/06/20 03:49:47 UTC, 0 replies.
- [PR] Sliding window ptransform for time series data [beam] - posted by "AshokDevireddy (via GitHub)" <gi...@apache.org> on 2025/06/20 04:28:46 UTC, 10 replies.
- Re: [PR] [DO NOT MERGE] tried to add artifactApiService [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 12:46:39 UTC, 2 replies.
- Re: [I] [Bug]: Array is missing in `ColumnType` descriptor - ClickHouseIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 12:46:43 UTC, 1 replies.
- Re: [I] [Feature Request]: Update Python JDBC write transforms to support configuring the batch size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 12:46:55 UTC, 0 replies.
- [PR] define display_data as a appliedptransform attribute similar to annot… [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2025/06/20 20:27:56 UTC, 0 replies.
- [I] The PostCommit Python Nexmark Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/20 21:36:02 UTC, 2 replies.
- [I] The PostCommit Java Nexmark Dataflow V2 Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/21 00:49:57 UTC, 2 replies.
- [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/21 00:50:04 UTC, 3 replies.
- [I] The PostCommit Java Nexmark Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/21 00:50:05 UTC, 2 replies.
- [I] [Bug]: Prism firing windows incorrectly when sliding windows are used [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/21 00:59:37 UTC, 2 replies.
- [PR] Fix the issue of sliding window firing early. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/21 01:38:43 UTC, 4 replies.
- [PR] reconnect when publishMessage in JMS fails [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/21 01:56:10 UTC, 5 replies.
- [PR] Improve LogElements to show pane_info and timestamps in seconds. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/21 04:30:02 UTC, 5 replies.
- Re: [I] [Bug]: BQ TableRow does not accept column named 'f' [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/21 12:46:18 UTC, 0 replies.
- [PR] Support Docker Compose v2 in Python TransformServiceLauncher [beam] - posted by "nguymin4 (via GitHub)" <gi...@apache.org> on 2025/06/21 19:40:59 UTC, 5 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/06/21 22:12:28 UTC, 1 replies.
- Re: [I] [Bug]: SpannerIO ExecuteStreamingRead timeout not being set [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/22 12:46:14 UTC, 0 replies.
- Re: [I] [Feature Request]: {BigQuery IO Iceberg} - Allow users to run streaming reads [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/22 12:46:16 UTC, 0 replies.
- Re: [I] [Feature Request]: Managed IO connector for Apache Iceberg to allow users to define file size for writes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/22 12:46:16 UTC, 0 replies.
- Re: [PR] Added documentation for return vs yield usage in DoFn.process() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/22 17:37:51 UTC, 4 replies.
- Re: [I] [Bug]: Python 3.12 in-compatibility of Apache Beam [beam] - posted by "mmckerns (via GitHub)" <gi...@apache.org> on 2025/06/22 19:38:43 UTC, 0 replies.
- [I] [Prism]: Support Docker in MacOS with transforms for Cross Language [beam] - posted by "nguymin4 (via GitHub)" <gi...@apache.org> on 2025/06/22 22:38:51 UTC, 0 replies.
- [PR] Mysql embeddings [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/22 23:47:04 UTC, 0 replies.
- [PR] Fix suppressed Spotbugs issues [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/23 09:50:37 UTC, 5 replies.
- [PR] sdks/python: Check if ML RAG Integration Tests Ever Run [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/23 12:26:51 UTC, 0 replies.
- [PR] Fix The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/06/23 12:34:45 UTC, 15 replies.
- Re: [I] [Task]: Investigate Failures in Go Flink Load Tests with original load [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 12:46:57 UTC, 0 replies.
- Re: [I] [Flaky Py SDK Snapshots]: Publish Beam SDK Snapshots is failing for Python distroless container [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 12:46:58 UTC, 0 replies.
- Re: [I] [Feature Request]: Managed IO connector for Apache Iceberg to offer dynamically handling schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/23 12:47:01 UTC, 0 replies.
- Re: [PR] sdks/python: Check if ML RAG Integration Tests Ever Run in the CI [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/23 13:27:11 UTC, 4 replies.
- [I] [Feature Request]: Installing Jupyter Sidepanel by pip [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/23 14:25:50 UTC, 2 replies.
- [PR] Try reenabling flaky test [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/23 14:46:41 UTC, 3 replies.
- [PR] ✨[Feature]: Add pip-based install support for JupyterLab side panel extension [beam] - posted by "Chenzo1001 (via GitHub)" <gi...@apache.org> on 2025/06/23 14:54:51 UTC, 8 replies.
- [PR] Minstant [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/23 17:10:33 UTC, 0 replies.
- [I] [Feature Request]: Add the job name to userAgentString for Spanner IO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/23 17:17:16 UTC, 1 replies.
- [PR] ]Cherrypick] Fix suppressed Spotbugs issues [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/23 17:36:31 UTC, 0 replies.
- [PR] Improve exception raised from cache [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/23 17:50:49 UTC, 2 replies.
- Re: [I] [Feature Request]: Add library stubs or py.typed marker [beam] - posted by "cnsgsz (via GitHub)" <gi...@apache.org> on 2025/06/23 19:09:36 UTC, 0 replies.
- [PR] Disable dependency logging in local envs [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/23 19:14:47 UTC, 2 replies.
- Re: [PR] [Cherrypick] Fix suppressed Spotbugs issues [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/23 19:34:48 UTC, 1 replies.
- [PR] Reduce issues induced by ordering [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/23 20:17:52 UTC, 2 replies.
- [PR] add a thread to flush buffered metrics [beam] - posted by "Naireen (via GitHub)" <gi...@apache.org> on 2025/06/23 23:10:23 UTC, 0 replies.
- [PR] Deserialize proto based (mutable key range) change stream return records [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/24 00:10:38 UTC, 10 replies.
- [PR] Add new change record action functions [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/24 00:30:26 UTC, 7 replies.
- [PR] improved the error message when encoding_positions_set has errors [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/24 01:33:16 UTC, 2 replies.
- [I] [Bug]: Update dill version to make pylint work [beam] - posted by "davidreisbr (via GitHub)" <gi...@apache.org> on 2025/06/24 02:49:59 UTC, 0 replies.
- [PR] Move PeriodicStream into periodicsequence. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/24 03:07:48 UTC, 13 replies.
- [PR] Add dataflow option go [beam] - posted by "LEEKYE (via GitHub)" <gi...@apache.org> on 2025/06/24 06:43:11 UTC, 4 replies.
- [PR] [WIP] Fix Python Transform and IT for DebeziumIO [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2025/06/24 09:42:08 UTC, 0 replies.
- Re: [I] [Task]: Manage Infra privileges via Infra-as-code [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 12:46:51 UTC, 0 replies.
- Re: [I] [Task]: Build a cleaner for assets in the GCP test environment [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 12:46:55 UTC, 0 replies.
- [PR] fixed encoding_positions_set [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/24 13:31:12 UTC, 1 replies.
- [I] [Bug]: IcebergIO partitionning_month manifest update issue [beam] - posted by "mskyrim (via GitHub)" <gi...@apache.org> on 2025/06/24 14:22:28 UTC, 1 replies.
- Re: [I] [Bug] [BQ Streaming Inserts]: Whole number in float field is treated like an int [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/24 14:25:57 UTC, 0 replies.
- [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] - posted by "mskyrim (via GitHub)" <gi...@apache.org> on 2025/06/24 14:27:42 UTC, 0 replies.
- [PR] Iobase streaming others [beam] - posted by "razvanculea (via GitHub)" <gi...@apache.org> on 2025/06/24 15:25:29 UTC, 3 replies.
- [I] The PreCommit Portable Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/24 15:39:18 UTC, 2 replies.
- Re: [I] [Feature Request]: PubSubIO should allow disabling auto ack after the 1st fused stage [beam] - posted by "wattache (via GitHub)" <gi...@apache.org> on 2025/06/24 15:46:12 UTC, 0 replies.
- [PR] Bump workflow timeout [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/24 17:02:53 UTC, 2 replies.
- [I] [Feature Request]: ClickHouseIO - Include Beam runtime environment in User-Agent string [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2025/06/24 18:11:19 UTC, 0 replies.
- [PR] Cloudpickle configurable [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/24 19:00:05 UTC, 0 replies.
- [PR] [yaml]: Phases 3-4 Moderate-High Usage Yaml examples [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/24 19:20:39 UTC, 1 replies.
- [I] [Bug]: Request Size Limit Exceeded for ProtoRows with Large Payloads (Beyond Dismissed Edge Case) [beam] - posted by "criptonyte (via GitHub)" <gi...@apache.org> on 2025/06/25 00:30:06 UTC, 0 replies.
- [PR] Another fix for jdbc timestamp logical type. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/25 01:47:02 UTC, 1 replies.
- [PR] Bump github.com/docker/docker from 28.2.2+incompatible to 28.3.0+incompatible in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 04:29:04 UTC, 1 replies.
- [PR] Fix post commit xlang [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/25 13:06:59 UTC, 3 replies.
- [I] [Bug]: Spark runner fails on sliding windows [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/25 13:40:16 UTC, 0 replies.
- [PR] Skip sliding window tests on samza and spark runner test suites [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/25 13:50:01 UTC, 2 replies.
- [PR] Pin torch dependencies to tested versions [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/25 15:12:46 UTC, 4 replies.
- Re: [PR] Fix post commit xlang jdbcio test failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/25 16:51:47 UTC, 0 replies.
- [I] [Feature Request]: Support Protobuf 6.x [beam] - posted by "yilei (via GitHub)" <gi...@apache.org> on 2025/06/25 17:26:19 UTC, 0 replies.
- [PR] Add cross-process determinism check for DeterministicFastPrimitivesCoder. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/25 17:45:53 UTC, 8 replies.
- [I] [Bug]: Beam YAML parsing bug [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2025/06/25 19:55:35 UTC, 2 replies.
- [PR] Arnav Arora BigTablePR [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2025/06/25 20:11:15 UTC, 15 replies.
- Re: [PR] [IO] Fix Python Transform and IT for DebeziumIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/25 22:06:59 UTC, 1 replies.
- [PR] V2 integration test [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/25 23:56:39 UTC, 0 replies.
- [PR] fixed the beam yaml create issue by creating the full dict [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/26 00:13:26 UTC, 1 replies.
- [PR] Stale claner implementation [beam] - posted by "ksobrenat32 (via GitHub)" <gi...@apache.org> on 2025/06/26 00:18:03 UTC, 1 replies.
- [PR] Fix internal test failure due to a newly added test. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/26 03:34:48 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.238.0 to 0.239.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/26 04:45:20 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.80 to 1.17.82 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/26 04:46:25 UTC, 1 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.81.0 to 1.82.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/06/26 04:47:29 UTC, 2 replies.
- Re: [PR] Fix flakiness in fuzzy test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/28 12:06:17 UTC, 0 replies.
- Re: [I] [Bug]: symbols are not exported from `apache_beam`, causing type errors from Pylance [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:22 UTC, 1 replies.
- Re: [I] [Feature Request]: Infrastructure documentation [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:24 UTC, 1 replies.
- Re: [I] [Bug]: TypeScript xlang ValueError: numpy.dtype size changed [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:25 UTC, 1 replies.
- Re: [I] [Bug]: Beam example repo warning log while launching on Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:26 UTC, 1 replies.
- Re: [I] [Bug]: Python error just in importing apache-beam line within docker image [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:27 UTC, 1 replies.
- Re: [I] [Bug]: python trivial inferencing code fails when dealing with unpacking+generators [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:28 UTC, 1 replies.
- Re: [I] [Feature Request][RRIO]: Enable BackOffSupplier configuration [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:29 UTC, 1 replies.
- Re: [I] [Feature Request]: requester-pays flag for GCS storage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:30 UTC, 1 replies.
- Re: [I] [Feature Request]: Add a DIRECT_READ method to bigqueryio go sdk using BigQuery Storage API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:32 UTC, 1 replies.
- Re: [I] [Task]: Investigate how to make large python_Combine_Flink_Streaming_2GB_Fanout*.txt working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:33 UTC, 1 replies.
- Re: [I] [Feature Request]: Python-based Unbounded WebSocker IO Connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:34 UTC, 1 replies.
- Re: [I] [Feature Request]: Support `OrderedListState` in SparkRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:35 UTC, 1 replies.
- Re: [I] [Bug]: BigQuery SchemaUpdateOptions fails depending on dataset size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 12:46:36 UTC, 1 replies.
- [PR] Revert "Deserialize proto based (mutable key range) change stream return records" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/28 15:33:19 UTC, 1 replies.
- [PR] Support TimestampTypes in PeriodicImpulse. Fix flakiness in fuzzy tests. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/28 19:23:21 UTC, 1 replies.
- Re: [PR] [WIP] Fix flakiness in fuzzy test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/28 19:25:20 UTC, 1 replies.
- Re: [PR] Remove stdout prints from HistogramData [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/28 20:01:13 UTC, 0 replies.
- Re: [PR] Remove system-rules dependency [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2025/06/28 20:17:57 UTC, 1 replies.
- Re: [PR] Drop junit-dep dependency by removing system-rules usage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/28 21:06:08 UTC, 1 replies.
- Re: [PR] added waitForConditionAndForceCancel [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/28 23:20:02 UTC, 0 replies.
- Re: [PR] [1/2] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/29 00:29:56 UTC, 11 replies.
- Re: [I] [Bug]: com.rabbitmq.client.AlreadyClosedException causes RabbitMQIO pipeline to fail [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/29 00:48:11 UTC, 0 replies.
- [PR] RabbitMqIO doesn't handle closed channels [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/29 01:14:59 UTC, 1 replies.
- [PR] Support BigQuery dialect in Beam SQL [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/29 01:34:17 UTC, 7 replies.
- [PR] [2/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/29 02:44:53 UTC, 1 replies.
- Re: [PR] Fix flakiness in fuzzy tests and support TimestampTypes in PeriodicImpulse. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/29 03:44:52 UTC, 4 replies.
- Re: [PR] Another attempt to fix jdbc timestamp logical type. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2025/06/29 04:43:38 UTC, 3 replies.
- Re: [I] The PreCommit Python Lint job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/29 04:57:00 UTC, 1 replies.
- Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] - posted by "Ashfaqbs (via GitHub)" <gi...@apache.org> on 2025/06/29 07:52:44 UTC, 1 replies.
- [I] [Bug]: Missing `create_blob` and incorrect returns in FakeBucket's `lookup_blob` [beam] - posted by "nhonx (via GitHub)" <gi...@apache.org> on 2025/06/29 10:36:42 UTC, 1 replies.
- [PR] Fix logic in lookup_blob to correctly return blob in bucket [beam] - posted by "nhonx (via GitHub)" <gi...@apache.org> on 2025/06/29 10:42:58 UTC, 2 replies.
- Re: [I] [Bug]: Certain nullable type resolved to not null coder after #32705 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:26 UTC, 1 replies.
- Re: [I] [Bug]: vLLM inference with direct runner leaves a python process in the background after Beam program terminates [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:27 UTC, 1 replies.
- Re: [I] [Task]: Improve the example for PythonExternalTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:29 UTC, 1 replies.
- Re: [I] [Feature Request]: Refactor Histogram Implementation out of DF runner so it can be used by portable and other runners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:31 UTC, 1 replies.
- Re: [I] [Feature Request]: Add per-worker labelled/histogram metrics to Kafka IO for a Portable Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:32 UTC, 1 replies.
- Re: [I] [Failing Test]: Fix and re-enable the TensorRT integration test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:33 UTC, 1 replies.
- Re: [I] [Feature Request]: Publish Apache Beam SDK as a .tar.gz Archive for Compatibility with `rules_oci` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:34 UTC, 1 replies.
- Re: [I] [Bug]: BigtableIO.Read can't retrive large row that exceeds 256MB [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:35 UTC, 1 replies.
- Re: [I] [Bug]: FnHarness.main not thread-safe on JvmInitializer calls [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:36 UTC, 1 replies.
- Re: [I] [Task]: Update Python SDK code base to PEP 585 standards [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:36 UTC, 2 replies.
- Re: [I] [Task]: Documentation for SubProcess example [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/29 12:46:38 UTC, 1 replies.
- [PR] Fix(java/sql): Fix NullPointerException in TextTableProvider for Java 17 [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/29 15:09:36 UTC, 2 replies.
- [PR] Support Protobuf 6.x. [beam] - posted by "yilei (via GitHub)" <gi...@apache.org> on 2025/06/29 17:14:34 UTC, 0 replies.
- [PR] fixed the large row errors fof BigQuery IO storage write [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/29 20:08:25 UTC, 3 replies.
- [PR] added the job id for spanner IO [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2025/06/30 00:49:18 UTC, 0 replies.
- [PR] run bomupgrader.py to update Google Cloud-related dependency [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/30 06:30:29 UTC, 7 replies.
- [PR] Revert "Revert "Deserialize proto based (mutable key range) change stream return records"" [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/30 06:33:05 UTC, 0 replies.
- [PR] Fix LoadTests Go GBK Flink Batch job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2025/06/30 10:33:22 UTC, 2 replies.
- Re: [I] [Bug]: NumPy > 2.x.x is not compatible with sklearn. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:46:48 UTC, 0 replies.
- Re: [I] [Bug]: Cross-Language State Growth in Solace IO with Python SDK and Flink Runner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:46:56 UTC, 1 replies.
- Re: [I] [Feature Request]: Beam Python SDK version mismatches between submission/runtime are not detected in some cases [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:46:58 UTC, 1 replies.
- Re: [I] [Distroless] Add ARM-based Distroless Java SDK variants [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:47:00 UTC, 1 replies.
- Re: [I] [Distroless] Add ARM-based Distroless Python SDK (non-ML) variants [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:47:01 UTC, 1 replies.
- Re: [I] [Feature Request]: Map Type supported in the JsonToRow Transformer [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:47:03 UTC, 1 replies.
- Re: [I] [Feature Request][Go SDK]: Make lull logging say the Go name of the transform, not just the ID. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:47:09 UTC, 0 replies.
- Re: [I] [Bug]: Apache Beam FlinkRunner does not process Kafka messages [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 12:47:09 UTC, 0 replies.
- [I] [Task]: Upgrade calcite to a more recent version [beam] - posted by "flo076 (via GitHub)" <gi...@apache.org> on 2025/06/30 14:50:52 UTC, 0 replies.
- [PR] Add logic for generating ml requirements [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/30 15:14:03 UTC, 0 replies.
- [PR] Actually publish distroless containers when releasing [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/30 15:49:24 UTC, 1 replies.
- Re: [PR] [1/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/30 15:49:33 UTC, 1 replies.
- [PR] Skip test if no python interpreter. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2025/06/30 16:19:04 UTC, 3 replies.
- Re: [PR] [1/3] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 16:22:44 UTC, 3 replies.
- Re: [PR] Fix TypeError in avro_union_type_to_beam_type with complex union types [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/30 17:02:47 UTC, 0 replies.
- [I] [Feature Request]: Add set of ML Beam containers [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2025/06/30 17:17:27 UTC, 0 replies.
- [PR] Revert "Revert "Parse v2 record. (#35408)" (#35469)" [beam] - posted by "changliiu (via GitHub)" <gi...@apache.org> on 2025/06/30 17:21:31 UTC, 0 replies.
- Re: [PR] Adding GCP Spanner Change Stream support for Python [beam] - posted by "flpablo (via GitHub)" <gi...@apache.org> on 2025/06/30 17:43:37 UTC, 1 replies.
- Re: [PR] Remove unused IOException from Backoff and BackoffUtils. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2025/06/30 18:07:52 UTC, 1 replies.
- [I] [Bug]: Issue with Yaml Filter-sql [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/30 18:19:36 UTC, 1 replies.
- [PR] [yaml]: fix filter sql issue [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2025/06/30 18:20:08 UTC, 2 replies.
- Re: [PR] [2/3] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "mohamedawnallah (via GitHub)" <gi...@apache.org> on 2025/06/30 18:30:22 UTC, 1 replies.
- Re: [PR] [3/3] sdks/python: enrich data with Milvus Search [Vector, Keyword, Hybrid] [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/06/30 20:07:56 UTC, 3 replies.
- [PR] Fix PostCommit Python Xlang IO Direct [beam] - posted by "akashorabek (via GitHub)" <gi...@apache.org> on 2025/06/30 23:47:17 UTC, 0 replies.