Messages by Thread
-
[PR] Fix BigtableIO RESUME_OR_NEW duplicate InitializeDoFn execution [beam]
via GitHub
-
Re: [PR] Add custom window support in Go SDK [beam]
via GitHub
-
[PR] Revert "[Experimental] Use zstd compression in Docker builds" [beam]
via GitHub
-
[PR] [Spark] Make cancel() cancel the Spark jobs and stop only a session the runner created [beam]
via GitHub
-
[PR] Update runner capability matrix [beam]
via GitHub
-
Re: [PR] [Experimental] Use zstd compression in Docker builds [beam]
via GitHub
-
[PR] AddFiles: CommitSchemaUnion [beam]
via GitHub
-
[PR] Ensure 0 backlog is sent when finishing processing restrictions. [beam]
via GitHub
-
[I] [Bug][Spark] SparkStructuredStreamingRunner cancel() does not cancel Spark jobs and stops a SparkSession it may not own [beam]
via GitHub
-
[PR] Fix PostCommit TransformService Direct workflow [beam]
via GitHub
-
[I] [Feature Request]: SolaceIO: Support user properties (message metadata) mapping [beam]
via GitHub
-
Re: [I] [Task]: Go SDK portable logical type support [beam]
via GitHub
-
[PR] [Spark] Let cancel() wait for the execution thread before stopping the session [beam]
via GitHub
-
[I] [Bug]: Go Prism Runner Concurrent Map Mutations [beam]
via GitHub
-
[PR] Bump org.nosphere.apache.rat from 0.8.2 to 0.9.0 [beam]
via GitHub
-
[PR] Fix PostCommit Java workflow [beam]
via GitHub
-
[PR] [CI] Stop infinite reviewer reassignment, batch state commits, and cl… [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
Re: [PR] [CI] Stop infinite reviewer reassignment, batch state commits, clean up stale state [beam]
via GitHub
-
[PR] Revert "[Python] Propagate WriteToFiles finalization failures" [beam]
via GitHub
-
[PR] [Gemini] Add ExpireSnapshots maintenance operation to Iceberg IO [beam]
via GitHub
-
Re: [I] [Feature Request][Java SDK]: Support writing to multiple Firestore databases in the same pipeline [beam]
via GitHub
-
[PR] [CI] Restore Java 17 in the Spark Versions PreCommit so the Spark 4 module runs [beam]
via GitHub
-
Re: [PR] Treat a 404 from BigQuery table and dataset deletes as success [beam]
via GitHub
-
[PR] [Website] Add GSoC 2026 Python streaming blog post [beam]
via GitHub
-
[PR] [Spark][#36841] Translate stateless streaming pipelines on the Spark 4 runner [beam]
via GitHub
-
Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam]
via GitHub
-
[PR] Bump js-yaml from 3.15.1 to 3.15.2 in /website/www [beam]
via GitHub
-
[PR] Bump google.golang.org/grpc from 1.82.1 to 1.83.2 in /playground/backend [beam]
via GitHub
-
[PR] Bump vllm from 0.10.1.1 to 0.27.0 in /sdks/python/container/ml/py311 [beam]
via GitHub
-
[I] [Feature Request]: Implement JsonIO.read() / readRows() for the Java SDK [beam]
via GitHub
-
[PR] Adds Delta Lake bounded CDC read support to Beam Python and YAML SDKs [beam]
via GitHub
-
[I] The PostCommit Java job is flaky [beam]
via GitHub
-
[PR] Setup reviewers for IcebergIO and DeltaIO [beam]
via GitHub
-
Re: [I] Enable TestStreamTest.testMultiStage [beam]
via GitHub
-
Re: [I] Add Beam DAG JSON config support for portable pipeline [beam]
via GitHub
-
[PR] Warn on failed import of internal BQ client for easier debugging [beam]
via GitHub
-
[PR] Portable tuple logical type [beam]
via GitHub
-
[PR] Bump golang.org/x/sync from 0.22.0 to 0.23.0 in /sdks [beam]
via GitHub
-
[I] [Feature Request]: Improve exception visibility in `FileSystems.matchSingleFileSpec` to prevent masking of root-cause Exceptions [beam]
via GitHub
-
[PR] Implement Iceberg Side-Input Table Cache Integration with Fallback [beam]
via GitHub