Google Git
Sign in
apache / beam / HEAD
  1. 1c74621 workflows: add `ubuntu-latest` to `beam_PreCommit_Python_ML`, `beam_PostCommit_Python`, and `beam_PreCommit_Python_Coverage` (#35816) by Mohamed Awnallah · 6 hours ago master
  2. 55bbbb3 Fix ml gradle (#36134) by Danny McCormick · 8 hours ago
  3. f296000b Update action (#36131) by Vitaly Terentyev · 9 hours ago
  4. ab2db45 Update import gpg action (#36130) by Vitaly Terentyev · 9 hours ago
  5. abbaab8 Fix flaky GrpcDirectGetWorkStreamTest.testConsumedWorkItems_itemsSplitAcrossResponses (#36129) by scwhittle · 10 hours ago
  6. 2beb75c infra/security: update project_id and bucket_name to match the correct configuration (#36122) by Enrique Calderon · 24 hours ago nightly-refs/heads/master
  7. f359ff5 Merge pull request #36117: [Dataflow Java] Support the existing --logMdc option by adding the present mdc values to custom_data json field. by Kenn Knowles · 26 hours ago
  8. f96128a Update PubsubIO.java documentation (#36120) by johnjcasey · 27 hours ago
  9. 2a5bbc2 [Dataflow Java] Support the existing --logMdc option by adding the present mdc values to custom_data json field. by Sam Whittle · 2 days ago
  10. dbae047 feat(pubsub): support batch mode in WriteToPubSub transform (#36027) by liferoad · 2 days ago
  11. 4f0bcf6 Pin Avro 1.12 in expansion service container (#36108) by Yi Hu · 2 days ago
  12. e64815d Hint Suggestions for invalid pipeline options (#36072) by Tarun Annapareddy · 2 days ago
  13. becfcf8 Fix CVE-2025-48734, CVE-2024-13009 (#36106) by Radosław Stankiewicz · 2 days ago
  14. 1da37bc [2/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] (#35473) by Mohamed Awnallah · 2 days ago
  15. 33d8d70 [YAML] - update readme to correct pipeline calls (#36076) by Derrick Williams · 2 days ago
  16. a2e0909 Bump github.com/spf13/cobra from 1.9.1 to 1.10.1 in /sdks (#36038) by dependabot[bot] · 2 days ago
  17. 9651c64 Fix JDBC type validation to check for empty strings in Read and Write Postgres schema transform providers (#36103) by liferoad · 3 days ago
  18. 246d955 Fix PostCommit Python job (#36098) by Vitaly Terentyev · 3 days ago
  19. 359c9eb Introduce Schema Registry Functionality to Managed KafkaIO Write. (#35644) by fozzie15 · 3 days ago
  20. 60630af Merge pull request #36077: [KafkaIO] Only update size metrics once per batch by Kenn Knowles · 3 days ago
  21. 48b453a Merge pull request #35561: [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress by Kenn Knowles · 3 days ago
  22. 69aa8af Fix portableLocalRunnerJuliaSetWithSetupPy by Vitaly Terentyev · 3 days ago fix-juliaset
  23. 10f0f07 workflows: add `ALLOYDB_PASSWORD` to Precommit Python Transforms (#36096) by Mohamed Awnallah · 3 days ago
  24. 28ad235 Add interactive dependency to notebooks (#36091) by Danny McCormick · 3 days ago
  25. dffa53f Correctly exclude prism when using external transforms (#36049) by Danny McCormick · 3 days ago
  26. a2f9fb8 pin avro 1.12.0 in expansion service (#36092) by Ahmed Abualsaud · 4 days ago
  27. fe188e3 [#34236] Add Vertex AI Multi-Modal embedding handler (#35677) by Jack McCluskey · 4 days ago
  28. 32aff26 [yaml] - add yaml expand_pipeline ut tests (#36087) by Derrick Williams · 4 days ago
  29. be4fb97 Support managed jdbc io (Postgres) (#36034) by Shunping Huang · 4 days ago
  30. be002c7 [YAML]: add optional schema config for all transforms (#35952) by Derrick Williams · 4 days ago
  31. 56607ec Improve Iceberg Blueprint and documentation and Tests (#35961) by Tarun Annapareddy · 4 days ago
  32. 56dac75 Fix MqttIO read checkpoint logic (#36056) by Yi Hu · 4 days ago
  33. ed383fa Logs the BigQuery error that caused the load job failure (resolves #1… (#36068) by Ian Mburu · 4 days ago
  34. a351c88 Added documentation for return vs yield usage in DoFn.process() (#34912) by yashu · 4 days ago
  35. 520b456 Only update size metrics once per batch by Steven van Rossum · 6 days ago
  36. 32f5be6 Update iceberg to 1.9.2 (#35981) by Ahmed Abualsaud · 6 days ago
  37. 0ba89bb YAML example suite minor updates (#36074) by Charles Nguyen · 6 days ago
  38. d9ddcd4 Add YAML Editor and Visualization Panel (#35947) by Chenzo · 6 days ago
  39. 9ac64e0 Spanner: Extend SpannerIO support for experimental hosts (#36048) by Sagnik Ghosh · 7 days ago
  40. f10fbf0 Add prism capability matrix (#36066) by Danny McCormick · 7 days ago
  41. 6a7ef33 [Java] Fix expensive OneOfType precondition messages by making them lazy (#36063) by scwhittle · 7 days ago
  42. d2fdabb Update beam_PreCommit_Whitespace.yml to run validateChanges (#36064) by liferoad · 7 days ago
  43. 0c509d3 Add ALLOYDB_PASSWORD to Examples and Coverage workflow (#36061) by Danny McCormick · 7 days ago
  44. 626be06 [YAML] Fraud Detection MLOps Workflow Example (#36012) by Charles Nguyen · 8 days ago
  45. c367bd3 Add Iceberg to AlloyDB Blueprint (#36036) by Tarun Annapareddy · 8 days ago
  46. 32d53ab Update notebook to use embedding gemma (#36035) by Danny McCormick · 8 days ago
  47. 1982627 Comment send email action (#36050) by Vitaly Terentyev · 8 days ago
  48. 07ea0f8 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#36042) by dependabot[bot] · 8 days ago
  49. 20b52a1 Comment send email action by Vitaly Terentyev · 8 days ago fix-send-mail
  50. 0a536e7 fix(Partition): support numpy integer types in partition validation (#36044) by liferoad · 8 days ago
  51. 67eaded Fix jdbc logical type not found when python sdk worker running in docker env (#36014) by Shunping Huang · 9 days ago
  52. d28fd64 feat(build): add validation task for CHANGES.md formatting (#36041) by liferoad · 9 days ago
  53. cccaa75 Only retrieve the shared caches once during setup in ReadFromKafkaDoFn (#36028) by Steven van Rossum · 9 days ago
  54. 9adc8dc Support Protobuf 6.x. (#35477) by Yilei · 9 days ago
  55. 230f3ea Cloudpickle deterministic coder changes.md. (#36037) by claudevdm · 9 days ago
  56. 6280b39 Update CHANGES.md to have fields for 2.69.0 release by Vitaly Terentyev · 9 days ago
  57. f3441bd Moving to 2.69.0-SNAPSHOT on master branch. by Amar3tto · 9 days ago
  58. faacf70 Bump cloud.google.com/go/spanner from 1.83.0 to 1.85.0 in /sdks (#36005) by dependabot[bot] · 9 days ago v2.68.0-RC00
  59. 35969b3 Introduce more abstract handling of throttling signaling (#35984) by Jack McCluskey · 10 days ago
  60. 7d6de9a [Prism] Fix two kinds of errors when using json log format. (#36020) by Shunping Huang · 10 days ago
  61. 4289ea2 Allow stateful exception handling (#35965) by Danny McCormick · 10 days ago
  62. f725e85 Update CHANGES.md (#36033) by flpablo · 10 days ago
  63. 523d833 Cache deterministic types (#36032) by claudevdm · 10 days ago
  64. 9f3b160 Add validation to check for non-ints from partitionfns (#35881) by Hai Joey Tran · 10 days ago
  65. a4ad5cd refactor(build): update changelog formatting in gradle task (#36021) by liferoad · 10 days ago
  66. f69fd72 Exit the poll loop in ReadFromKafkaDoFn after consumerPollingTimeout has elapsed (#36029) by Steven van Rossum · 10 days ago
  67. 266de26 Bump cloud.google.com/go/bigquery from 1.69.0 to 1.70.0 in /sdks (#36024) by dependabot[bot] · 10 days ago
  68. 2ab70ff Upgrade Errorprone to 2.31.0 (#35684) by Yi Hu · 11 days ago
  69. 17d5039 Bump github.com/aws/aws-sdk-go-v2/config from 1.31.4 to 1.31.6 in /sdks (#36025) by dependabot[bot] · 11 days ago
  70. f1a0855 Fix PostCommit Python ValidatesContainer Dataflow With RC job (#36016) by Vitaly Terentyev · 14 days ago
  71. e8fab26 Pass update compat through as_deterministic_coder and use cloudpickle for deterministic special types. (#35725) by claudevdm · 14 days ago
  72. 6bdfcb3 update description and logs for timeout (#36003) by LEEKYE · 14 days ago
  73. 4bb6e5a python: replace <=3.12 with <3.13 for google-apitools marker (semantics unchanged) (#35929) by Diego Hernandez · 14 days ago
  74. 258b8d1 [Prism] Surface log format option and improve logging presentation (#36008) by Shunping Huang · 14 days ago
  75. dab5f5d YAML example suite update (#35960) by Charles Nguyen · 14 days ago
  76. e72d9c7 fix pip extra options by Vitaly Terentyev · 2 weeks ago
  77. f5c5357 Add space character by Vitaly Terentyev · 2 weeks ago
  78. 372b25b Add GitHub Actions workflow for managing GCP Service Account keys (#35911) by Enrique Calderon · 2 weeks ago
  79. 4bcef0b Update beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml (#36015) by liferoad · 2 weeks ago
  80. e67a5a2 fix(mongodb): update filter composition to handle MongoDB 5.x driver (#36004) by liferoad · 2 weeks ago
  81. cffedbe Remove bad session test from SpannerReadIT (#36009) by shreyakhajanchi · 2 weeks ago
  82. 5d7a8ef Revert "Add AftersynchronizedProcessing Time as continuation trigger in Pytho…" (#35963) by liferoad · 2 weeks ago
  83. 01feaea Bump cloud.google.com/go/bigtable from 1.38.0 to 1.39.0 in /sdks (#36006) by dependabot[bot] · 2 weeks ago
  84. 6e89a7e Pin onnx version (#36010) by Vitaly Terentyev · 2 weeks ago
  85. deb9a0c [Prism] Fix resource (docker container) leak when shutting down (#35991) by Shunping Huang · 2 weeks ago
  86. 04ce0b6 Update BOM to 26.65.0 (#35854) by Vitaly Terentyev · 2 weeks ago
  87. ff7c389 Fix an issue when running a pipeline with prism runner on docker in python. (#36002) by Shunping Huang · 2 weeks ago
  88. aca551a update the changes.md for upgrading MongoDB Java driver from 3.12.11 to 5.5.0 (#35999) by liferoad · 2 weeks ago
  89. e28a69a Fix the link (#36000) by tvalentyn · 2 weeks ago
  90. 8e0f35f Adds a pipeline option to terminate processing of an element after a timeout (python) (#35391) by LEEKYE · 2 weeks ago
  91. f3be4c4 Add test to cover SDF with side input data correctness (#35951) by apanich · 2 weeks ago
  92. d7d27b0 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#35993) by dependabot[bot] · 2 weeks ago
  93. 5447d64 [bugFix] sdks/python: properly add Milvus as extra dependency (#35920) by Mohamed Awnallah · 2 weeks ago
  94. 02a532b Add TPU samples. (#35987) by tvalentyn · 2 weeks ago
  95. 0670eb1 Fix PostCommit Python Arm job (#35962) by Vitaly Terentyev · 2 weeks ago
  96. 8dd03dc Remove leftover logic handling Java8 container (#35988) by Yi Hu · 2 weeks ago
  97. ac00807 [YAML]: add import jinja pipeline example (#35945) by Derrick Williams · 2 weeks ago
  98. a7ec1ae update py containers (#35982) by Ahmed Abualsaud · 2 weeks ago
  99. 8c6ff9a Add a security GCP log analyzer (#35922) by Enrique Calderon · 2 weeks ago
  100. 4549214 Bump github.com/aws/aws-sdk-go-v2/config from 1.31.2 to 1.31.3 in /sdks (#35983) by dependabot[bot] · 2 weeks ago