Google Git
Sign in
apache / beam / HEAD
  1. 0b2e57c Use self-hosted runners for republish workflow (#33507) by Danny McCormick · 2 days ago master nightly-refs/heads/master
  2. 0ea0fb4 Do not publish javadoc jar when exportJavadoc disabled (#33560) by Yi Hu · 2 days ago
  3. 6b3bca3 Use randbytes in custom LCG random generator (#33557) by Yi Hu · 2 days ago
  4. e5defdd Add retry logic to each batch method of the GCS IO (#33539) by Dmytro Sadovnychyi · 2 days ago
  5. b649235 Add issue link to disabled TensorRT integration test (#33079) by Jack McCluskey · 2 days ago
  6. 3b1dff9 Temporarily use self hosted runners for snapshots (#33563) by Danny McCormick · 2 days ago
  7. d7c5691 [Dataflow Streaming] Support to receive multiple work items in a single StreamingGetWorkResponseChunk (#33512) by Arun Pandian · 2 days ago
  8. 35732ce Support use staged harness for Dataflow runner v2 job (#33508) by Yi Hu · 3 days ago
  9. 2b72e12 Revert "Bump yapf from 0.29.0 to 0.43.0 in /sdks/python (#33112)" (#33552) by Jack McCluskey · 3 days ago
  10. f1f079b Give some folks triage permissions (#33550) by Danny McCormick · 3 days ago
  11. 1392cc8 Fix TextIO not fully reading a GCS file when decompressive transcoding happens (#33384) by Shunping Huang · 3 days ago
  12. d50cc15 [Managed Iceberg] Fix partition value race condition (#33549) by Ahmed Abualsaud · 3 days ago
  13. c6f8aae Temporarily skip deleting beam-performancetests-singlestoreio-12661373176 (#33545) by Danny McCormick · 3 days ago
  14. 6b3783f [Managed Iceberg] support BQMS catalog (#33511) by Ahmed Abualsaud · 3 days ago
  15. 4fc5c86 [#31438] WindowingStrategy Plumbing + AllowedLateness + Fixing Session Windows (#33542) by Robert Burke · 4 days ago
  16. a19466a Pin protobuf 3 for debezium (#33541) by Danny McCormick · 4 days ago
  17. 5a3ddc4 [Iceberg] cleanup FileIO resources (#33509) by Ahmed Abualsaud · 4 days ago
  18. b4c3a4f [BigQueryIO] fetch updated schema for newly created Storage API stream writers (#33231) by Ahmed Abualsaud · 4 days ago
  19. 40151ab Add Iceberg support for name-based mapping schema (#33315) by Filipe Regadas · 5 days ago
  20. 6509e51 [#33513][prism]Handle Time sorted requirement and drop late data. (#33515) by Robert Burke · 5 days ago
  21. 6618968 Return zero elements immediately if the requested number of quantiles is 1. (#33524) by Dmitry Labutin · 5 days ago
  22. fa086f9 Pin protobuf for older hadoop tests (#33525) by Danny McCormick · 5 days ago
  23. ab354db Update REVIEWERS.yml with the BigTable team (#33492) by liferoad · 5 days ago
  24. b911cca Documents the connectors supported via the Managed API (#33516) by Chamikara Jayalath · 5 days ago
  25. 4a5575c Update typehinting code to use primitives and collections types as main types over typing variants (#33427) by Jack McCluskey · 5 days ago
  26. 1b78b67 Bump yapf from 0.29.0 to 0.43.0 in /sdks/python (#33112) by dependabot[bot] · 5 days ago
  27. 39850bf Clean up py38 targets (#33510) by Yi Hu · 5 days ago
  28. 06644ec Bump com.gradle.develocity from 3.17.6 to 3.19 (#33375) by dependabot[bot] · 5 days ago
  29. f17bb8d SolaceIO: separate auth and session settings (#32406) by Bartosz Zablocki · 5 days ago
  30. 1d5a3e8 Enable caching in Python tests workflow (#33355) by Eduardo Ramírez · 5 days ago
  31. 43b2bf7 [feat 32473] Added soft deadline logic to Spanner Change Stream IO connector. (#32474) by Andrej Galad · 6 days ago
  32. e657d6c Adds an SdkHarnessOption that controls whether logging is redirected through the FnApi (#33418) by Tim Heckman · 6 days ago
  33. e0b04bf Update 2024.md (#33502) by liferoad · 6 days ago
  34. d6e0b0c Add support for Iceberg table identifiers with special characters (#33293) by Filipe Regadas · 6 days ago
  35. bbccf52 Build wheels on gha runners instead of local runners (#33505) by Danny McCormick · 6 days ago
  36. a1df014 [#31912] Fix bug in finalization for Prism & fix the Java bundle finalizing tests. (#33493) by Robert Burke · 6 days ago
  37. 254c1e2 Adds references to KeyCommitTooLargeException docs whever we throw the exception and also mentions --experiments=throw_exceptions_on_large_output as an option. (#33380) by Andrew Crites · 6 days ago
  38. 28999bc Fix republish docker branch (#33501) by Danny McCormick · 6 days ago
  39. b3e7f55 [java] Fix avro bytes conversion for BQ storage (#33412) by Michel Davit · 6 days ago
  40. d5248c1 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#33500) by dependabot[bot] · 7 days ago
  41. 05473f5 Use other fallback coders for protobuf message base class (#33432) by Shunping Huang · 8 days ago
  42. 4a32482 [Distroless] Publish Java SDK distroless variants (#33485) by Damon · 9 days ago
  43. 98c8534 Merge pull request #33487 Better error message on incorrect package listing. by Robert Bradshaw · 9 days ago
  44. f27547d [#32167][Prism] Use the worker-id gRPC metadata (#33438) by Damon · 9 days ago
  45. 7e6cf18 Update gcp bom to 26.50.0 (#33192) by Danny McCormick · 9 days ago
  46. 4c14921 Better error message on incorrect package listing. by Robert Bradshaw · 10 days ago
  47. f4006fe Merge pull request #33483 from rohitsinha54/fix-trie-merge by Robert Bradshaw · 10 days ago
  48. 2fb01be Fix bounded trie merge when merging on empty trie by Rohit Sinha · 10 days ago
  49. f3972c7 Add descriptive tags to republished containers (#33477) by Danny McCormick · 10 days ago
  50. badbce0 Update BEAM_DEV_SDK_CONTAINER_TAG for deps update. (#33480) by claudevdm · 10 days ago
  51. 73575e4 Stage beam_Publish_Java_SDK_Distroless_Snapshots.yml (#33469) by Damon · 10 days ago
  52. f32724b Stage beam_Publish_Python_SDK_Distroless_Snapshots.yml (#33470) by Damon · 10 days ago
  53. 0a91a39 fix error on local-env-setup.sh (#33461) by Shingo Furuyama · 10 days ago
  54. 8f2bf22 Bump github.com/aws/aws-sdk-go-v2/config from 1.28.6 to 1.28.7 in /sdks (#33440) by dependabot[bot] · 10 days ago
  55. dfb90ed Revert "Update Java expansion service to use distroless (#33464)" (#33476) by Danny McCormick · 10 days ago
  56. ee478ed Make Beam expansion service shadowJar multi-release so it processes multi-release dependencies correctly (#33472) by Yi Hu · 10 days ago
  57. 18ec331 Fix missing worker_id from interceptor (#33453) by Damon · 13 days ago
  58. 669076a Update Java expansion service to use distroless (#33464) by Danny McCormick · 13 days ago
  59. 23524a7 Remove aws v1 dependencies (#33466) by Danny McCormick · 13 days ago
  60. 2c1b605 Don't block bot on neutral responses (#33465) by Danny McCormick · 13 days ago
  61. 7800360 Remove amazon-web-services and kinesis folders + settings.gradle cleanup (#33456) by Danny McCormick · 13 days ago
  62. 9b09eda Update xlang kinesis to v2 (#33416) by Danny McCormick · 13 days ago
  63. df0ee41 Implement "stage_file_with_retry" for robust file staging (#33436) by Shunping Huang · 13 days ago
  64. 65c26b2 Fix iceberg ITs (#33462) by Ahmed Abualsaud · 13 days ago
  65. 4dfd014 Fix typo of output type in the docs. (#33463) by Danish Amjad · 13 days ago
  66. 97c4134 Remove aws v1 from infrastructure (#33455) by Danny McCormick · 13 days ago
  67. 813ef7c Update Python Dependencies (#33459) by github-actions[bot] · 13 days ago
  68. 7ca424d [yaml] add mysql, oracle, postgres and sql server providers (#33124) by Jeff Kinard · 14 days ago
  69. 0dc2c24 [Managed Iceberg] refactor integration tests; make it easy to add a new catalog to test suite (#33444) by Ahmed Abualsaud · 2 weeks ago
  70. def0678 Clean up Typescript Tests workflow (#33458) by Damon · 2 weeks ago
  71. 5944a30 BigQueryIO : control StorageWrite parallelism in batch, by reshuffling before write on the number of streams set for BigQueryIO.write() using .withNumStorageWriteApiStreams(numStorageWriteApiStreams) (#32805) by Razvan Culea · 2 weeks ago
  72. 067deed python multi-lang with schematransforms guide (#33362) by Ahmed Abualsaud · 2 weeks ago
  73. 1abc6c8 Support Iceberg partition identity transform (#33332) by Filipe Regadas · 2 weeks ago
  74. bf7e317 [Managed BigQuery] use file loads with Avro format for better performance (#33392) by Ahmed Abualsaud · 2 weeks ago
  75. ab73855 Update .GitHub/workflows README.md (#33341) by Damon · 2 weeks ago
  76. 74bcba1 [yaml] allow logging bytes in LogForTesting (#33433) by Jeff Kinard · 2 weeks ago
  77. c1b9fac Clean up Python Tests workflow (#33396) by Damon · 2 weeks ago
  78. 7e077dc [yaml] add RunInference support with VertexAI (#33406) by Jeff Kinard · 3 weeks ago
  79. 7c86bf3 Bump google.golang.org/api from 0.212.0 to 0.214.0 in /sdks (#33429) by dependabot[bot] · 3 weeks ago
  80. 30f128b Bump github.com/docker/docker in /sdks (#33420) by dependabot[bot] · 3 weeks ago
  81. a51a0e1 Move Dataflow Python Managed tests to prod (#33426) by Ahmed Abualsaud · 3 weeks ago
  82. e8df26f Merge pull request #33381 Migrate lineage counters to bounded tries. by Robert Bradshaw · 3 weeks ago
  83. 8fee3ca Improve existing Python multi-lang SchemaTransform examples (#33361) by Ahmed Abualsaud · 3 weeks ago
  84. fe6b7aa Merge pull request #33423: Add 2.63.0 section to CHANGES.md by Kenn Knowles · 3 weeks ago
  85. 55b0ce9 Add 2.63.0 section to CHANGES.md by Kenneth Knowles · 3 weeks ago
  86. ca8a35a Bump Iceberg to v1.6.1 (#33294) by Filipe Regadas · 3 weeks ago
  87. ec2e150 Moving to 2.63.0-SNAPSHOT on master branch. by kennknowles · 3 weeks ago
  88. 5eed396 fix error on start-build-env.sh (#33401) by Shingo Furuyama · 4 weeks ago
  89. e9424b9 Merge pull request #33414 from shunping/revert-reshuffle-changes by Chamikara Jayalath · 4 weeks ago
  90. 116df9f Fix env variable loading in Cost Benchmark workflow (#33404) by Jack McCluskey · 4 weeks ago
  91. 330f57b [YAML] Better docs for Filter and MapToFields. (#33274) by Robert Bradshaw · 4 weeks ago
  92. d17f77a Merge pull request #33386: In contributor docs, don't try to download releases from snapshot repo by Kenn Knowles · 4 weeks ago
  93. 14f7caf Update lineage query function. by Robert Bradshaw · 4 weeks ago
  94. f476417 Added support for SparkRunner streaming stateful processing (#33267) by twosom · 4 weeks ago
  95. 4cbf257 Revert three commits related to supporting custom coder in reshuffle by Shunping Huang · 4 weeks ago
  96. 71a5ced Deserialization fix. by Robert Bradshaw · 4 weeks ago
  97. e68a79c Validate circular reference for yaml (#33208) by Ravi Magham · 4 weeks ago
  98. d704422 Add missing imports. by Robert Bradshaw · 4 weeks ago
  99. 286e29c [Managed Iceberg] Support partitioning time types (year, month, day, hour) (#32939) by Ahmed Abualsaud · 4 weeks ago
  100. a9f50fa Python ExternalTransformProvider improvements (#33359) by Ahmed Abualsaud · 4 weeks ago