Google Git Google Git
Sign in
apache/beam/HEAD
  1. eb8f207 Trigger BQ CDC IT. Fix impl (#40618) by claudevdm · 4 hours ago master
  2. 2c21f02 AddFiles: Parse partition keys in filepath for requirement check (#40691) by claudevdm · 4 hours ago
  3. 61a94bd TPC-DS suite follow ups (#40741) by Yi Hu · 5 hours ago
  4. 1ba4129 Preserve ModelManager metric_tag across RunInference side-input model updates (#40714) by RuiLong J. · 6 hours ago
  5. 509c333 [Go] Avoid importing gcpopts in gcsx and dataflowlib to prevent flag collisions (#40729) by Derrick Williams · 6 hours ago
  6. 5d0fdfb Update transformers bounds and tests (#40745) by Jack McCluskey · 7 hours ago
  7. 8a6a3c1 Add V2 standard coders for WindowedValue and Timer with ElementMetadata support (#40744) by Radosław Stankiewicz · 8 hours ago
  8. 0202475 [DebeziumIO] Add CHANGES.md entry for opt-in full metadata (#40701) (#40743) by Tobias Kaymak · 8 hours ago
  9. 5c15387 [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique (#40571) by Anish Mehta · 8 hours ago
  10. 313c54d update bigquery tools test patch (#40746) by Derrick Williams · 9 hours ago
  11. 1d8e837 [RunInference] Validate model handler batching arguments (#40718) by alisha-1000 · 10 hours ago
  12. f1a9dc0 Update pytorch dependencies (#40710) by Jack McCluskey · 10 hours ago
  13. 3d5ca3e Update Numpy and Pandas Deps (#40704) by Jack McCluskey · 12 hours ago
  14. a7e7379 Bump google.golang.org/api from 0.304.0 to 0.305.0 in /sdks (#40742) by dependabot[bot] · 12 hours ago
  15. 0213fa8 add pr size label workflow (#40717) by Derrick Williams · 12 hours ago
  16. 6271afb Merge pull request #40733 from apache/20261022_fixCodeqlGo by Vitaly Terentyev · 15 hours ago
  17. 6848f84 Handle null split initialization results in Flink lazy source enumerator (#40417) by ddebowczyk92 · 25 hours ago nightly-refs/heads/master
  18. 932dbe6 [Java][BigQueryIO] Fix BigQueryIO streaming insert silently dropping transient network errors during response body read (#40420) by Danish Amjad · 25 hours ago
  19. e4c2f8c Honor allowMissingRequiredFields when building Storage Write API messages (#40204) by Khaled Hammouda · 25 hours ago
  20. c8b5acf Scope RunInference model_identifier annotation to BeamML_RunInference (#40671) by RuiLong J. · 27 hours ago
  21. d4ba44d [Java] Honor GOOGLE_CLOUD_UNIVERSE_DOMAIN for the Dataflow endpoint (#40672) by Shunping Huang · 27 hours ago
  22. d593d38 [Python] Support custom BigQuery endpoints and universe domains (#40675) by Shunping Huang · 27 hours ago
  23. e333810 Only feed total memory readings to the ModelManager resource estimator (#40646) by Divyansh Yadav · 28 hours ago
  24. 1fcf426 Upgrade allowed version of pillow (#40708) by Danny McCormick · 28 hours ago
  25. 94b84b6 [Java] Use GcsUtil V2 by default (#40713) by Shunping Huang · 28 hours ago
  26. 6e5fdbf Temporarily skip Iceberg cdc tests for managed service (#40731) by Ahmed Abualsaud · 29 hours ago
  27. 198abd4 [go] - update codeql go workflow by Derrick Williams · 29 hours ago
  28. 9f5f83e [Python] Keep BigQuery load jobs distinct for table aliases (#40001) by Bruno Volpato · 32 hours ago
  29. 3d5375a Expand Beam SQL TPC-DS query support and add Python TPC-DS suite (#40695) by Yi Hu · 33 hours ago
  30. 248548d Merge pull request #40303 from reuvenlax/merge_validates_runner_phase2 by reuvenlax · 34 hours ago
  31. cae975b Update FlareDB runner doc (#40576) by Ganesh Sivakumar · 34 hours ago
  32. e261c9f [#36841] Spark 4 streaming: windowed GroupByKey and Combine via transformWithState (#40703) by Tobias Kaymak · 34 hours ago
  33. 9811046 [DebeziumIO] Add opt-in full metadata (op and Debezium source fields) to readAsJson (#40702) by Tobias Kaymak · 34 hours ago
  34. 1484637 drop transformers 428 (#40719) by Abdelrahman Ibrahim · 34 hours ago
  35. f5f6006 rename TestRecord (#40728) by Abdelrahman Ibrahim · 35 hours ago
  36. 5b6aa70 Merge pull request #40683 from apache/fix-spanner-flatmap by Vitaly Terentyev · 2 days ago
  37. f3f7ad1 Fix prober community metrics (#40707) by Vitaly Terentyev · 2 days ago
  38. b4f9f3e Update xgboost dependency, execute in CI (#40694) by Jack McCluskey · 2 days ago
  39. 06e4102 [yaml] - fix spanner configs and examples (#40587) by Derrick Williams · 2 days ago
  40. 5b9c5ba test: allow users to set custom Neo4j config (#40700) by Florent Biville · 2 days ago
  41. 63d8acc [BEAM-19954] Resolve string annotations in callable type hints (#40625) by GAURAV THAKUR · 2 days ago
  42. b54c607 move pipeline examples from blueprint to pipelines (#40615) by Derrick Williams · 2 days ago
  43. 8cae499 [Java] Close GcsUtilV2's small-file performance gaps with GcsUtilV1 (#40677) by Shunping Huang · 2 days ago
  44. fa6c858 Merge pull request #40706 from apache/fix-publish-beam-metrics by Vitaly Terentyev · 2 days ago
  45. 3988ad7 Apply before set image by Vitaly Terentyev · 2 days ago fix-publish-beam-metrics
  46. bbd5e28 [RunInference] Honor model updates in also in the first batch. (#40667) by tvalentyn · 2 days ago
  47. e18c217 [Python] Infer the right type for slices of fixed-size tuples (#40680) by raams95 · 2 days ago
  48. f1ec3ac [Go] Support non-default universes for GCS and Dataflow clients (#40686) by Shunping Huang · 3 days ago
  49. ceeb5fa Merge pull request #40682 from Eliaaazzz/fix/runinference-max-batch-weight by tvalentyn · 3 days ago
  50. 11e1ce2 Add an option to set the Dataflow container base repository (Python, Java, Go) (#40690) by Shunping Huang · 3 days ago
  51. 0724ef9 [Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo (#40550) by Divyansh Yadav · 3 days ago
  52. d50c0a8 [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler (#40574) by Divyansh Yadav · 3 days ago
  53. 9146ff2 Merge pull request #40693 from apache/fix-publish-website by Vitaly Terentyev · 3 days ago
  54. 8a9afdc Fix bigquery_tools_test to mock gcp_bigquery library instead... (#40676) by Chamikara Jayalath · 3 days ago
  55. 14be1c0 Update google-adk dependency range (#40689) by Jack McCluskey · 3 days ago
  56. 7bdc6ff Fix Release Nightly Snapshot job (#40685) by Vitaly Terentyev · 3 days ago
  57. 9ea8253 Add -R flag by Vitaly Terentyev · 3 days ago fix-publish-website
  58. f014f5a Update test case for numpy 2.4.6 (#40692) by Jack McCluskey · 3 days ago
  59. 2fdcfb8 Render ARRAY and ITERABLE fields that are not backed by a List (#39750) by ZIHAN DAI · 3 days ago
  60. a412e69 enable canceling SQL streaming pipeline (#40666) by Ahmed Abualsaud · 3 days ago
  61. 45e6dd2 Fix chown by Vitaly Terentyev · 3 days ago
  62. d8ef6a9 Bump github.com/klauspost/compress in /playground/backend (#40688) by dependabot[bot] · 3 days ago
  63. bf57625 Revert errant google-adk bump on master (#40687) by Jack McCluskey · 3 days ago
  64. cdf9c3a Update google-adk dependency by jrmccluskey · 3 days ago
  65. 62f901f Upgrade google-api-client to 2.7.2 and use bomupgrade to manage (#40670) by Shunping Huang · 3 days ago
  66. d746d74 [Python] Fix GCS client creation in non-default universes (#40674) by Shunping Huang · 3 days ago
  67. 4dbf0d7 Fix Release NightlySnapshot after enabling errorprone for Java17+ build (#40668) by Yi Hu · 4 days ago
  68. 41df604 Add missing properties (#40684) by Vitaly Terentyev · 4 days ago
  69. f40b716 Bump distlib from 0.4.3 to 0.4.4 in /sdks/python (#40679) by dependabot[bot] · 4 days ago
  70. ba412b0 Use with_output_types by Vitaly Terentyev · 4 days ago fix-spanner-flatmap
  71. a8d6afd Finish max_batch_weight support for RunInference: issue number in CHANGES.md and pipeline-level regression tests by Elia LIU · 4 days ago
  72. 86d036c Apply element_size_fn and batch_length_fn to examples in keyed RunInference handlers. by Valentyn Tymofieiev · 9 days ago
  73. d37ad24 [Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful batching by Valentyn Tymofieiev · 9 days ago
  74. 0c37058 Remove Beam SQL Data Catalog provider (#40663) by Abdelrahman Ibrahim · 4 days ago
  75. 68e762e Default to parquet in AddFiles for extension less files. (#40614) by claudevdm · 4 days ago
  76. 18db489 [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex (#40593) by Arun Pandian · 4 days ago
  77. b4ecb26 Modernize legacy DoFn in BatchElementsExample (#40557) (#40560) by CH-Abhinav · 4 days ago
  78. 75d7e2c Process deletes before adds when committing OrderedList state updates. Otherwise we delete the newly added id from the idTracker. (#40659) by Andrew Crites · 4 days ago
  79. f8b1e8c [Python] Add typed decision questions and model adapters (#40220) by Bruno Volpato · 4 days ago
  80. 3ab18d0 [Go SDK] Add portable logical type registration and standard date and micros_instant types (#40154) by Elia Liu · 4 days ago
  81. 3bef0c0 [Python] Fail bundles on state write errors (#39992) by Bruno Volpato · 4 days ago
  82. 05c4879 allow dropping pk or watermark column (#40457) by Ahmed Abualsaud · 4 days ago
  83. 5dc1270 [Prism] Keep a stateful key in progress while a split primary holds it (#40624) by pablo rodriguez defino · 4 days ago
  84. 59a8647 Update nlp_tensorflow_streaming.ipynb (#40641) by Ryan McGinnis · 4 days ago
  85. a8ee2b8 [Spark 4] Group the streaming stateful ParDo by encoded key bytes to support null keys (#40516) by Tobias Kaymak · 4 days ago
  86. 6235796 Remove a race with another file write that is not essential to test presence of duplicates. (#40596) by tvalentyn · 4 days ago
  87. bd10258 Run portable ValidatesRunner tests one at a time (#40632) by Abdelrahman Ibrahim · 4 days ago
  88. 2c60b19 Fix postgres database for grafana (#40656) by Vitaly Terentyev · 4 days ago
  89. 14575dc Update api key for tour of beam (#40655) by Radosław Stankiewicz · 4 days ago
  90. 590abac [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights (#40549) by raams95 · 4 days ago
  91. 8648b89 Update users.yml (#40654) by Radosław Stankiewicz · 4 days ago
  92. 5fa8c2c Bump github/codeql-action from 4.38.3 to 4.39.0 (#40651) by dependabot[bot] · 5 days ago
  93. e4bc725 Bump zizmorcore/zizmor-action from 0.6.4 to 0.7.1 (#40652) by dependabot[bot] · 5 days ago
  94. 49d41ad Bump google.golang.org/api from 0.302.0 to 0.304.0 in /sdks (#40650) by dependabot[bot] · 5 days ago
  95. 10d3b8d Fix temp table cleanup for continuous read in BigQueryIO (#37535) by Radosław Stankiewicz · 5 days ago
  96. 5fc82a6 [Spanner Change Streams] Match single-RPC deadline to total timeout in SpannerIO.ReadChangeStream (#40616) by Radosław Stankiewicz · 5 days ago
  97. 707b951 Preserve HTTP errors when quota response is not JSON (#40631) by GAURAV THAKUR · 5 days ago
  98. 40df757 Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) (#39203) by Shahar Epstein · 5 days ago
  99. 8ef7176 Bump minimum cryptography bounds beyond known severe CVEs (#40591) by Jack McCluskey · 5 days ago
  100. 2be5254 [Prism] Finalize bundles of DoFns fused after another transform (#40640) by pablo rodriguez defino · 7 days ago