github@beam.apache.org, 2026-05

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

- Re: [PR] Support staging Python packages given via a URL [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 00:08:15 UTC, 13 replies.
- [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] - posted by "bambadiouf1 (via GitHub)" <gi...@apache.org> on 2026/05/01 02:04:48 UTC, 8 replies.
- [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.1.3,<2.5.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:57:30 UTC, 3 replies.
- [PR] Update jinja2 requirement from <4.0.0,>=2.7.1 to >=3.0.3,<4.0.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:57:30 UTC, 3 replies.
- [PR] Update pyyaml requirement from <7.0.0,>=3.12 to >=5.4.1,<7.0.0 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:57:32 UTC, 3 replies.
- Re: [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 05:38:06 UTC, 8 replies.
- Re: [PR] Fix PostCommit Python Xlang Gcp Direct job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 05:38:14 UTC, 0 replies.
- Re: [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 05:38:16 UTC, 3 replies.
- Re: [PR] Revert "remove processContext usage across examples (java and kotlin)" [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/01 08:07:09 UTC, 0 replies.
- [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/01 09:36:54 UTC, 4 replies.
- Re: [PR] datastore: Same key in mutation batch [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 12:34:47 UTC, 7 replies.
- Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior (fixes #37445) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 12:49:45 UTC, 2 replies.
- Re: [I] Requesting invitation to ASF Slack Workspace [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 12:50:01 UTC, 2 replies.
- Re: [PR] Deflake PreCommit Java watchForNewFiles [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/01 12:59:11 UTC, 0 replies.
- [PR] Bump to Beam 2.73.0 [beam-starter-java] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 13:00:11 UTC, 1 replies.
- [PR] Update republish_released_docker_containers.yml to 2.73.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 13:01:49 UTC, 2 replies.
- Re: [PR] [IcebergIO] Support hash distribution mode when writing rows [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/01 13:13:18 UTC, 6 replies.
- Re: [I] The PreCommit Python job is flaky [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/01 13:30:05 UTC, 4 replies.
- Re: [I] [Bug]: AddFilesIT leaks pubsub topic [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/01 13:37:40 UTC, 1 replies.
- [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] - posted by "arr2036 (via GitHub)" <gi...@apache.org> on 2026/05/01 13:57:21 UTC, 16 replies.
- Re: [PR] Move Python PreCommit middle versions to PostCommit [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 14:10:22 UTC, 3 replies.
- Re: [PR] Fix SDF bundle finalization timeout in streaming test [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/01 14:22:12 UTC, 4 replies.
- Re: [PR] Fix Playground CI Nightly job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 14:22:44 UTC, 4 replies.
- Re: [PR] Bump google.golang.org/api from 0.257.0 to 0.269.0 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/01 14:38:01 UTC, 0 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.72.0 to 1.73.1 in /sdks [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/01 14:38:21 UTC, 0 replies.
- Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 14:54:58 UTC, 8 replies.
- Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:12:26 UTC, 2 replies.
- Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:17:26 UTC, 3 replies.
- Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:18:11 UTC, 1 replies.
- Re: [PR] Add primitive read translators [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:18:50 UTC, 0 replies.
- Re: [PR] Update triggering frequency documentation for Storage API methods [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:19:29 UTC, 1 replies.
- Re: [PR] Report source lineage from HadoopFormatIO [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:20:37 UTC, 5 replies.
- Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:21:37 UTC, 0 replies.
- Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:22:31 UTC, 1 replies.
- Re: [PR] [Go SDK] Rewrite dot runner to generate DOT from portable pipeline proto [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:24:41 UTC, 0 replies.
- Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:25:17 UTC, 1 replies.
- Re: [PR] Omit state commits in stateful Dofn [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:25:48 UTC, 0 replies.
- Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:26:17 UTC, 4 replies.
- Re: [PR] Add Python example for slowly updating global window side input pattern [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:27:02 UTC, 1 replies.
- Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:30:39 UTC, 1 replies.
- Re: [PR] fix: correct typo "occured" to "occurred" in data_sampler.py [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:32:42 UTC, 0 replies.
- Re: [PR] Remove incorrect type hint. [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:36:36 UTC, 6 replies.
- Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/01 15:36:47 UTC, 3 replies.
- Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2026/05/01 15:38:40 UTC, 0 replies.
- Re: [I] [Bug]: Unhandled exception in KafkaIO SDF [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2026/05/01 15:38:42 UTC, 0 replies.
- Re: [PR] [wip] - js2py to mini-racer [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/01 16:18:47 UTC, 7 replies.
- [PR] Add pipeline hash [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/05/01 17:35:28 UTC, 9 replies.
- [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/01 18:09:25 UTC, 6 replies.
- Re: [PR] fix(python): Register all output pcollections of a transform rather than only ones that happened to be accessed in DoOutputsTuple [beam] - posted by "hjtran (via GitHub)" <gi...@apache.org> on 2026/05/01 19:16:58 UTC, 1 replies.
- Re: [I] The Playground CI Nightly job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 19:49:02 UTC, 9 replies.
- [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/01 19:51:54 UTC, 3 replies.
- [PR] Remove unused variable [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/01 19:53:21 UTC, 4 replies.
- [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] - posted by "johnjcasey (via GitHub)" <gi...@apache.org> on 2026/05/01 20:00:03 UTC, 5 replies.
- Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/05/01 20:27:43 UTC, 18 replies.
- Re: [PR] Adds a new coder translator for Java SchemaCoder. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/05/01 21:15:20 UTC, 5 replies.
- Re: [PR] Bump Java bytecode compatibility version to Java11 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/01 21:52:37 UTC, 0 replies.
- Re: [I] [Task]: Deprecate Java8 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/01 21:52:39 UTC, 0 replies.
- Re: [PR] Optimze away WindmillWatermarkHold::clear when the cached hold is empty [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/02 00:02:10 UTC, 3 replies.
- Re: [PR] Use trigger state to know if a window is new and optimize reads [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/02 00:06:20 UTC, 13 replies.
- Re: [PR] Add more logging into boot.go to facilitate future triaging [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/02 01:11:26 UTC, 1 replies.
- Re: [PR] Improve logging in boot.go to facilitate future triaging [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/05/02 01:48:08 UTC, 4 replies.
- Re: [I] The PreCommit Python Transforms job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/02 08:12:38 UTC, 4 replies.
- Re: [PR] Update go version. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 12:48:57 UTC, 2 replies.
- Re: [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 12:49:04 UTC, 1 replies.
- Re: [I] [prism] Processing Time handling (TestStream, Timers, ProcessContinuations) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 12:49:08 UTC, 1 replies.
- Re: [I] [Bug]: BigQueryIO Write does not work using Storage_write_api on DataflowRunner with unbounded data and autosharding [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 12:49:12 UTC, 1 replies.
- Re: [I] [Failing Test]: GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer stuck [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 12:49:16 UTC, 1 replies.
- [PR] add datadog io normalization and yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/02 18:18:27 UTC, 41 replies.
- [I] The PostCommit Go Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 21:47:23 UTC, 6 replies.
- [I] The PostCommit Go job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 04:46:35 UTC, 9 replies.
- Re: [PR] [Java SDK] Infer Beam logical types for JSR-310 and UUID fields [beam] - posted by "sachinnn99 (via GitHub)" <gi...@apache.org> on 2026/05/03 06:57:52 UTC, 6 replies.
- [PR] Side Input fixes [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/05/03 08:50:09 UTC, 6 replies.
- [PR] testing poc [beam] - posted by "flamedante (via GitHub)" <gi...@apache.org> on 2026/05/03 10:49:27 UTC, 5 replies.
- Re: [PR] SolaceIO - add ack deadline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 12:48:53 UTC, 3 replies.
- Re: [I] [Failing Test]: A few failed tests for TestStream with keyed elements [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 12:48:57 UTC, 0 replies.
- Re: [I] [Bug]: Unable to use @FieldAccess in DoFn for fetching Nullable Schema Fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 12:48:59 UTC, 1 replies.
- Re: [I] [Bug]: Go pipline on Dataflow throws "java.lang.NoClassDefFoundError: org/apache/beam/vendor/grpc/v1p54p0/io/grpc/Channel" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 12:49:03 UTC, 1 replies.
- Re: [I] [Failing Test]: Dataflow V2 VR Streaming Flakiness due to timeout close worker pool [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 12:49:10 UTC, 0 replies.
- Re: [PR] Side Input improvements [beam] - posted by "reuvenlax (via GitHub)" <gi...@apache.org> on 2026/05/04 06:43:37 UTC, 12 replies.
- Re: [I] [Feature Request]: Expose pvalue.Row in core.py rather than pvalue.py [beam] - posted by "HarshYadav1159 (via GitHub)" <gi...@apache.org> on 2026/05/04 07:49:37 UTC, 1 replies.
- Re: [I] Add Kafka Streams runner [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/04 07:52:02 UTC, 0 replies.
- Re: [I] DoFn.process should raise exception if something other than a List is returned [beam] - posted by "chrisqiqiu (via GitHub)" <gi...@apache.org> on 2026/05/04 09:21:07 UTC, 0 replies.
- Re: [PR] [ValueKind] Add to model [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/04 11:44:53 UTC, 2 replies.
- Re: [I] [Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0 [beam] - posted by "aprochko (via GitHub)" <gi...@apache.org> on 2026/05/04 12:06:52 UTC, 1 replies.
- [PR] Run workflows on ubuntu-24.04 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/04 12:19:42 UTC, 3 replies.
- Re: [PR] feat(ml): add qdrant ingestion [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 12:50:23 UTC, 16 replies.
- Re: [PR] [yaml] - add Reshuffle transform and a test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 12:50:30 UTC, 1 replies.
- Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 12:50:33 UTC, 2 replies.
- Re: [PR] [Bug] Fix PubsubUnboundedSink not following 1000 messages per batch limit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 12:50:42 UTC, 3 replies.
- Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:33 UTC, 2 replies.
- Re: [I] [Feature Request]: BQ: Allow map values to be nullable in GCP SDK BigQueryIO [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:39 UTC, 0 replies.
- Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:41 UTC, 2 replies.
- Re: [PR] [3/3] sdks/python: sink data with Milvus Search I/O connector [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:43 UTC, 0 replies.
- Re: [I] [Feature Request]: Request to use BASIC enum when calling tables.get() in BigQuery [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:45 UTC, 0 replies.
- Re: [I] [Bug]: Fix ParquetIO.Read/Parse(Files) where ParquetFileReader has row groups of zero rows [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:48 UTC, 1 replies.
- Re: [I] [Feature Request]: Modify ParquetIO.Read/Parse(Files) to use additional outputs pattern with a deadletter PCollection [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:52 UTC, 1 replies.
- Re: [I] [Bug]: ElasticsearchIO should use RetryPolicy in case of connectivity issues [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:03:56 UTC, 1 replies.
- Re: [I] [Bug]: typescript SDK - DirectRunner - readFromPubSub does not work [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 13:04:00 UTC, 1 replies.
- Re: [PR] [runners-spark] Use robust constructor resolution in EncoderFactory [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/04 14:04:44 UTC, 0 replies.
- Re: [I] [Feature Request]: Make Reshuffle transform available to Beam YAML [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/05/04 14:07:10 UTC, 0 replies.
- [PR] remove processContext usage across examples (java and kotlin) [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/04 14:38:34 UTC, 10 replies.
- Re: [I] [Bug]: Building wheels failing on self hosted actions, working on github's runners [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/04 15:30:04 UTC, 0 replies.
- Re: [PR] Upgrade github action versions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/04 16:13:01 UTC, 4 replies.
- Re: [I] Beam Connector for Reading Data from Delta Lake [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/04 16:24:37 UTC, 1 replies.
- Re: [PR] Implemented MLTransform generate vocab Dataflow benchmark [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/04 16:29:50 UTC, 22 replies.
- Re: [PR] Adds backlog reporting support for non-fnapi based SDF's. [beam] - posted by "acrites (via GitHub)" <gi...@apache.org> on 2026/05/04 17:27:59 UTC, 14 replies.
- Re: [PR] Allow apache-beam[gcp] to resolve with google-cloud-storage 3.x [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/04 17:53:18 UTC, 2 replies.
- Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/04 18:15:19 UTC, 2 replies.
- Re: [PR] Add option to use asyncio for AsyncWrapper [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/04 18:38:54 UTC, 0 replies.
- Re: [PR] [Drain] Support extensible element metadata propagation in ReduceFnRunner [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/04 19:00:36 UTC, 13 replies.
- [PR] yaml_transform_test - add some debug logs and increase row count [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/04 19:47:03 UTC, 5 replies.
- Re: [I] [Bug]: JavaFieldSchema does not support for Beam Logical Types [beam] - posted by "barunkumaracharya (via GitHub)" <gi...@apache.org> on 2026/05/04 19:50:54 UTC, 1 replies.
- Re: [I] [Task]: Update stale python sdk google-cloud-storage dependency [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/04 21:29:07 UTC, 0 replies.
- [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] - posted by "bambadiouf1 (via GitHub)" <gi...@apache.org> on 2026/05/05 00:03:19 UTC, 15 replies.
- Re: [PR] [yaml] - Add huggingface model handler [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/05 01:06:56 UTC, 19 replies.
- [PR] BatchElements transform for Java SDK [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/05/05 02:56:41 UTC, 17 replies.
- Re: [PR] [WIP] BatchElements Transform for Java SDK [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/05/05 03:05:18 UTC, 1 replies.
- Re: [PR] [Java IO] Add ArrowFlight IO connector [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/05/05 09:05:10 UTC, 4 replies.
- Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] - posted by "bvolpato (via GitHub)" <gi...@apache.org> on 2026/05/05 09:36:20 UTC, 5 replies.
- [PR] [Iceberg] Add autosharding to yaml [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/05 11:36:02 UTC, 5 replies.
- Re: [I] [Feature Request]: Propagate drain mode up to reduceFn [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/05 12:38:21 UTC, 0 replies.
- Re: [I] [Bug]: Iceberg managed connector upgrade failed in GCP Dataflow [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 12:55:17 UTC, 0 replies.
- Re: [I] [Task]: Enable outputting scalars instead of numpy arrays using a parameter in MLTransform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 12:55:19 UTC, 1 replies.
- Re: [I] [Task]: validate timestamps / windowing metadata in FnApiDoFnRunner [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 12:55:32 UTC, 0 replies.
- Re: [I] [Failing Test]: JavaUsingPython postcommit tests are failing [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 12:55:33 UTC, 0 replies.
- [PR] [ErrorProne ] fix violation in ValueInSingleWindow [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/05 14:04:18 UTC, 3 replies.
- Re: [PR] Introduce ValueKind to Java and add to WindowedValue [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/05 14:23:28 UTC, 9 replies.
- Re: [PR] Go VR Flink test on Flink 2.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/05 14:48:04 UTC, 1 replies.
- [I] The PreCommit Java IOs Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 16:07:38 UTC, 6 replies.
- [PR] MongoDB IO write connector for Beam YAML [beam] - posted by "arnavarora2004 (via GitHub)" <gi...@apache.org> on 2026/05/05 16:16:17 UTC, 2 replies.
- Re: [I] The PostCommit Java Dataflow V1 job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/05 16:34:53 UTC, 4 replies.
- Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/05 17:04:20 UTC, 5 replies.
- Re: [PR] GCS client library migration in Java SDK - part 3 [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/05 17:57:40 UTC, 15 replies.
- Re: [PR] Stabilize StorageApiDataTriggeredSchemaUpdateIT assertion [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 18:02:07 UTC, 3 replies.
- [PR] Upgrade to Avro 1.12 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/05 19:08:42 UTC, 6 replies.
- Re: [PR] SQL DDL documentation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/05 19:12:35 UTC, 6 replies.
- Re: [PR] Bump org.jetbrains.kotlin.jvm from 1.7.20 to 1.8.22 [beam-starter-kotlin] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2026/05/05 21:16:20 UTC, 0 replies.
- Re: [PR] Bump beamVersion from 2.42.0 to 2.48.0 [beam-starter-kotlin] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2026/05/05 21:16:39 UTC, 0 replies.
- [PR] fix: update deps for Gradle 9 compat, add Gradle wrapper [beam-starter-kotlin] - posted by "brucearctor (via GitHub)" <gi...@apache.org> on 2026/05/05 22:34:10 UTC, 3 replies.
- Re: [PR] Move GetExperiments to a common place for other boot.go [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/05/05 22:45:49 UTC, 0 replies.
- [PR] Pin tensor_rt digest for PyTorch sentiment Dataflow benchmarks [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/05 23:10:53 UTC, 10 replies.
- [PR] Added Portable Runner Passing for Python Runners [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/05/06 01:14:23 UTC, 2 replies.
- Re: [PR] [Dataflow] Added Portable Runner Passing for Python/Go Runners [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 03:15:09 UTC, 0 replies.
- Re: [PR] [runners-spark] Add Spark 4 runner [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/05/06 12:02:09 UTC, 10 replies.
- [PR] [yaml] - mongodb write normalization [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/06 12:41:19 UTC, 23 replies.
- Re: [PR] Make Beartype use the default behavior in is_consistent_with() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:53:50 UTC, 2 replies.
- Re: [PR] Fix non-unique job names in TextIOReadTest [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:53:52 UTC, 4 replies.
- Re: [PR] [Go SDK] Add GroupIntoBatches transform (#19868) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:53:54 UTC, 6 replies.
- Re: [PR] Bump minimatch in /scripts/ci/pr-bot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:53:57 UTC, 1 replies.
- Re: [PR] RedisIO support PCollection of [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:53:59 UTC, 4 replies.
- Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:00 UTC, 5 replies.
- Re: [PR] feat(io): Implement parallel reading in SparkReceiverIO (Fixes #37410) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:02 UTC, 3 replies.
- Re: [PR] support generics in from row and to row conversions [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:04 UTC, 4 replies.
- Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:05 UTC, 4 replies.
- Re: [PR] Added flag for overriding artifact hostname [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:07 UTC, 5 replies.
- Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 12:54:10 UTC, 4 replies.
- Re: [PR] Fix trigger example write append [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:28 UTC, 2 replies.
- [PR] Bump pip from 26.0.1 to 26.1 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:33 UTC, 4 replies.
- Re: [PR] [WIP] Add vllm Dynamo support [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:33 UTC, 1 replies.
- Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:37 UTC, 1 replies.
- Re: [I] Tutorials issue [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:42 UTC, 1 replies.
- Re: [I] [Feature Request]: Differentiate between batchSize and minBatchSize in JDBCIO Write [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:44 UTC, 1 replies.
- Re: [I] [Bug]: Type specification for generate_user_type_from_bq_schema has not been updated after adding selected_fields [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:46 UTC, 1 replies.
- Re: [I] [Feature Request]: Generalize reading arbitrary types from files. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 13:06:58 UTC, 0 replies.
- [PR] update exclued path to relative path [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/06 13:43:43 UTC, 3 replies.
- Re: [I] The IcebergIO Managed Integration Tests on Dataflow job is flaky [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/06 14:59:28 UTC, 8 replies.
- Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/06 15:50:45 UTC, 0 replies.
- [PR] Bump pip from 26.0.1 to 26.1 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 15:54:33 UTC, 4 replies.
- [PR] Fix WindowedValue.of() invocation. [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/06 17:23:49 UTC, 2 replies.
- Re: [I] YAML Test CLI flag mismatch [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/06 18:09:52 UTC, 0 replies.
- Re: [PR] Use canonical --tests flag in YAML main test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/06 18:10:41 UTC, 1 replies.
- [PR] Fix FHIR search method signature mismatch after google.golang.org/api [beam] - posted by "bambadiouf1 (via GitHub)" <gi...@apache.org> on 2026/05/06 19:13:48 UTC, 4 replies.
- [PR] [IcebergIO]: Compaction using sort-aware binpack planning [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/06 19:29:22 UTC, 0 replies.
- Re: [PR] Consolidate linting and type checking configs into pyproject.toml [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:06:12 UTC, 1 replies.
- [PR] Bump actions/checkout from 3 to 6 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:12:54 UTC, 0 replies.
- [PR] Bump actions/setup-java from 3 to 5 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:13:00 UTC, 0 replies.
- [PR] Bump beamVersion from 2.48.0 to 2.73.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:13:07 UTC, 2 replies.
- [PR] Bump org.hamcrest:hamcrest from 2.2 to 3.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:13:10 UTC, 0 replies.
- [PR] Bump org.jetbrains.kotlin.jvm from 1.8.22 to 2.3.21 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 20:14:26 UTC, 0 replies.
- [PR] add yaml agent development skill [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/06 20:36:33 UTC, 8 replies.
- Re: [I] [Bug]: Go Validates Runner tests failing under Flink 2.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/06 20:59:39 UTC, 0 replies.
- [PR] Bump github.com/apache/thrift from 0.21.0 to 0.23.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 21:14:16 UTC, 3 replies.
- Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/05/06 23:00:57 UTC, 0 replies.
- Re: [PR] update excluded path to relative path [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/05/07 01:05:40 UTC, 2 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:06:51 UTC, 5 replies.
- [PR] Bump cloud.google.com/go/bigquery from 1.74.0 to 1.77.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:07:29 UTC, 2 replies.
- Re: [PR] Bump cloud.google.com/go/bigquery from 1.72.0 to 1.76.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:07:31 UTC, 1 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.5.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:07:49 UTC, 5 replies.
- [PR] Bump crazy-max/ghaction-import-gpg from 6.3.0 to 7.0.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:00 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:06 UTC, 5 replies.
- [PR] Bump hashicorp/setup-terraform from 3 to 4 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:08 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.4.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:10 UTC, 5 replies.
- [PR] Bump docker/build-push-action from 7.0.0 to 7.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:16 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/datastore from 1.22.0 to 1.23.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:22 UTC, 3 replies.
- Re: [PR] Bump cloud.google.com/go/datastore from 1.21.0 to 1.23.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:08:25 UTC, 1 replies.
- [PR] Bump actions/checkout from 4 to 6 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:09:59 UTC, 5 replies.
- [PR] Bump docker/login-action from 4.0.0 to 4.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:10:04 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.276.0 to 0.278.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:10:13 UTC, 2 replies.
- Re: [PR] Bump google.golang.org/api from 0.257.0 to 0.277.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:10:16 UTC, 1 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.42.0 to 1.47.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:12:21 UTC, 1 replies.
- Re: [PR] Bump cloud.google.com/go/bigtable from 1.41.0 to 1.46.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 01:12:23 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.12.6 to 2.14.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:39:45 UTC, 2 replies.
- [PR] Bump github.com/lib/pq from 1.11.1 to 1.12.3 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:39:50 UTC, 2 replies.
- [PR] Bump google.golang.org/grpc from 1.80.0 to 1.81.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:39:56 UTC, 2 replies.
- [PR] Bump actions/upload-artifact from 4 to 7 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:40:55 UTC, 6 replies.
- [PR] Bump actions/download-artifact from 7 to 8 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:41:03 UTC, 2 replies.
- [PR] Bump actions/github-script from 8 to 9 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:41:10 UTC, 2 replies.
- Re: [I] [Feature Request]: [IcebergIO] Fetch a fresh spec periodically in hash distribution [beam] - posted by "AtharvUrunkar (via GitHub)" <gi...@apache.org> on 2026/05/07 06:09:04 UTC, 1 replies.
- [I] [Task]: [Go][Prism] Resolve TODO: Optimize watermark reads in stageState using min-heap [beam] - posted by "Mathdee (via GitHub)" <gi...@apache.org> on 2026/05/07 07:23:49 UTC, 2 replies.
- Re: [I] [Feature Request]: Add the ability to cancel timers in methods annotated with @onWindowExpiration [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/07 12:12:43 UTC, 1 replies.
- Re: [PR] introduce private method to remove clones [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 12:53:34 UTC, 3 replies.
- Re: [PR] ML pipelines: RunInference - OSS Image Object detection, OSS Image Captioning, OSS Image Classification [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/07 12:53:35 UTC, 22 replies.
- Re: [I] [Failing Test]: BeamFnDataInboundObserverTest flaky "Inbound observer closed" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 13:08:25 UTC, 1 replies.
- Re: [I] [Task]: Implement Cache metrics [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 13:08:27 UTC, 1 replies.
- Re: [I] [Bug] [BQ Streaming Inserts]: Whole number in float field is treated like an int [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 13:08:44 UTC, 0 replies.
- Re: [I] [Task]: Fix hugging face ModelHandler top level imports [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 13:08:46 UTC, 0 replies.
- Re: [I] [Bug]: Python BQ directrunner postcommits flake with KeyError: '__pyx_vtable__' [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 13:08:48 UTC, 0 replies.
- [PR] Implement MLTransform One-Hot Encoding benchmark pipeline [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/07 14:16:00 UTC, 20 replies.
- [PR] Mitigate test broken after Avro Upgrade due to AVRO-4110 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/07 15:09:40 UTC, 5 replies.
- Re: [PR] Rename run_pylint.sh [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 15:21:54 UTC, 2 replies.
- [PR] Implement high-performance sorted writing support in IcebergIO [beam] - posted by "atognolag (via GitHub)" <gi...@apache.org> on 2026/05/07 15:33:15 UTC, 13 replies.
- [PR] Minimal change to push back to dofn generating output if the sdk is producing faster than runner is consuming. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/05/07 16:22:19 UTC, 5 replies.
- [PR] Refresh Iceberg partition specs periodically [beam] - posted by "AtharvUrunkar (via GitHub)" <gi...@apache.org> on 2026/05/07 17:21:00 UTC, 6 replies.
- [I] [Bug]: [IcebergIO] Use RecordWriterManager for Partitioned writes [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/07 18:13:17 UTC, 0 replies.
- Re: [PR] Migrate to Google Cloud Dataflow Client [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/05/07 18:27:38 UTC, 16 replies.
- Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/07 19:30:57 UTC, 0 replies.
- [PR] Fix empty stream name encountered in StorageApiFinalizeWrtiesDoFn [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/07 19:37:08 UTC, 14 replies.
- [PR] [Dataflow] Added Portable Runner alias to java runners [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/05/07 21:40:39 UTC, 13 replies.
- [I] The PostCommit Java ValidatesRunner Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 21:50:07 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 2026/05/07 22:40:57 UTC, 0 replies.
- [I] The Go tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:34:08 UTC, 3 replies.
- [PR] Bump github.com/go-sql-driver/mysql from 1.9.3 to 1.10.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:39:00 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/storage from 1.62.0 to 1.62.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:39:18 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/pubsub from 1.50.1 to 1.50.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:39:31 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.5 to 1.41.7 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:40:51 UTC, 3 replies.
- Re: [I] [Bug]: pytest retry configuration is not effective [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:00 UTC, 0 replies.
- Re: [I] [Feature Request]: Specify output_type in ReadFromBigQuery Beam YAML transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:02 UTC, 0 replies.
- Re: [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:08 UTC, 0 replies.
- Re: [I] [Feature Request]: Adding artifact staging endpoint [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:10 UTC, 1 replies.
- Re: [I] [Task]: Add an integration test to detect memory leaks. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:12 UTC, 1 replies.
- Re: [I] [Feature Request]: External transforms should be able to ignore optional params of unknown type. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:13 UTC, 1 replies.
- Re: [I] [Task]: Support Vertex AI model garden for Vertex AI embeddings [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 12:57:15 UTC, 1 replies.
- Re: [PR] [Python] Python] Bound the memory used for fnapi outbound data messages and receiving messages. [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 14:12:38 UTC, 24 replies.
- [PR] fix rrio teardown executor cleanup path [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/08 16:17:35 UTC, 4 replies.
- [PR] Fix PostCommit Java ValidatesRunner Flink job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/08 17:08:40 UTC, 3 replies.
- [I] [Task]: Upgrade gcs-connector libraries to 3.x [beam] - posted by "clairemcginty (via GitHub)" <gi...@apache.org> on 2026/05/08 18:29:24 UTC, 1 replies.
- [PR] Upgrade gcsio to 3.1.16 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/08 18:59:22 UTC, 7 replies.
- [PR] Reapply "Bump com.pswidersk.terraform-plugin from 1.0.0 to 1.1.1"" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/08 19:01:27 UTC, 0 replies.
- Re: [PR] Reapply "Bump com.pswidersk.terraform-plugin from 1.0.0 to 1.1.1" [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 19:03:48 UTC, 2 replies.
- [PR] Revert "[yaml] - Add huggingface model handler" [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/08 19:05:43 UTC, 3 replies.
- [PR] Throttle reads on data channel when writes on output channel are backpressured. [beam] - posted by "tvalentyn (via GitHub)" <gi...@apache.org> on 2026/05/08 19:33:04 UTC, 4 replies.
- [PR] Fix race conditions, error recovery, and exit handlers in job servers [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/08 19:58:33 UTC, 10 replies.
- [PR] Bump gradle-wrapper from 8.12 to 9.5.0 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 20:14:34 UTC, 2 replies.
- Re: [PR] [Dataflow] Added Portable Runner Parsing for Python/Go Runners [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/05/08 21:44:33 UTC, 14 replies.
- [I] The PreCommit YAML Xlang Direct job is perma-red [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 21:50:35 UTC, 6 replies.
- [PR] Disable public ip for Dataflow Validates Runner test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/08 22:00:27 UTC, 0 replies.
- [PR] Fix truncating file handle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/09 02:45:17 UTC, 7 replies.
- [PR] Fix flaky BigQuery file loads by safely handling concurrent mkdirs [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/09 03:04:57 UTC, 3 replies.
- [PR] Fix deadlock in AsyncWrapper thread pool shutdown [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/09 04:47:03 UTC, 5 replies.
- Re: [PR] Add portable Mqtt source and sink transforms [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/05/09 06:39:44 UTC, 1 replies.
- Re: [PR] [#38059] Fix GCS glob matching to support ** and / in object names [beam] - posted by "hilaryRope (via GitHub)" <gi...@apache.org> on 2026/05/09 10:48:26 UTC, 3 replies.
- Re: [I] [Task]: Polish Beam SQL user experience [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 12:49:36 UTC, 0 replies.
- Re: [I] [Bug]: WriteToParquet exhibits different behavior when using return versus yield [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 12:49:48 UTC, 0 replies.
- Re: [I] [Bug]: Error occurs when assigning an interface to a field of a struct used for emitting in Go SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 12:49:51 UTC, 0 replies.
- Re: [I] [Bug]: Error reading from BigQueryIO.readTableRowsWithSchema() when query contains an array of structs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 12:49:51 UTC, 0 replies.
- [I] The PreCommit Java PVR Prism Loopback job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 18:50:02 UTC, 7 replies.
- [PR] Fix dataframe warnings on ChainedAssignmentError [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/09 21:28:08 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner ULR job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 04:48:13 UTC, 21 replies.
- [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] - posted by "chrisqiqiu (via GitHub)" <gi...@apache.org> on 2026/05/10 09:41:01 UTC, 17 replies.
- [PR] [Dataflow Streaming] Add Operation::finishKey() and move processTimers into it [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/10 10:26:36 UTC, 14 replies.
- Re: [I] [Feature Request]: Introduce a merged environment type [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:44 UTC, 1 replies.
- Re: [I] [RRIO]: PubsubIO.FixedRateRead pulls from Pub/Sub at a fixed rate [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:45 UTC, 1 replies.
- Re: [I] [RRIO]: Add retryAfter field to UserCodeQuotaException [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:47 UTC, 1 replies.
- Re: [I] [Task]: Set beam schema proto field in user_type in typehint/schemas.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:48 UTC, 1 replies.
- Re: [I] [Task]: Create MLTransform notebooks for each transform [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:50 UTC, 1 replies.
- Re: [I] [Task]: Improve the MLTransform preprocessing page [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:49:59 UTC, 0 replies.
- Re: [I] [Bug]: WriteToFiles in python leave few records in temp directory when writing to large number (100+) of files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:50:00 UTC, 0 replies.
- Re: [I] [Bug]: :beam_CleanUpPrebuiltSDKImages :beam-test-tools:removeStaleSDKContainerImages FAILED [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 12:50:02 UTC, 0 replies.
- [I] The PostRelease Nightly Snapshot job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 18:50:12 UTC, 3 replies.
- [PR] Fix PreCommit Java PVR Prism workflow [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/11 01:17:54 UTC, 4 replies.
- Re: [PR] Fix PreCommit Java PVR Prism Loopback workflow [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/11 01:34:01 UTC, 1 replies.
- [PR] Attempt to fix deadline exceeded in Python test workflows [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/11 04:03:03 UTC, 1 replies.
- [PR] Bump github.com/testcontainers/testcontainers-go from 0.40.0 to 0.42.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 05:01:05 UTC, 4 replies.
- [PR] Bump cloud.google.com/go/spanner from 1.88.0 to 1.91.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 05:01:21 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.43.0 to 0.44.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 05:01:25 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/profiler from 0.4.3 to 0.6.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 05:01:35 UTC, 2 replies.
- [PR] Fix ULR metadata propagation test flake [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/11 10:24:19 UTC, 11 replies.
- [PR] upgrade test containers and fix issues [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/11 12:38:26 UTC, 11 replies.
- Re: [I] [Feature Request]: Make `Neo4jIO.WriteUnwind` output write statistics. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:18 UTC, 1 replies.
- Re: [I] [Feature Request]: Capture pipeline error [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:21 UTC, 1 replies.
- Re: [I] [Bug]: JdbcDriver causes metaspace leak [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:37 UTC, 0 replies.
- Re: [I] [Bug]: The`:sdks:java:javadoc:aggregateJavadoc` task does not work with Java 11 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:39 UTC, 0 replies.
- Re: [I] [Bug]: Beam SDK throws `NoClassDefFoundError` using SparkRunner in Dataproc 2.1 (Java 11) [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:41 UTC, 1 replies.
- Re: [I] [Task]: Remove support for the typing module [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 13:29:43 UTC, 0 replies.
- [PR] update spotless to 8.4 and reformat [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/11 13:52:19 UTC, 0 replies.
- [PR] Reduce number of layers for Beam container images [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/11 14:49:49 UTC, 6 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 16:19:59 UTC, 4 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/ml/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 16:26:02 UTC, 4 replies.
- [I] [Task]: Improve the schema support [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/05/11 16:49:18 UTC, 1 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 17:01:16 UTC, 3 replies.
- Re: [PR] Fix deadlock in AsyncWrapper reset_state() [beam] - posted by "dustin12 (via GitHub)" <gi...@apache.org> on 2026/05/11 17:07:30 UTC, 1 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 17:07:46 UTC, 3 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 17:09:45 UTC, 3 replies.
- Re: [PR] Fix thread leak for LOOPBACK workers in external worker pool [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/11 17:21:27 UTC, 10 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 17:22:11 UTC, 3 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 17:25:08 UTC, 3 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 18:46:06 UTC, 3 replies.
- [PR] Enable multi-release attribute for Spark job server jar [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/11 18:46:22 UTC, 5 replies.
- [PR] [Website] add drain update to docs [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/11 18:47:28 UTC, 4 replies.
- Re: [I] [Feature Request]: Add a Variant type to Beam Schemas [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/11 18:48:16 UTC, 0 replies.
- [PR] huggingface model handler for yaml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/11 19:30:43 UTC, 0 replies.
- [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 20:03:32 UTC, 3 replies.
- [PR] Exercise Spark 4 tests [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/11 20:10:11 UTC, 18 replies.
- [PR] Add DoFnRunner::finishKey() method [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/12 01:39:10 UTC, 9 replies.
- [PR] Make SubprocessServer shared cache purging idempotent [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/12 01:55:53 UTC, 5 replies.
- [PR] Add retry in connecting manager in MultiProcessShared [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/12 02:20:59 UTC, 5 replies.
- [PR] update transform catalogue docs [beam] - posted by "ganesh-skumar (via GitHub)" <gi...@apache.org> on 2026/05/12 07:37:18 UTC, 8 replies.
- [PR] [Dataflow Streaming] Add a job setting to limit value size in windmill state cache [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/12 08:25:12 UTC, 13 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.7 to 1.32.17 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 09:36:18 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.21.1 to 1.22.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 09:37:30 UTC, 4 replies.
- [PR] Bump golang.org/x/net from 0.53.0 to 0.54.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 09:37:35 UTC, 2 replies.
- [PR] Bump github.com/nats-io/nats.go from 1.51.0 to 1.52.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 09:37:41 UTC, 2 replies.
- [I] [GSoC 2026] Kafka Streams Runner — skeleton Gradle module + pipeline entry points [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/12 09:55:31 UTC, 2 replies.
- [I] [Feature Request]: ClickHouseIO: Add DateTime64 support for sub-second timestamp precision [beam] - posted by "BentsiLeviav (via GitHub)" <gi...@apache.org> on 2026/05/12 10:38:33 UTC, 1 replies.
- Re: [PR] huggingface model handler for yaml - retry [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:09:53 UTC, 7 replies.
- Re: [I] [Bug]: Issues while reading from Pubsub emulator and using DirectRunner Golang [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:13:07 UTC, 1 replies.
- Re: [I] [Feature Request]: Time series processing for batch data [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:13:09 UTC, 0 replies.
- Re: [I] [Bug]: DaskRunner GBK is broken, pending upstream fix in dask [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:13:27 UTC, 0 replies.
- Re: [I] [Bug]: Incorrect exception message setting wrong expectations [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:13:29 UTC, 0 replies.
- Re: [I] [Bug]: Dependency Issue with Apache Beam 2.51.0 Upgrade [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 13:13:32 UTC, 0 replies.
- [PR] Bump urllib3 to patched release in Python container requirements [beam] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/12 13:55:20 UTC, 6 replies.
- [PR] Add explicit read-only permissions to CI workflows [beam] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/12 13:59:27 UTC, 6 replies.
- [PR] Fix README typo in website description [beam] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/12 14:10:44 UTC, 3 replies.
- [PR] Expose StorageWriteApiMaxRequestCallbackWaitTimeSec in BQ storage write. [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/05/12 14:52:58 UTC, 12 replies.
- [PR] Bump protobufjs in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 15:15:35 UTC, 6 replies.
- [PR] [Prism] Fix gRPC deadline exceeded errors during bundle failure by passing errgroup context [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/12 16:04:42 UTC, 7 replies.
- [PR] [wip] js2py to quickjs [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/12 17:12:10 UTC, 27 replies.
- [PR] update ruff to pyproject [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/12 17:47:20 UTC, 4 replies.
- [PR] Bump @protobufjs/utf8 from 1.1.0 to 1.1.1 in /sdks/typescript [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 17:57:02 UTC, 2 replies.
- [PR] Add python test to reproduce a failed dofn. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/12 19:49:26 UTC, 1 replies.
- [PR] Make sure session creation happens before starting agent [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/12 20:34:04 UTC, 5 replies.
- [PR] Setup Validates runner tests for Spark4 runner [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/12 20:34:41 UTC, 10 replies.
- [I] The PostCommit XVR Spark3 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 21:56:28 UTC, 6 replies.
- [I] The PostCommit XVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 21:56:30 UTC, 6 replies.
- [I] The PostCommit XVR Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 21:56:34 UTC, 6 replies.
- [PR] Bump gradle-wrapper from 8.12 to 9.5.1 [beam-starter-kotlin] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 23:39:34 UTC, 0 replies.
- [PR] Revert "Refactor StorageAPI BigQuery sink" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/13 03:08:09 UTC, 4 replies.
- Re: [PR] Refactor StorageAPI BigQuery sink [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/13 03:10:46 UTC, 1 replies.
- [PR] Bump google.golang.org/api from 0.278.0 to 0.279.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 04:38:19 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Spark4 StructuredStreaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 04:48:12 UTC, 1 replies.
- [PR] [Dataflow Streaming] Rearrange work scheduling code for multi key bundles [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/13 09:54:43 UTC, 0 replies.
- [PR] cap v2 streaming ValidatesRunner forks [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/13 11:13:16 UTC, 1 replies.
- [PR] WriteToJson - force num_shards [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/13 11:55:18 UTC, 10 replies.
- [PR] increase timeout for jdbc test [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/13 13:07:27 UTC, 6 replies.
- Re: [I] [Feature Request]: Pass in URN information to GCP Runner. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 13:17:10 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Write Support for Azure CosmosDB with Core(SQL) API [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 13:17:12 UTC, 0 replies.
- [I] [Feature Request]: expose Bigtable reader idle timeout config [beam] - posted by "brandtnewton (via GitHub)" <gi...@apache.org> on 2026/05/13 13:59:15 UTC, 3 replies.
- [PR] Revert "upgrade test containers and fix issues" [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/13 14:55:05 UTC, 2 replies.
- [PR] Fix iceberg gcs dependency after gcsio 3.0 upgrade [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/13 16:58:35 UTC, 8 replies.
- [PR] [runners-spark] Spark 4 follow-up: address remaining review comments from #38255 [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/05/13 18:10:14 UTC, 4 replies.
- [PR] Pipe Valuekind through DoFn and output builders [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/13 18:42:56 UTC, 33 replies.
- Re: [PR] [runners-spark] Spark 4 follow-up: Announce in CHANGES.md and address remaining review comments from #38255 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/13 18:44:19 UTC, 3 replies.
- Re: [PR] update port for jdbc test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/13 19:01:15 UTC, 2 replies.
- [PR] cherry-pick #38485 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/13 19:13:38 UTC, 3 replies.
- [PR] Update SpannerIO.java - comment documentation [beam] - posted by "googledrew (via GitHub)" <gi...@apache.org> on 2026/05/13 20:23:07 UTC, 8 replies.
- [PR] [mqtt] Add portable MqttIO Read/Write transforms (revives #32385) [beam] - posted by "tkaymak (via GitHub)" <gi...@apache.org> on 2026/05/13 21:21:38 UTC, 0 replies.
- [PR] Don't emit beam:coder:schema:v1 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/13 21:39:26 UTC, 1 replies.
- [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_10KB_values:runtime [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 22:41:04 UTC, 0 replies.
- [PR] Bump Java dev image for Dataflow [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/14 00:19:22 UTC, 4 replies.
- [PR] Sickbay two failed tests due to new schema coder urn. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/14 01:17:13 UTC, 8 replies.
- [PR] Fix flaky test test_transient_connection_error_recovery [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/14 04:03:40 UTC, 0 replies.
- [I] The IcebergIO Integration Tests on Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 04:47:44 UTC, 7 replies.
- [I] The PostCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 04:47:50 UTC, 7 replies.
- [I] The IcebergIO Integration Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 04:47:53 UTC, 10 replies.
- Re: [PR] Isolate tests in multi_process_shared with unique temp path. [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 05:28:09 UTC, 5 replies.
- [I] The Python tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 07:32:12 UTC, 2 replies.
- [PR] Fix PostCommit Java PVR Spark4 Batch job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/14 08:59:51 UTC, 2 replies.
- Re: [I] [Feature Request]: gRPC connector to Dataproc Metastore [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 13:07:36 UTC, 0 replies.
- Re: [I] [RRIO] [Call] Consider many requests to one API call use cases [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 13:07:37 UTC, 0 replies.
- [PR] [Iceberg] pin hadoop to 3.3.6 [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/14 15:37:48 UTC, 9 replies.
- [PR] Debug sharedcache purge [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/14 18:20:41 UTC, 0 replies.
- [PR] CherryPick: Fix Iceberg hadoopIO dep failure [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/14 19:22:56 UTC, 6 replies.
- [PR] Cherry-pick #38488 and #38500 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/14 19:39:07 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 2026/05/14 21:08:32 UTC, 9 replies.
- [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 21:54:54 UTC, 6 replies.
- [PR] Set torch upper bound to fix ml python test [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/15 03:17:22 UTC, 6 replies.
- [PR] Bump google.golang.org/grpc from 1.81.0 to 1.81.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 04:42:26 UTC, 2 replies.
- [PR] [Cherrypick] Sickbay two failed tests due to new schema coder urn (#38497) [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/15 08:52:09 UTC, 3 replies.
- [PR] [Cherrypick] Set torch upper bound to fix ml python test (#38505) [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/15 10:24:56 UTC, 4 replies.
- Re: [I] [Bug]: Latest.Globally() issues in global window [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 13:08:08 UTC, 0 replies.
- Re: [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 13:08:08 UTC, 0 replies.
- Re: [I] [Task]: Eliminate `ClassLoadingStrategy.Default.INJECTION` throughout Beam Java code base [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 13:08:09 UTC, 0 replies.
- Re: [I] [Feature Request]: Improve Type Hinting of fuctions passed to beam.Map() [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 13:08:11 UTC, 1 replies.
- [PR] Fix Dataflow archetype missing API client dependency [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/15 14:10:23 UTC, 9 replies.
- [PR] ClickHouseIO: Add DateTime64 support for sub-second timestamp precision [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/05/15 14:21:18 UTC, 5 replies.
- Re: [I] WriteToBigQuery in BundleBasedDirectRunner fails when method is FILE_LOADS [beam] - posted by "Wellbek (via GitHub)" <gi...@apache.org> on 2026/05/15 14:48:24 UTC, 2 replies.
- [PR] [Cherrypick] Fix empty stream name encountered in StorageApiFinalizeWrtiesDoFn (#38410) [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/15 14:56:21 UTC, 3 replies.
- [PR] add support for matchall [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/15 15:05:32 UTC, 0 replies.
- [I] [Task]: Support standard portable coder 'beam:coder:schema:v1' in all SDKs [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 15:29:27 UTC, 0 replies.
- [PR] Revert 37631 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 15:43:14 UTC, 1 replies.
- [I] [Task]: Remove hadoop-common pin from expansion service and Iceberg modules [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/15 15:45:08 UTC, 0 replies.
- Re: [PR] Revert #37631 and #38497 in the release branch [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 15:45:16 UTC, 3 replies.
- [PR] Revert #37631 and #38497 on HEAD [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 15:45:27 UTC, 5 replies.
- [PR] Add TODO [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/15 15:47:34 UTC, 5 replies.
- Re: [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] - posted by "stankiewicz (via GitHub)" <gi...@apache.org> on 2026/05/15 15:59:40 UTC, 2 replies.
- [PR] Fix pom involving maven-archetype and opentelemetry [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 18:24:59 UTC, 7 replies.
- Re: [PR] [yaml] add support for matchall [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/15 18:56:46 UTC, 13 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-go] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:04 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-java] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:14 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-kotlin] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:18 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-python] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:27 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-scala] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:31 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-starter-typescript] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:36 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [beam-swift] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 19:00:41 UTC, 0 replies.
- [PR] Revert "Fix Dataflow archetype missing API client dependency" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 21:01:01 UTC, 5 replies.
- [PR] [Release-2.74] Cherry-pick #38518 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/15 21:05:57 UTC, 4 replies.
- [PR] GSoC 2026] Add Kafka Streams runner skeleton module + portable entry points [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/16 10:35:46 UTC, 2 replies.
- Re: [PR] [GSoC 2026] Add Kafka Streams runner skeleton module + portable entry points [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/16 11:49:44 UTC, 4 replies.
- Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/16 12:49:50 UTC, 2 replies.
- [I] The PreCommit Python PVR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/16 18:51:06 UTC, 5 replies.
- Re: [PR] Fix SubprocessServer cache thread-safety and test isolation [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/16 20:34:29 UTC, 10 replies.
- Re: [I] There should be no need to redirect to https, as that is done by the TLP server [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/05/16 23:46:09 UTC, 1 replies.
- [PR] Remove redundant HTTP->HTTPS redirect in .htaccess [beam] - posted by "liferoad (via GitHub)" <gi...@apache.org> on 2026/05/16 23:50:25 UTC, 4 replies.
- [PR] Debug grpc deadline exceed exceptions [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/17 02:37:16 UTC, 1 replies.
- [I] The PostCommit Python ValidatesRunner Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 04:49:58 UTC, 5 replies.
- [I] The PostCommit Python Portable Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 04:50:02 UTC, 5 replies.
- Re: [PR] DRAFT PR for using RateLimiter with Streaming Pipeline [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 12:49:33 UTC, 2 replies.
- Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Java SDK breaking changes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 12:49:41 UTC, 0 replies.
- Re: [I] [Feature Request]: Cache the BigQuery table definition instead of calling tables.get() from every worker [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 12:49:44 UTC, 0 replies.
- Re: [I] [Failing Test]: portable_runner_test in Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 12:49:46 UTC, 1 replies.
- Re: [I] [Task]: Explore use of beam.BatchElements in MLTransform. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 12:49:49 UTC, 1 replies.
- [PR] ix pipeline options NPE after Jackson 2.18 bump [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/17 16:10:58 UTC, 3 replies.
- [PR] Fix PipelineOptions display-data NPE [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/18 07:55:58 UTC, 9 replies.
- Re: [I] The PostCommit Java ValidatesRunner Dataflow V2 Streaming job is flaky [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/18 14:09:07 UTC, 1 replies.
- Re: [PR] Fix pipeline options NPE after Jackson 2.18 bump [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/18 14:30:06 UTC, 2 replies.
- [PR] Fix interactive environment clean up failure at atexit. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/18 15:13:39 UTC, 5 replies.
- [PR] Update managed-io.md for release 2.74.0-RC1 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/18 17:02:01 UTC, 3 replies.
- [I] [Feature Request]: Add a native Logging transform to Java SDK [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/18 18:35:28 UTC, 3 replies.
- [I] [Feature Request]: Implement AsyncDoFn in Java [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/05/18 18:54:20 UTC, 1 replies.
- [PR] Update go dependencies [beam] - posted by "joesantos418 (via GitHub)" <gi...@apache.org> on 2026/05/18 19:14:50 UTC, 9 replies.
- [PR] Fix Pythn Flink PVR [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/18 20:17:26 UTC, 0 replies.
- Re: [PR] Fix Python Flink PVR [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/18 21:32:52 UTC, 6 replies.
- [PR] Updated All Externally Visible Logs/Docs from Runner V2 to Portable Runner [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/05/18 23:31:46 UTC, 11 replies.
- Re: [I] [Feature Request]: Support generic PTransforms in Python SDK [beam] - posted by "mattalbr (via GitHub)" <gi...@apache.org> on 2026/05/19 02:04:19 UTC, 6 replies.
- [PR] feat: Add LogElements transform to Java SDK [beam] - posted by "lalitx17 (via GitHub)" <gi...@apache.org> on 2026/05/19 05:06:08 UTC, 21 replies.
- [PR] [GSoC 2026] Kafka Streams runner skeleton module + portable entry points [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/19 05:54:41 UTC, 8 replies.
- Re: [PR] Fix PipelineOptions deserialization NPE [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/19 11:55:54 UTC, 0 replies.
- Re: [I] SuppressWarnings("serial") for starter and example archetypes [beam] - posted by "SyedAbd110786 (via GitHub)" <gi...@apache.org> on 2026/05/19 12:21:39 UTC, 2 replies.
- [PR] Fix Dataflow V2 Streaming ValidatesRunner CI forks and timeout [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/19 13:21:01 UTC, 1 replies.
- Re: [I] [Failing Test]: `MLTest.test_ml_preprocessing_yaml` is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 13:38:01 UTC, 1 replies.
- [PR] Update Beam website to release 2.74.0 [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/19 13:46:26 UTC, 2 replies.
- [PR] Fix race condition in UserPipelineTracker.clear() [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/19 14:21:37 UTC, 6 replies.
- [PR] Bump cloud.google.com/go/storage from 1.62.1 to 1.62.2 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 16:52:21 UTC, 3 replies.
- [PR] Update Dataflow Proto Python [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/05/19 17:14:11 UTC, 4 replies.
- [PR] Remove Java 8 variant of beam_PostCommit_Java_ValidatesRunner_Dataflow_JavaVersions [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/19 17:30:28 UTC, 4 replies.
- [PR] Update Dataflow Dependency Java [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/05/19 17:34:11 UTC, 6 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/ml/py310 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 18:11:39 UTC, 3 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 18:13:34 UTC, 3 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/py314 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 18:23:12 UTC, 4 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/ml/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 18:26:57 UTC, 3 replies.
- [PR] [yaml] - expand jinja method [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/19 18:30:34 UTC, 11 replies.
- [PR] Support infer types involving dataclass fields [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/19 20:13:25 UTC, 8 replies.
- [I] [Feature Request]: Support for efficient serialization of more built-in types [beam] - posted by "mattalbr (via GitHub)" <gi...@apache.org> on 2026/05/19 20:19:08 UTC, 0 replies.
- Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/19 20:51:36 UTC, 0 replies.
- Re: [PR] Fix race condition in UserPipelineTracker.clear() and various problems [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/20 00:41:41 UTC, 2 replies.
- [I] [Task]: Create the initial repo location [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:49:31 UTC, 1 replies.
- [I] [Task]: Create the initial source with basic read support and BeamParquetHandler [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:50:10 UTC, 0 replies.
- [I] [Task]: Add support for splitting the source [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:50:43 UTC, 0 replies.
- [I] [Task]: Add support for dynamic work rebalancing [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:51:15 UTC, 0 replies.
- [I] [Task]: Implement BeamFileSystemClient [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:51:44 UTC, 0 replies.
- [I] [Task]: Add support for Managed IO (Beam changes) [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:52:12 UTC, 0 replies.
- [I] [Task]: Setup a GCS based delta lake repo for integration testing [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:52:41 UTC, 0 replies.
- [I] [Task]: Add prism-based integration tests [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:53:03 UTC, 0 replies.
- [I] [Task]: [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:53:16 UTC, 0 replies.
- [I] [Task]: Add perf tests [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:53:37 UTC, 4 replies.
- [PR] Initial Delta Lake source prototype [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 00:59:18 UTC, 0 replies.
- [I] [Feature Request]: Define an expansion service jar for Delta Lake [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 02:13:33 UTC, 1 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/ml/py311 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 04:14:34 UTC, 3 replies.
- [PR] Bump google.golang.org/api from 0.279.0 to 0.280.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 09:05:48 UTC, 2 replies.
- [PR] Bump cloud.google.com/go/datastore from 1.23.0 to 1.24.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 09:06:05 UTC, 3 replies.
- [PR] Make sure session creation happens before starting agent (#38477) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 13:12:55 UTC, 4 replies.
- Re: [PR] Update transform catalogue docs [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 13:13:09 UTC, 3 replies.
- [PR] Disable grpc fork support on some test suites. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/20 13:49:02 UTC, 7 replies.
- [PR] Revert "[Java Portable SDK] Configure JVM so that it exits upon OutOfMemoryError originating in JVM." [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/05/20 14:14:11 UTC, 5 replies.
- Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:12:29 UTC, 0 replies.
- Re: [PR] Enable connection pooling by default [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:12:45 UTC, 3 replies.
- Re: [PR] Bump org.codehaus.plexus:plexus-xml from 3.0.2 to 4.1.1 [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:12:54 UTC, 1 replies.
- Re: [PR] Bump protobuf from 4.25.8 to 5.29.6 in /playground/infrastructure [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:13:07 UTC, 1 replies.
- Re: [PR] Bump github.com/fsouza/fake-gcs-server from 1.52.3 to 1.54.0 in /sdks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:13:11 UTC, 1 replies.
- Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:14:41 UTC, 1 replies.
- Re: [PR] add support for bigtable materialized view source [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:18:14 UTC, 0 replies.
- Re: [PR] feat: improve skill scores for apache/beam [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:19:15 UTC, 1 replies.
- Re: [PR] Bump mypy-protobuf from 3.5.0 to 5.1.0 in /sdks/python [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:19:23 UTC, 1 replies.
- Re: [PR] Fix/add experiment refactor [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:21:05 UTC, 3 replies.
- Re: [PR] Fix serial warning in starter and example archetypes [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:21:56 UTC, 1 replies.
- Re: [PR] Improve coder inference in WithKeys to reduce mismatch risks [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/20 15:25:18 UTC, 2 replies.
- Re: [PR] Fix finalize_release job [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/20 15:57:17 UTC, 3 replies.
- Re: [I] [Feature Request]: Add retry logic for transient commit failures in KafkaCommitOffset [beam] - posted by "Shri-Vardhan (via GitHub)" <gi...@apache.org> on 2026/05/20 16:18:38 UTC, 1 replies.
- [PR] update idna dependency to >=3.15 [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/20 16:18:47 UTC, 2 replies.
- Re: [PR] feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API [beam] - posted by "enzomaruffa (via GitHub)" <gi...@apache.org> on 2026/05/20 17:00:05 UTC, 3 replies.
- Re: [PR] [Python] Add type_overrides parameter to BigQuery I/O for custom BigQuery-to-Python type mappings [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/20 18:34:05 UTC, 3 replies.
- Re: [PR] [Prism] Fix DEADLINE_EXCEEDED errors caused by worker failures [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/20 18:35:39 UTC, 13 replies.
- [PR] Fix table row inference benchmark using wrong model path [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/20 21:13:43 UTC, 5 replies.
- [I] The PostCommit Python Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 22:08:08 UTC, 1 replies.
- [PR] Initial skeleton for the Delta Lake source [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/20 23:30:26 UTC, 7 replies.
- [PR] Fix test hang in subprocess expansion service on port bind failure [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/21 02:03:38 UTC, 6 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.5.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:40:56 UTC, 3 replies.
- [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.4.0 to 2.6.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:40:59 UTC, 2 replies.
- [PR] Bump gradle-wrapper from 8.14.3 to 9.5.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:41:47 UTC, 1 replies.
- [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.0 to 2.14.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:41:50 UTC, 2 replies.
- [PR] Bump com.avast.gradle:gradle-docker-compose-plugin from 0.16.12 to 0.17.5 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:42:03 UTC, 2 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.5.1 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 04:42:10 UTC, 3 replies.
- [PR] fix cancelled run handling in workflow prefetcher [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/21 08:13:00 UTC, 5 replies.
- Re: [PR] Avoid cloning from unstable tox/CI venvs [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/21 09:56:54 UTC, 0 replies.
- [PR] [Iceberg] Fix manifest bounds being padded with trailing 0x00 bytes [beam] - posted by "dejii (via GitHub)" <gi...@apache.org> on 2026/05/21 10:29:08 UTC, 9 replies.
- [PR] Fix Fn API data plane deadlock when outbound queue is full [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/21 10:42:47 UTC, 6 replies.
- [PR] [Cherrypick] Configure JVM so that it exits upon OutOfMemoryError originating in JVM (#38567) [beam] - posted by "Amar3tto (via GitHub)" <gi...@apache.org> on 2026/05/21 12:02:55 UTC, 7 replies.
- [PR] Revert gcsio 3 upgrades [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/21 12:57:59 UTC, 3 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/py312 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 13:03:08 UTC, 3 replies.
- Re: [PR] [CP] Make sure session creation happens before starting agent (#38477) [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/21 13:28:38 UTC, 1 replies.
- [PR] Fix flaky MatrixPowerTest.test_basics by reading all generated shards [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/21 13:29:45 UTC, 6 replies.
- Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 13:36:07 UTC, 1 replies.
- Re: [I] Can not publish pubsub message with ordering key [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/21 13:36:15 UTC, 0 replies.
- Re: [PR] Migrate Jupyter Sidepanel extension to pip-based installation [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/05/21 13:59:11 UTC, 0 replies.
- [PR] Attempt to fix recent hiccup of official maven repo [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/21 14:08:26 UTC, 0 replies.
- Re: [PR] Fallback to Google Maven Mirror on Maven Central block/throttle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/21 14:57:44 UTC, 8 replies.
- [I] [Feature Request]: Add metrics tracking for offset commit failures and retry attempts in KafkaCommitOffset [beam] - posted by "Shri-Vardhan (via GitHub)" <gi...@apache.org> on 2026/05/21 15:22:20 UTC, 5 replies.
- [PR] Suppress log spams in gcsio 3.0 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/21 15:32:17 UTC, 12 replies.
- Re: [PR] Enforce Google Maven Mirror on CI environments [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/21 17:05:47 UTC, 5 replies.
- [PR] Fix data_race condition in WindmillStreamSenderTest [beam] - posted by "parveensania (via GitHub)" <gi...@apache.org> on 2026/05/21 18:11:01 UTC, 7 replies.
- [PR] Add support for datetime, date, and frozenset to FastPrimitivesCoder [beam] - posted by "mattalbr (via GitHub)" <gi...@apache.org> on 2026/05/21 19:50:00 UTC, 8 replies.
- [PR] [Dataflow Streaming] Prepare BoundedQueueExecutor for MultiKey bundles [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/22 00:42:33 UTC, 12 replies.
- [PR] [Release-2.74] Cherry-pick #38588 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/22 02:16:18 UTC, 4 replies.
- [PR] Fix flaky tests and silent hangs during SubprocessServer initialization [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/22 03:15:39 UTC, 1 replies.
- [PR] Bump golang.org/x/net from 0.54.0 to 0.55.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 04:41:35 UTC, 2 replies.
- [PR] Bump golang.org/x/sys from 0.44.0 to 0.45.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 04:41:41 UTC, 3 replies.
- [PR] Bump docker/build-push-action from 7.1.0 to 7.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 04:42:11 UTC, 2 replies.
- Re: [I] Create SolaceIO [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2026/05/22 07:45:53 UTC, 0 replies.
- [PR] test: add security PoC test for CI/CD validation [beam] - posted by "4ek0 (via GitHub)" <gi...@apache.org> on 2026/05/22 09:10:35 UTC, 4 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 11:09:12 UTC, 3 replies.
- [PR] Bump idna from 3.11 to 3.15 in /sdks/python/container/ml/py313 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 11:13:12 UTC, 3 replies.
- [PR] Revert "huggingface model handler for yaml - retry" [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/22 12:04:14 UTC, 3 replies.
- [PR] docs: Week-1 design doc for UnboundedSource [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/05/22 12:26:27 UTC, 2 replies.
- Re: [PR] Add hashes for staged files and relevant validations in boot [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 13:19:36 UTC, 2 replies.
- Re: [I] [Feature Request]: PubSubIO read considering OrderingKey [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 13:19:38 UTC, 0 replies.
- [PR] SolaceIO - fix for data loss during scaling/rebalancing (#36991) [beam] - posted by "iht (via GitHub)" <gi...@apache.org> on 2026/05/22 15:29:46 UTC, 21 replies.
- [PR] increase timeout for beam_PreCommit_Yaml_Xlang_Direct.yml [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/22 15:56:35 UTC, 3 replies.
- [PR] Fix golint for tour-of-beam test [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/22 16:04:20 UTC, 4 replies.
- [PR] Revert "Bump golangci/golangci-lint-action from 3 to 8" [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/22 16:30:26 UTC, 4 replies.
- [PR] Configure Docker auth before Java container push in Dataflow V2 strea… [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/22 17:51:24 UTC, 4 replies.
- [PR] Update CHANGES.md after release cut [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/22 20:46:02 UTC, 6 replies.
- Re: [PR] Update managed-io.md for release 2.74.0-RC2 [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/22 21:10:43 UTC, 0 replies.
- [I] The PostCommit TransformService Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 21:53:40 UTC, 1 replies.
- [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] - posted by "tejasiyer-dev (via GitHub)" <gi...@apache.org> on 2026/05/22 22:23:11 UTC, 45 replies.
- [PR] Update Python Dependencies - manual trigger [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 22:57:50 UTC, 8 replies.
- [PR] Fix expansion service timeout [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/23 01:02:06 UTC, 0 replies.
- Re: [PR] Debug grpc errors in tests [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/23 03:42:09 UTC, 0 replies.
- [PR] Refactor shared cache and debug deadline exceeded [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/23 03:50:55 UTC, 1 replies.
- [PR] Add metrics for Kafka offset commit failures [beam] - posted by "Kriti-dev07 (via GitHub)" <gi...@apache.org> on 2026/05/23 07:07:43 UTC, 5 replies.
- [PR] Count cancelled runs in last-5 flaky check [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/23 08:43:41 UTC, 4 replies.
- Re: [PR] Add ValueKind element metadata [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/23 10:14:29 UTC, 0 replies.
- Re: [I] Include logger name in FnApiLogRecordHandler log entries [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/23 12:49:49 UTC, 0 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 2026/05/23 22:30:08 UTC, 0 replies.
- Re: [PR] Fix python expansion service startup timeout [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/24 01:13:41 UTC, 10 replies.
- [I] [GSoC 2026] Kafka Streams Runner — translation framework + Impulse translator [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/24 07:52:29 UTC, 4 replies.
- Re: [PR] Reduce python expansion service startup time [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/24 12:12:54 UTC, 0 replies.
- [PR] Fix flaky test_csv_to_json in Beam YAML SDK [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/24 12:36:35 UTC, 4 replies.
- Re: [PR] Fix loop error. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:22 UTC, 2 replies.
- Re: [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:24 UTC, 1 replies.
- Re: [I] [Bug]: Pass project-id to BigQuery Client in Beam Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:28 UTC, 1 replies.
- Re: [I] [Feature Request]: Add support for pyarrow >= 19.0.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:32 UTC, 1 replies.
- Re: [I] [Bug]: Type hints lost in core transforms [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:36 UTC, 2 replies.
- Re: [I] [Bug]: SparkRunner log plumbing for Python SDK not working properly [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:40 UTC, 1 replies.
- Re: [I] [prism] Programmatic Cancel, and Drain [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 12:50:44 UTC, 1 replies.
- [PR] Try fixing setup-gradle [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/24 13:08:48 UTC, 1 replies.
- [PR] [WIP] Iceberg CDC streaming source [beam] - posted by "ahmedabu98 (via GitHub)" <gi...@apache.org> on 2026/05/24 17:17:02 UTC, 0 replies.
- [PR] Refactor _SharedCache to handle context vs non-context ownership [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/24 19:20:10 UTC, 6 replies.
- [I] [Bug]: IcebergIO write fails with "Null value set on non-nullable field keyMetadata" — @Nullable not detected in SerializableDataFile schema [beam] - posted by "mb0518 (via GitHub)" <gi...@apache.org> on 2026/05/24 21:16:04 UTC, 1 replies.
- [I] The PreCommit Python Integration job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:31 UTC, 1 replies.
- [I] The PreCommit Python Lint job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:35 UTC, 1 replies.
- [I] The Publish Beam SDK Snapshots job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:39 UTC, 2 replies.
- [I] The Cancel Stale Dataflow Jobs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:43 UTC, 1 replies.
- [I] The PreCommit Python Coverage job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:47 UTC, 2 replies.
- [I] The PreCommit Python Docs job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:51 UTC, 1 replies.
- [I] The PreCommit RAT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:27:57 UTC, 1 replies.
- [I] The PreCommit Python Dataframes job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:28:00 UTC, 1 replies.
- [I] The PreCommit Python Formatter job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:28:08 UTC, 0 replies.
- [I] The PreCommit Python Runners job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:28:10 UTC, 1 replies.
- [I] The PreCommit Python Docker job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:28:14 UTC, 2 replies.
- [I] The PreCommit Python Examples job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 01:28:24 UTC, 1 replies.
- [PR] ci: declare workflow-level `contents: read` on go/python/java/typescript test workflows [beam] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/25 03:19:58 UTC, 5 replies.
- [I] The PreCommit Flink Container job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:04:11 UTC, 3 replies.
- [I] The PreCommit Java Amazon-Web-Services2 IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:04:19 UTC, 0 replies.
- [I] The PerformanceTests SingleStoreIO job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:04:21 UTC, 3 replies.
- [PR] Remove blocked setup-gradle action from CI setup [beam] - posted by "NandanPaT-eL (via GitHub)" <gi...@apache.org> on 2026/05/25 05:16:42 UTC, 5 replies.
- [PR] Update cython requirement from <4,>=3.0 to >=3.2.5,<4 in /sdks/python [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:39:50 UTC, 4 replies.
- [PR] Bump docker/login-action from 4.1.0 to 4.2.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:40:55 UTC, 4 replies.
- [PR] Bump docker/setup-buildx-action from 4.0.0 to 4.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:41:07 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.17 to 1.32.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:41:22 UTC, 4 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.18 to 1.22.19 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:42:42 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.16 to 1.19.17 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:43:59 UTC, 4 replies.
- [I] The PreCommit Xlang Generated Transforms job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:30 UTC, 1 replies.
- [I] The PreCommit Prism Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:34 UTC, 1 replies.
- [I] The PreCommit Spotless job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:38 UTC, 2 replies.
- [I] The PreCommit Portable Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:42 UTC, 1 replies.
- [I] The PreCommit Whitespace job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:51 UTC, 0 replies.
- [I] The PreCommit Typescript job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:04:58 UTC, 0 replies.
- [I] The PreCommit SQL Java17 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:00 UTC, 1 replies.
- [I] The PreCommit Java Solace IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:10 UTC, 0 replies.
- [I] The PostCommit Go VR Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:12 UTC, 2 replies.
- [I] The PreCommit SQL job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:16 UTC, 2 replies.
- [I] The PreCommit Python Dill tests with dill deps installed job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:25 UTC, 0 replies.
- [I] The PreCommit Website job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:27 UTC, 1 replies.
- [I] The PreCommit Website Stage GCS job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:32 UTC, 1 replies.
- [I] The PostCommit XVR PythonUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 10:59:59 UTC, 1 replies.
- [I] The PostCommit Java Examples Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:03 UTC, 2 replies.
- [I] The PostCommit Java Jpms Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:12 UTC, 0 replies.
- [I] The PostCommit Java Examples Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:24 UTC, 0 replies.
- [I] The PostCommit Java PVR Spark4 Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:32 UTC, 0 replies.
- [I] The PostCommit Java Nexmark Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:36 UTC, 1 replies.
- [I] The PostCommit PortableJar Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:42 UTC, 2 replies.
- [I] The PostCommit Java Jpms Direct Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:48 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:50 UTC, 1 replies.
- [I] The PostCommit Java Examples Dataflow Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:00:58 UTC, 0 replies.
- [I] The PostCommit Python Dependency job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:00 UTC, 2 replies.
- [I] The PostCommit Go VR Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:06 UTC, 2 replies.
- [I] The PostCommit Java Tpcds Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:13 UTC, 0 replies.
- [I] The PostCommit Java Jpms Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:21 UTC, 0 replies.
- [I] The Publish Website job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:23 UTC, 1 replies.
- [I] The PostCommit Python job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:27 UTC, 4 replies.
- [I] The PostCommit Java Jpms Dataflow Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:35 UTC, 0 replies.
- [I] The PostCommit Python Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:37 UTC, 1 replies.
- [I] The PostCommit Python Xlang IO Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:43 UTC, 1 replies.
- [I] The Community Metrics Prober job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:47 UTC, 2 replies.
- [I] The PostCommit PortableJar Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:01:53 UTC, 1 replies.
- [I] The Python ValidatesContainer Dataflow ARM job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:09 UTC, 1 replies.
- [I] The PostCommit YAML Xlang Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:15 UTC, 2 replies.
- [I] The PostCommit Java Nexmark Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:19 UTC, 0 replies.
- [I] The PostCommit Java InfluxDbIO Integration Test job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:24 UTC, 1 replies.
- [I] The PostCommit Python ValidatesRunner Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:28 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner SparkStructuredStreaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:32 UTC, 1 replies.
- [I] The PostCommit Python Xlang Gcp Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:36 UTC, 2 replies.
- [I] The PostCommit Java Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:40 UTC, 0 replies.
- [I] The PreCommit GHA job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:45 UTC, 0 replies.
- [I] The PostCommit Java Examples Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:02:52 UTC, 0 replies.
- [I] The PostCommit Java BigQueryEarlyRollout job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:00 UTC, 0 replies.
- [I] The PostCommit Javadoc job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:08 UTC, 0 replies.
- [I] The PostCommit Python Examples Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:10 UTC, 3 replies.
- [I] The PostCommit Python ValidatesContainer Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:14 UTC, 1 replies.
- [I] The PostCommit Java Examples Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:21 UTC, 1 replies.
- [I] The PostCommit Java Nexmark Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:25 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 2026/05/25 11:03:29 UTC, 1 replies.
- [I] The PostCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:38 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Spark4 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:48 UTC, 0 replies.
- [I] The PostCommit Java Nexmark Dataflow V2 Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:50 UTC, 1 replies.
- [I] The PostCommit Python Nexmark Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:03:54 UTC, 1 replies.
- [I] The PostCommit Java Tpcds Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:03 UTC, 0 replies.
- [I] The PostCommit Java IO Performance Tests job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:05 UTC, 5 replies.
- [I] The PostCommit Python Examples Spark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:17 UTC, 2 replies.
- [I] The PostCommit Python ValidatesRunner Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:21 UTC, 2 replies.
- [I] The PostCommit Website Test job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:28 UTC, 1 replies.
- [I] The PostCommit XVR GoUsingJava Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:32 UTC, 1 replies.
- [I] The PostCommit Python MongoDBIO IT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:36 UTC, 2 replies.
- [I] The PostCommit Java Nexmark Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:40 UTC, 1 replies.
- [I] The PostCommit Java Avro Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:44 UTC, 2 replies.
- [I] The PostCommit Python Arm job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:50 UTC, 2 replies.
- [I] The PostCommit Java PVR Spark3 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:54 UTC, 2 replies.
- [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:04:58 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Twister2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:02 UTC, 0 replies.
- [I] The PostCommit Java Hadoop Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:04 UTC, 2 replies.
- [I] The PostCommit Java Jpms Flink Java11 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:08 UTC, 1 replies.
- [I] The PostCommit Java ValidatesRunner Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:13 UTC, 0 replies.
- [I] The PostCommit Java Jpms Spark Java11 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:29 UTC, 0 replies.
- [I] The LoadTests Python FnApiRunner Microbenchmark job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:41 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Direct JavaVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:43 UTC, 1 replies.
- [I] The PostCommit Java Nexmark Flink job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:53 UTC, 0 replies.
- [I] The PostCommit Java SingleStoreIO IT job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:05:55 UTC, 2 replies.
- [I] The PostCommit XVR JavaUsingPython Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:02 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 2026/05/25 11:06:10 UTC, 2 replies.
- [I] The PostCommit Java Tpcds Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:15 UTC, 0 replies.
- [I] The PostCommit Java PVR Flink Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:17 UTC, 1 replies.
- [I] The PostCommit Java PVR Spark4 Streaming job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:27 UTC, 0 replies.
- [I] The PostCommit Java Examples Dataflow V2 Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:28 UTC, 1 replies.
- [I] The PostCommit Python Examples Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:34 UTC, 2 replies.
- [I] The PostCommit Java PVR Spark Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 11:06:42 UTC, 2 replies.
- Re: [I] [Bug]: Change reflection-based schema generation to generate deterministic schemas [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:33 UTC, 0 replies.
- Re: [I] [Feature Request]: Golang support/documentation for unbounded DoFns [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:35 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Spanner ChangeStream support to Golang [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:37 UTC, 0 replies.
- Re: [I] [Bug]: sdk-go anonymous dofn function some times not working [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:39 UTC, 0 replies.
- Re: [I] [Task]: Create Colab Notebook for `WriteToFhir` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:41 UTC, 0 replies.
- Re: [I] [YAML] Add documentation to the Beam site. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:43 UTC, 0 replies.
- Re: [I] [Feature Request]: Create a Java/Scala Example in "Getting Started With Apache Spark" [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:45 UTC, 0 replies.
- Re: [I] [Feature Request]: Allow metrics export to `DataflowRunner` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:47 UTC, 0 replies.
- Re: [I] [Feature Request]: Support all collections.abc types [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:49 UTC, 0 replies.
- Re: [I] [Bug]: Codecov Python no longer accurate since Oct 12th missing most files [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:51 UTC, 0 replies.
- Re: [I] [Bug]: Checks added by GHA step attached to irrelevant test [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:53 UTC, 0 replies.
- Re: [I] [Task]: publish test results for GHA Python tests [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:55 UTC, 0 replies.
- Re: [I] [Feature Request]: Request Response IO for Python SDK [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:57 UTC, 0 replies.
- Re: [I] [Feature Request]: Control number of files or size [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:41:59 UTC, 0 replies.
- Re: [I] [Bug]: Non-actionable and spammy " "warnings about GetWorkTimingInfosTracker.java [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:42:01 UTC, 0 replies.
- Re: [I] [Task]: Write artifacts in human readable form generated by MLTransform along with generated TF graph. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:42:02 UTC, 0 replies.
- Re: [I] [Bug]: Cannot use S3 with Cloudflare R2. [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:42:04 UTC, 0 replies.
- [I] The PreCommit Community Metrics job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:18 UTC, 0 replies.
- [I] The PreCommit Java Parquet IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:26 UTC, 0 replies.
- [I] The PreCommit Java Spark Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:33 UTC, 0 replies.
- [I] The IcebergIO Unit Tests job is permared [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:35 UTC, 1 replies.
- [I] The PreCommit Java Examples Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:38 UTC, 1 replies.
- [I] The PreCommit Java Dataflow Non-portable Worker job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:44 UTC, 2 replies.
- [I] The PreCommit Java RabbitMq IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:52 UTC, 0 replies.
- [I] The PreCommit Go job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:43:59 UTC, 0 replies.
- [I] The PreCommit Java ElasticSearch IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:08 UTC, 0 replies.
- [I] The PreCommit Java MongoDb IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:09 UTC, 2 replies.
- [I] The PreCommit Java Kafka IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:16 UTC, 1 replies.
- [I] The PreCommit Java HBase IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:21 UTC, 1 replies.
- [I] The PreCommit Java InfluxDb IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:28 UTC, 1 replies.
- [I] The PreCommit Java Flink Versions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:32 UTC, 0 replies.
- [I] The PreCommit Java Csv IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:38 UTC, 0 replies.
- [I] The PreCommit Java SingleStore IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:45 UTC, 0 replies.
- [I] The PreCommit Java Kudu IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:44:54 UTC, 0 replies.
- [I] The PreCommit Java Datadog IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:02 UTC, 0 replies.
- [I] The PreCommit Java Cassandra IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:10 UTC, 0 replies.
- [I] The PreCommit Java Cdap IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:20 UTC, 0 replies.
- [I] The PreCommit Java PVR Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:22 UTC, 1 replies.
- [I] The PreCommit Java Neo4j IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:29 UTC, 0 replies.
- [I] The PreCommit Java job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:31 UTC, 3 replies.
- [I] The PreCommit Java Splunk IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:41 UTC, 0 replies.
- [I] The PreCommit Integration and Load Test Framework job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:43 UTC, 2 replies.
- [I] The PreCommit Java Clickhouse IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:45:52 UTC, 0 replies.
- [I] The PreCommit Java Thrift IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:04 UTC, 0 replies.
- [I] The PreCommit Java Solr IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:09 UTC, 0 replies.
- [I] The PreCommit Kotlin Examples job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:17 UTC, 0 replies.
- [I] The PreCommit Java JDBC IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:24 UTC, 0 replies.
- [I] The PreCommit Java Tika IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:33 UTC, 0 replies.
- [I] The PreCommit Java Jms IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:35 UTC, 1 replies.
- [I] The PreCommit Java GCP IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:39 UTC, 2 replies.
- [I] The PreCommit Java Azure IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:47 UTC, 0 replies.
- [I] The PreCommit Java Amqp IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:54 UTC, 0 replies.
- [I] The PreCommit Java PVR Flink Docker job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:46:56 UTC, 3 replies.
- [I] The PreCommit GoPortable job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:04 UTC, 3 replies.
- [I] The PreCommit Java Pulsar IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:13 UTC, 0 replies.
- [I] The PreCommit Java Debezium IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:15 UTC, 2 replies.
- [I] The PreCommit Java Mqtt IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:24 UTC, 0 replies.
- [I] The PreCommit Java Examples Dataflow Java21 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:26 UTC, 1 replies.
- [I] The PreCommit Java HCatalog IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:30 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 2026/05/25 13:47:36 UTC, 1 replies.
- [I] The PostCommit Java PVR Flink Batch job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:44 UTC, 0 replies.
- [I] The PreCommit Java Redis IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:48 UTC, 2 replies.
- [I] The PreCommit Java Hadoop IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:55 UTC, 0 replies.
- [I] The PreCommit GoPrism job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:47:57 UTC, 1 replies.
- [I] The PreCommit Java Snowflake IO Direct job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 13:48:06 UTC, 0 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow JavaVersions job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 16:20:20 UTC, 2 replies.
- [I] The PostCommit Java ValidatesRunner Dataflow job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 16:20:24 UTC, 2 replies.
- [I] The PostCommit Java Dataflow V2 job is flaky [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 16:20:27 UTC, 1 replies.
- Re: [PR] Fix WriteToPubSub to pass ordering_key to publish() method [beam] - posted by "codecov[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 18:10:47 UTC, 5 replies.
- [PR] Add fallback platforms for stager [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/26 00:36:33 UTC, 6 replies.
- [PR] [GSoC 2026] Kafka Streams runner — translation framework + Impulse translator [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/26 07:57:19 UTC, 9 replies.
- [PR] pin setup gradle to allowed SHA [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/26 12:07:53 UTC, 2 replies.
- Re: [PR] [SpannerIO] Add low-latency configuration in Spanner Change Streams with Heartbeat changes [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/05/26 13:14:22 UTC, 0 replies.
- Re: [I] [Failing Test]: BigQueryIO and BigTableIO integration test failed in ValidateRunner_GoUsingJava [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/26 13:32:03 UTC, 1 replies.
- [PR] [Cloud Spanner Change Streams] Fix inverted evaluation of cancelQueryOnHeartbeat. [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/05/26 13:32:35 UTC, 8 replies.
- [PR] Test only - hugging face [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/26 13:38:31 UTC, 9 replies.
- Re: [PR] Enforce binary-only constraints during early requirements cache attempts [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/26 14:50:44 UTC, 4 replies.
- Re: [I] [Bug]: Make fileio.MatchAll available to Beam YAML [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/26 16:41:31 UTC, 0 replies.
- [PR] fix race condition in sdb-operator [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/26 17:02:59 UTC, 8 replies.
- Re: [I] [Feature Request]: Add Python 3.14 Support [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/05/26 17:16:32 UTC, 1 replies.
- [PR] Update BEAM_DEV_SDK_CONTAINER_TAG to new version [beam] - posted by "damccorm (via GitHub)" <gi...@apache.org> on 2026/05/26 17:56:59 UTC, 3 replies.
- [PR] Disable build isolation for pip by default. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/26 18:57:55 UTC, 0 replies.
- [PR] Add embedded NVIDIA Dynamo support to vLLM ModelHandler [beam] - posted by "akshayjadiyanv (via GitHub)" <gi...@apache.org> on 2026/05/26 22:28:07 UTC, 8 replies.
- Re: [PR] Disable build isolation for pip by default in boot.go of Python containers [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/26 23:45:07 UTC, 6 replies.
- [PR] [kafka-stream] test CI [beam] - posted by "je-ik (via GitHub)" <gi...@apache.org> on 2026/05/27 06:12:04 UTC, 8 replies.
- [PR] Bump cloud.google.com/go/bigtable from 1.47.0 to 1.48.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 06:17:27 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.280.0 to 0.281.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 06:17:38 UTC, 2 replies.
- [PR] [Dataflow Streaming] Enable state tag encoding v2 [beam] - posted by "arunpandianp (via GitHub)" <gi...@apache.org> on 2026/05/27 07:16:07 UTC, 7 replies.
- [PR] Implements the Delta Lake source with support for splitting [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/27 07:30:48 UTC, 8 replies.
- [I] [Bug]: [Spanner Change Streams] Increased polling frequency for idle change streams causes increased Cloud Spanner load [beam] - posted by "scwhittle (via GitHub)" <gi...@apache.org> on 2026/05/27 11:48:27 UTC, 1 replies.
- Re: [I] [Bug]: Add system/user prefix to getId in StateTable, CachingStateTable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 13:42:52 UTC, 0 replies.
- Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 13:43:01 UTC, 1 replies.
- [I] [Bug]: Beam 2.72.0 claims it is not compatible with flink 2.0 [beam] - posted by "polino-fai (via GitHub)" <gi...@apache.org> on 2026/05/27 15:25:58 UTC, 2 replies.
- [I] [Feature Request]: Add support for Beam Python and YAML [beam] - posted by "chamikaramj (via GitHub)" <gi...@apache.org> on 2026/05/27 16:29:35 UTC, 0 replies.
- [PR] draft workflow [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/27 17:31:15 UTC, 2 replies.
- [PR] Upgrade GCP Libraries BOM to 26.83.0 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 17:55:43 UTC, 1 replies.
- Re: [PR] upgrade gcp bom workflow [beam] - posted by "gemini-code-assist[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 18:16:53 UTC, 6 replies.
- [PR] Disable java prism vr gradle cache and add more logging. [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/27 18:55:53 UTC, 1 replies.
- Re: [I] GCP DataFlow not cleaning up GCP BigQuery temporary datasets [beam] - posted by "aebrahim (via GitHub)" <gi...@apache.org> on 2026/05/27 19:34:17 UTC, 0 replies.
- [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.6.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:43:45 UTC, 1 replies.
- [PR] Bump com.diffplug.spotless from 5.6.1 to 8.6.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:43:48 UTC, 1 replies.
- [PR] Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.4.2 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:44:01 UTC, 4 replies.
- [PR] Bump docker/setup-qemu-action from 4.0.0 to 4.1.0 [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:44:55 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.101.0 to 1.102.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:45:25 UTC, 2 replies.
- [PR] Bump google.golang.org/api from 0.281.0 to 0.282.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:45:35 UTC, 2 replies.
- [PR] Bump github.com/aws/smithy-go from 1.25.1 to 1.26.0 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:45:41 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.19 to 1.22.20 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:47:09 UTC, 2 replies.
- [PR] [Python] Add UnboundedSource SDF wrapper (#19137) [beam] - posted by "Eliaaazzz (via GitHub)" <gi...@apache.org> on 2026/05/28 07:07:03 UTC, 8 replies.
- [PR] [GSoC 2026] Temporary feature-branch CI for Kafka Streams runner [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/28 10:01:44 UTC, 3 replies.
- [PR] [#38708] Add Flink 2.0 to SDK pipeline options validation lists [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/05/28 13:54:48 UTC, 2 replies.
- [PR] [Release-2.74] Cherry-pick #38695 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/28 14:15:14 UTC, 5 replies.
- Re: [I] [Feature Request]: Implement BatchElements in the beam-java-sdk [beam] - posted by "lucasfehres-cloudwise (via GitHub)" <gi...@apache.org> on 2026/05/28 14:40:07 UTC, 0 replies.
- [PR] Revert "Update transform catalogue docs" [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/28 14:58:05 UTC, 4 replies.
- [PR] Update JmsIO to ActiveMQ 6.2.5 and jakarta.jms [beam] - posted by "jbonofre (via GitHub)" <gi...@apache.org> on 2026/05/28 15:19:26 UTC, 3 replies.
- [PR] Re-enable call-args check in yaml_io.py [beam] - posted by "jrmccluskey (via GitHub)" <gi...@apache.org> on 2026/05/28 15:34:37 UTC, 3 replies.
- [PR] [Release-2.74] Cherry-pick #38726 into release branch [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/28 15:58:30 UTC, 5 replies.
- [PR] [yaml] - increase post commit workflow timeout [beam] - posted by "derrickaw (via GitHub)" <gi...@apache.org> on 2026/05/28 16:01:21 UTC, 4 replies.
- [PR] remove playground annotations from BatchElementsExample [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/28 17:06:03 UTC, 3 replies.
- [PR] [Prism] Fix race condition in element manager [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/28 17:52:08 UTC, 8 replies.
- Re: [PR] Add staged package hashes [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 23:00:23 UTC, 1 replies.
- [PR] [Prism] Fix Reshuffle handling to recursively remove sub-transforms [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/29 01:34:19 UTC, 4 replies.
- Re: [PR] Debug deadline exceeded [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/29 01:44:32 UTC, 1 replies.
- [PR] Fix flaky TestDataSampler/GetSamplesForPCollectionsTooManySamples [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/29 01:57:25 UTC, 10 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.17 to 1.19.18 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:47:28 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.18 to 1.32.19 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:48:39 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.20 to 1.22.21 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:49:57 UTC, 3 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.7 to 1.41.8 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:51:09 UTC, 2 replies.
- [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.102.0 to 1.102.1 in /sdks [beam] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:52:24 UTC, 3 replies.
- [I] [Bug]: ReadFromCSV [beam] - posted by "riana-r (via GitHub)" <gi...@apache.org> on 2026/05/29 07:33:55 UTC, 0 replies.
- [I] [GSoC 2026] Kafka Streams Runner — ExecutableStage (stateless ParDo) translator [beam] - posted by "junaiddshaukat (via GitHub)" <gi...@apache.org> on 2026/05/29 08:03:52 UTC, 0 replies.
- Re: [I] [Bug]: ReadFromCSV does not handle EmptyDataframe well internally [beam] - posted by "riana-r (via GitHub)" <gi...@apache.org> on 2026/05/29 09:37:04 UTC, 0 replies.
- Re: [I] [Failing Test]: Python Lint PreCommit Failing on yaml_io.py [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 13:37:11 UTC, 2 replies.
- Re: [I] [Feature Request]: Make Python container venv location configurable [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 13:37:14 UTC, 1 replies.
- [PR] Disable gRPC fork support in PortableRunnerTestWithSubprocesses [beam] - posted by "shunping (via GitHub)" <gi...@apache.org> on 2026/05/29 13:40:46 UTC, 6 replies.
- [PR] Bump setup gradle to allowlisted v6.1.0 [beam] - posted by "aIbrahiim (via GitHub)" <gi...@apache.org> on 2026/05/29 14:15:49 UTC, 2 replies.
- [I] [Feature Request]: Allow disable user metrics in Python SDK [beam] - posted by "Abacn (via GitHub)" <gi...@apache.org> on 2026/05/29 16:10:55 UTC, 1 replies.
- [PR] Release Note: Rename Dataflow Runner to Dataflow Portable Runner [beam] - posted by "TongruiLi (via GitHub)" <gi...@apache.org> on 2026/05/29 20:34:56 UTC, 8 replies.
- [PR] Handle empty batches in Python worker counters [beam] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/05/30 03:06:25 UTC, 4 replies.
- [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] - posted by "Anuragp22 (via GitHub)" <gi...@apache.org> on 2026/05/30 06:27:06 UTC, 9 replies.
- [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/05/30 10:25:32 UTC, 9 replies.
- Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 12:51:46 UTC, 0 replies.
- Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 12:51:52 UTC, 0 replies.
- [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/05/30 15:10:08 UTC, 5 replies.
- Re: [I] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/05/30 15:43:38 UTC, 1 replies.
- [PR] [CI] Fix Playground CI Nightly flakiness caused by API rate limiting and backend startup races [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/05/30 17:17:19 UTC, 3 replies.
- Re: [PR] Hugging face model handler #3 [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 17:53:54 UTC, 1 replies.
- [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] - posted by "durgaprasadml (via GitHub)" <gi...@apache.org> on 2026/05/30 17:58:08 UTC, 7 replies.
- Re: [I] [Task]: Update Python slowly updating side input example [beam] - posted by "Aaditya-git (via GitHub)" <gi...@apache.org> on 2026/05/31 06:56:14 UTC, 0 replies.
- Re: [I] [Feature Request]: Add Qdrant vector database ingestion support [beam] - posted by "claudevdm (via GitHub)" <gi...@apache.org> on 2026/05/31 10:44:50 UTC, 0 replies.
- Re: [PR] Iceberg CDC streaming source [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/31 12:59:33 UTC, 0 replies.
- Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/31 12:59:44 UTC, 1 replies.
- [PR] Add Worker hashes for Golang [beam] - posted by "tarun-google (via GitHub)" <gi...@apache.org> on 2026/05/31 22:36:18 UTC, 4 replies.