Google Git
Sign in
apache / beam / HEAD
  1. c531f89 Update hack to make Spark runner happy as well. (#31184) by Robert Bradshaw · 35 hours ago master nightly-refs/heads/master
  2. e64c359 Avoid json Unmarshal on proto CancelJobRequest (#31178) by Damon · 2 days ago
  3. f468d40 Avoid excessive flushing in DataflowWorkerLoggingHandler. (#31175) by Nick Anikin · 2 days ago
  4. afe0793 Add a workaround for BEAM-20873 for optimized list side inputs. (#31163) by Robert Bradshaw · 2 days ago
  5. 7090260 Fix flink versioning issues (#31168) by Danny McCormick · 2 days ago
  6. 7dbdbdf Pass location for Vertex endpoint retrieval (#31171) by Jack McCluskey · 2 days ago
  7. af1ff2f Revert "[YAML] Increase re-use of providers with implicitly overlapping trans…" (#31169) by Danny McCormick · 2 days ago
  8. 782b644 Add ordered processing transform to changes/blog (#31165) by Danny McCormick · 3 days ago
  9. d9a816d Adds Managed I/O / Iceberg to 2.56.0 blog and the I/O connectors catalog (#31162) by Chamikara Jayalath · 3 days ago
  10. 6fdabea Re-enable schedule trigger for PostCommit Java IO Performance Tests (#31024) by Danny McCormick · 3 days ago
  11. 9f715b0 Fix blog typo (#31160) by Danny McCormick · 3 days ago
  12. 6995666 [Prism] Enable Java validatesRunner tests on Prism (#31075) by Damon · 3 days ago
  13. ee329ef add support for int gauge metrics (#31136) by Naireen Hussain · 3 days ago
  14. 25191d5 Terraform module to provision a kafka proxy (#31142) by Damon · 3 days ago
  15. ac83276 [Prism] Connect Web UI cancel requests with backend (#31028) by Damon · 3 days ago
  16. 1418030 Add docs/blog for release (#31094) by Danny McCormick · 3 days ago
  17. 9833ac3 Update gcp bom (#31158) by Danny McCormick · 3 days ago
  18. d561e5d Display current threshold for GC thrashing logs (#29768) by Bruno Volpato · 3 days ago
  19. d72c1aa Fix bomupgrader naming (#31157) by Danny McCormick · 3 days ago
  20. ae7b960 Update Python Dependencies (#30963) by github-actions[bot] · 3 days ago
  21. 294aa65 Merge pull request #31143: Limit elasticsearch testing to basic tests when core SDK is modified by Kenn Knowles · 3 days ago
  22. 2f57014 Limit elasticsearch testing from core SDK change to just one suite (not full elasticsearch compat suite which is very flaky) by Kenneth Knowles · 5 days ago
  23. a298700 update Changes.md for bigquery metrics (#31155) by JayajP · 4 days ago
  24. 670e56f FnAPI proto changes for ordered list state. (#31092) by Robert Bradshaw · 4 days ago
  25. d2db322 Fix ISM-expecting tests by explicilty requisting random access. (#31149) by Robert Bradshaw · 4 days ago
  26. dc5841d [YAML] Increase re-use of providers with implicitly overlapping transforms. (#30793) by Robert Bradshaw · 4 days ago
  27. 44e2abe Pin tensorflow version in notebook (#31145) by Danny McCormick · 4 days ago
  28. 4458b8b Fix spotbug warning in KafkaIO PreCommit (#31146) by Yi Hu · 4 days ago
  29. 8ef90be Merge pull request #31140: Revert addition of Redistribute and tests to Java SDK, and translations from runners by Kenn Knowles · 4 days ago
  30. ea4770b Add controlling multiple models across processes to CHANGES (#31147) by Danny McCormick · 4 days ago
  31. 557ad39 Add `.python-version` to .gitignore (#31135) by Shahar Epstein · 4 days ago
  32. 49056fd Revert "Add Redistribute translation to FlinkRunner" by Kenneth Knowles · 5 days ago
  33. ab9af72 Revert "Add Redistribute translation to Samza runner" by Kenneth Knowles · 5 days ago
  34. ece456c Revert "Add Redistribute translation to Spark runner" by Kenneth Knowles · 5 days ago
  35. 3b272d2 Revert "Add direct Dataflow translation of Redistribute transform" by Kenneth Knowles · 5 days ago
  36. f498cdf Revert "Add Redistribute transform to Java SDK" by Kenneth Knowles · 5 days ago
  37. 43bf99d Update game_stats.py (#31134) by Ahmet Altay · 5 days ago
  38. 7f7bc3e Optimise View.asList() side inputs for iterating rather than for indexing. (#31087) by Robert Bradshaw · 5 days ago
  39. 4a134b5 Enable BigQueryMetrics by default (#31015) by JayajP · 5 days ago
  40. 356311f Fix typo (#31063) by Chamikara Jayalath · 5 days ago
  41. 9612fe1 Elasticsearch enable Point In Time based searches (#30824) by pablo rodriguez defino · 5 days ago
  42. 5f71e6a remove atomic and wait from strimzi helm terrafrom (#31132) by Vlado Djerek · 5 days ago
  43. e3b4d41 Merge pull request #31032: Bump com.gradle.enterprise from 3.15.1 to 3.17.2 by Kenn Knowles · 5 days ago
  44. 413af12 Allow users to configure wait options for new Neo4j databases (#31129) by Florent Biville · 5 days ago
  45. f0d0605 add finalizers to kafka loadbalancer services (#31130) by Vlado Djerek · 5 days ago
  46. 970109e Also allow links to Drive materials. (#31131) by tvalentyn · 6 days ago
  47. 0696d00 Add ReadChangeStream IO param to adjust backlog estimates for replication delay (#30995) by Jack Dingilian · 6 days ago
  48. b00958a rename cluster used (#31113) by Vlado Djerek · 6 days ago
  49. 61ca405 Implementing lull reporting at bundle level processing (#30693) by Arvind Ram · 6 days ago
  50. 6fa6a28 Merge pull request #30545: Add Redistribute transform to model, Java SDK, and most active runners by Kenn Knowles · 6 days ago
  51. 673da54 [#30083][prism] Factor out hold tracking to dedicated structures (#31105) by Robert Burke · 9 days ago
  52. 28a2682d add terraform for utility cluster. Add name override to gke (#30847) by Vlado Djerek · 9 days ago
  53. 68f6b55 One more macos change (#31123) by Danny McCormick · 9 days ago
  54. 3329edb [Python] Add feast feature store handler for enrichment transform (#30957) by Ritesh Ghorse · 9 days ago
  55. c20e329 Fix reporting metrics not supported warning for BigQueryIO Direct read (#31096) by Yi Hu · 9 days ago
  56. 3e5a658 fix test added in previous commit (#31116) by Ben Konz · 9 days ago
  57. 5c3786e Try fixing build wheels (#31115) by Danny McCormick · 9 days ago
  58. 15f7f02 Add UnboundedReaderMaxReadTimeMs to DataflowPipelineDebugOptions, deprecate UnboundedReaderMaxReadTimeSec (#31091) by Radosław Stankiewicz · 9 days ago
  59. b33a843 Revert global snake_case convention for SchemaTransforms (#31109) by Ahmed Abualsaud · 10 days ago
  60. 088c854 Fix :examples:java:twitter:execute task (#31103) by Yi Hu · 10 days ago
  61. 3c8a881 Add ability to load multiple copies of a model across processes (#31052) by Danny McCormick · 10 days ago
  62. 3d3669e Use java 11 for java_tests workflow (#31101) by Yi Hu · 10 days ago
  63. 0f69dc1 remove cloudsdk environment variable, not needed here (#31102) by Vlado Djerek · 10 days ago
  64. e784799 use strimzi kafka on beam_utility cluster (#30967) by Vlado Djerek · 11 days ago
  65. 2db9b80 Mention known issues in release notes. (#31088) by tvalentyn · 11 days ago
  66. 8454cc9 Change assertion and timeout for kafka stress test (#31089) by akashorabek · 11 days ago
  67. bdfc781 Add Redistribute translation to FlinkRunner by Kenneth Knowles · 8 weeks ago
  68. 495e9b2 Python package string change (#31093) by Danny McCormick · 11 days ago
  69. 83a90f2 Merge pull request #31083 Add usage counters to ListView side inputs. by Robert Bradshaw · 11 days ago
  70. 8f1d3da Add Redistribute translation to Samza runner by Kenneth Knowles · 8 weeks ago
  71. 21e3fa1 Add Redistribute translation to Spark runner by Kenneth Knowles · 8 weeks ago
  72. 18ebc45 Add direct Dataflow translation of Redistribute transform by Kenneth Knowles · 9 weeks ago
  73. f49ac7d Add Redistribute transform to Java SDK by Kenneth Knowles · 9 weeks ago
  74. 7ade06f Add Redistribute to Beam model protos by Kenneth Knowles · 8 weeks ago
  75. 08fc33b2 Touch trigger files (add some comments as well) by Kenneth Knowles · 8 weeks ago
  76. 45e7857 python sdk: fix several bugs regarding avto <-> beam schema conversion (#30770) by Ben Konz · 11 days ago
  77. 485c519 Merge pull request #31086: Simplify intermediate data in Iceberg sink; use manifest files by Kenn Knowles · 12 days ago
  78. ab27f6f Refactor Residuals to prepare for processing time scheduling. (#31057) by Robert Burke · 12 days ago
  79. 1ebd503 Simplify intermediate data in Iceberg sink; use manifest files by Kenneth Knowles · 12 days ago
  80. 58bea3f Fix building release candidate (#31084) by Danny McCormick · 12 days ago
  81. ba7ea85 Revert "Change type for UnboundedReaderMaxReadTimeSec (#31037)" (#31082) by Jack McCluskey · 12 days ago
  82. 5cce8d7 Add usage counters to ListView side inputs. by Robert Bradshaw · 13 days ago
  83. de665b7 [YAML] - Normalize YAML PubSub format (#31068) by Ferran Fernández Garrido · 12 days ago
  84. 37609ba Managed Transform protos & translation; Iceberg SchemaTransforms & translation (#30910) by Ahmed Abualsaud · 13 days ago
  85. a0dad08 Bump golang.org/x/net from 0.22.0 to 0.24.0 in /sdks (#31065) by dependabot[bot] · 13 days ago
  86. 3dbbad9 Bump golang.org/x/net from 0.17.0 to 0.23.0 in /.test-infra/mock-apis (#31051) by dependabot[bot] · 13 days ago
  87. 5a86b3f Bump golang.org/x/net from 0.17.0 to 0.23.0 in /learning/katas/go (#31050) by dependabot[bot] · 13 days ago
  88. 718af0d Don't use isolated builds when building an sdist for a pipeline package supplied in --setup_file option. (#31070) by tvalentyn · 13 days ago
  89. f8b8121 Fix test failure due to locale sensitivity. (#31069) by Robert Bradshaw · 13 days ago
  90. 2472695 filter out outdated workflow runs (#31071) by Andrey Devyatkin · 13 days ago
  91. 8dcbf96 [#30083][prism] Stabilize additional teststream cases. (#31046) by Robert Burke · 13 days ago
  92. 1a5dc1c Replace Source type for BigTable and Kafka stress tests (#30999) by akashorabek · 13 days ago
  93. 516ac97 fix examples on website (#31066) by rajkgupt · 13 days ago
  94. 49da7a3 Bump golang.org/x/net from 0.22.0 to 0.23.0 in /sdks (#31054) by dependabot[bot] · 13 days ago
  95. 93aa62c Merge pull request #31058 from svetakvsundhar/broken_links by Svetak Sundhar · 2 weeks ago
  96. 31f1c79 fix url for content security by Svetak Sundhar · 2 weeks ago
  97. 40ec29a fix website embedding issue (#31019) by Svetak Sundhar · 2 weeks ago
  98. 98b1f03 Better and earlier error for missing service loader metadata. (#31042) by Robert Bradshaw · 2 weeks ago
  99. fd10030 Add ScaleToGaussian TFTransform (#31026) by Jack McCluskey · 2 weeks ago
  100. d05196d Upgrade the version of GRPC to pick up a fix for #30867 (#31044) by tvalentyn · 2 weeks ago