1. c471fd3 [BEAM-12258] Re-throw exception from forked thread in PubsubTableProvideIT.testSQLLimit (#14734) by Brian Hulette · 70 minutes ago master
  2. 805bbe8 [BEAM-12919] Removed IBM Streams from runner matrix (#15542) by David Huntsperger · 3 hours ago
  3. 6f0a1c9 Merge pull request #15484: [BEAM-12769] Python support for directly using Java transforms using constructor and builder methods by Chamikara Jayalath · 17 hours ago
  4. cd1cd05 Merge pull request #15535 Augment and cleanup CoGBK tests. by Robert Bradshaw · 19 hours ago nightly-master
  5. 4cbc3e5 Move CoGBK tests into appropreate module. by Robert Bradshaw · 4 days ago
  6. 6c1c19d [BEAM-12803] Update deprecated use of _field_types (#15539) by Jonathan Hourany · 22 hours ago
  7. 6947fa2 Use correct ignore field prefix in Python side by Chamikara Jayalath · 25 hours ago
  8. a7b706c [BEAM-12858] Fix flaky test #15534 by tvalentyn · 26 hours ago
  9. 7f50e89 Addresses reviewer comments by Chamikara Jayalath · 30 hours ago
  10. 4acc8e1 Additional CoGBK tests. by Robert Bradshaw · 4 days ago
  11. 31b7056 Fix lint errors. by Daniel Thevessen · 4 days ago
  12. 8226412 Fix flaky test. by Daniel Thevessen · 4 days ago
  13. 8072cc0 Minor: Prune docker volumes in Inventory job(#15532) by Brian Hulette · 4 days ago
  14. afccd52 Merge pull request #15355: [BEAM-12740] Add option to CreateOptions to avoid GetObjectMetadata for creating unique temporary GCS file. by Chamikara Jayalath · 4 days ago
  15. 663c221 Adds support for a field name format that will be ignored at expansion service and adds support for positional args in Python using that. by Chamikara Jayalath · 5 days ago
  16. 50997ad [BEAM-12603] Add retries to FnApiRunnerTest due to flakiness of grpc … (#15524) by Ahmet Altay · 5 days ago
  17. 7db9554 [BEAM-12535] add dataframes notebook (#15470) by David Cavazos · 5 days ago
  18. f969f9a Merge pull request #15513 from [BEAM-12899] Upgrade Gradle to version 6.9.x by Pablo · 5 days ago
  19. 31806e3 [BEAM-12603] Add retries to FnApiRunnerTest due to flakiness of grpc networking on jenkins machines. by Yichi Zhang · 5 days ago
  20. 081cb9a [BEAM-12701] Added extra parameter in to_csv for DeferredFrame to name the PTransform label (#15450) by Eduardo Sánchez López · 5 days ago
  21. abfd4c6 Merge pull request #15519 from ajamato/master by Kyle Weaver · 6 days ago
  22. 645f3c8 [BEAM-12898] Disable Flink Load tests which are leading Dataproc clusters/GCE VMs by Alex Amato · 6 days ago
  23. 3a3933c Merge pull request #15515 from dpcollins-google/fix-jenkins-only-failure by Kyle Weaver · 6 days ago
  24. d46cd9e Merge pull request #15517 from ibzib/BEAM-10459 by Kyle Weaver · 6 days ago
  25. 1723745 Merge pull request #15490 from KevinGG/beam_sql_out_cache by Ning Kang · 6 days ago
  26. 05a0ae1 [BEAM-10459] Unignore numeric aggregation tests. by Kyle Weaver · 6 days ago
  27. ab67f1e Minor: Restore "Bugfix" section in CHANGES.md (#15516) by Brian Hulette · 6 days ago
  28. af69e6df [BEAM-10708] Introspect beam_sql output by KevinGG · 14 days ago
  29. c039ee2 [BEAM-11666] flake on RecordingManagerTest (#15118) by AlikRodriguez · 6 days ago
  30. 9a40e41 [BEAM-12794] Remove obsolete uses of sys.exc_info. (#15507) by Kyle Weaver · 6 days ago
  31. 65f8946 [BEAM-12543] Fix DataFrrame typo (#15509) by Brian Hulette · 6 days ago
  32. f9dea10 [BEAM-12100][BEAM-10379][BEAM-9514][BEAM-12647][BEAM-12099] AssertionError type mismatch from AggregateScanConverter (#15174) by Benjamin Gonzalez · 6 days ago
  33. 0f3f576 [BEAM-12885] Enable NeedsRunner Tests for Samza Portable Runner (#15512) by Ke Wu · 6 days ago
  34. b5f1ccc [BEAM-12882] - fix test that is flaky when jenkins is overloaded by Daniel Collins · 6 days ago
  35. f5afff1 [BEAM-12845] Add AWS services as a runtime dependency to Spark Job Server to support S3 (#15461) by Rogan Morrow · 6 days ago
  36. d930983 [BEAM-12153] revert "implement GroupByKey with CombinePerKey with Concatenate CombineFn" because of performance issues. (#15508) by Etienne Chauchot · 6 days ago
  37. 442bf87 [BEAM-12899] Upgrade Gradle to version 6.9.x by masahitojp · 6 days ago
  38. 0fc66aa Addressing reviewer comments by Chamikara Jayalath · 7 days ago
  39. b362a53 [BEAM-12876] Adding doc and glossary entry for resource hints (#15499) by David Huntsperger · 7 days ago
  40. b10590c Merge pull request #15511 from pcoet/noGradle by Ahmet Altay · 7 days ago
  41. 4437b2a [BEAM-10913] - Updating Grafana from v6.7.3 to v8.1.2 (#15503) by Fernando Morales · 7 days ago
  42. 446fa83 updated Maven-to-Gradle conversion step in Java quickstart by David Huntsperger · 7 days ago
  43. 2553f6f [BEAM-12740] Add option to CreateOptions to avoid GetObjectMetadata for creating unique temporary GCS file. by Sam Whittle · 5 weeks ago
  44. 92aebe4 [BEAM-11980] Java GCS - Implement IO Request Count metrics (#15394) by Benjamin Gonzalez · 8 days ago
  45. be08391 Bump dataflow java container version to beam-master-20210913 (#15506) by Andy Xu · 8 days ago
  46. 96f3820 Merge pull request #15495 [BEAM-12689] fixed broken Python tab on HCatalog IO page by Robert Bradshaw · 8 days ago
  47. a14fd0c [BEAM-7261] Add support for BasicSessionCredentials for AWS credentials. (#15501) by Israel Herraiz · 8 days ago
  48. a63e15f Avoid apiary submission of job graph when it is not needed. (#15458) by Robert Bradshaw · 8 days ago
  49. c4581cc Merge pull request #15498 from apache/BEAM-12873 by Ahmet Altay · 8 days ago
  50. 1547518 Merge pull request #15492 from rohdesamuel/hotkeyflake by Ning Kang · 8 days ago
  51. 8ff2824 Fixes lint by Chamikara Jayalath · 11 days ago
  52. 150e802 Fixes yapf by Chamikara Jayalath · 12 days ago
  53. 2a7c0aa Python support for directly using Java transforms using constructor and builder methods. by Chamikara Jayalath · 13 days ago
  54. 25c67cd [BEAM-11097] Add implementation of side input cache (#15483) by Jack McCluskey · 11 days ago
  55. 3a20f49 [BEAM-12873] HL7v2IO: to leave schematizedData null, not empty by Tomo Suzuki · 11 days ago
  56. ad2a9c2 [BEAM-12802] Add support for prefetch through data layers down through the State API building on previous commits. (#15475) by Lukasz Cwik · 11 days ago
  57. 6427b75 Merge pull request #15425: [BEAM-8376] Google Cloud Firestore Connector - Add handling for partitions queries with zero cursors by Chamikara Jayalath · 11 days ago
  58. 55a3185 Merge pull request #15496 from ihji/fix_output_types by Heejong Lee · 11 days ago
  59. a44f5d7 Decreasing peak memory usage for beam.TupleCombineFn (#15494) by Ihor Indyk · 11 days ago
  60. 8b57eb0 [BEAM-8376] Google Cloud Firestore Connector - Add handling for partitions queries with zero cursors by BenWhitehead · 3 weeks ago
  61. 51948b3 [BEAM-12805] Fix XLang CombinePerKey test by explicitly assigning the output type by Heejong Lee · 11 days ago
  62. b6a1e38 fixed broken Python tab on HCatalog IO page by David Huntsperger · 11 days ago
  63. 8a646aa Port changes from Pub/Sub Lite to beam (#15418) by dpcollins-google · 11 days ago
  64. efb4b60 [BEAM-12662] Get Flink version from cluster. (#15223) by Kyle Weaver · 11 days ago
  65. a204890 [BEAM-12634] JmsIO auto scaling feature (#15464) by rvballada · 11 days ago
  66. 95c3811 Added type annotations to some combiners missing it. (#15414) by Dmytro Kozhevin · 11 days ago
  67. 0d02a88 [BEAM-12842] Add timestamp to test work item to deflake by Sam R · 11 days ago
  68. 3a3a844 [BEAM-12588] Multimap user state proto changes (#15473) by kileys · 11 days ago
  69. 7c8503e Register MapCoder, some comments/cleanup. (#15471) by Robert Bradshaw · 11 days ago
  70. 297171b [BEAM-5097] Increment counter for "small words" in go SDK example (#15399) by Ritesh Ghorse · 12 days ago
  71. 549d138 Merge pull request #15445 from Bump throttling counter on BigQueryRead retries due to RESOURCE_EXHAU… by Pablo · 12 days ago
  72. 37cd8f8 Merge pull request #15412 from Ruwann/docs-additional-bq-parameters by Pablo · 12 days ago
  73. f7da22b Merge pull request #15451 from Fix broken 'differences from pandas' link by Pablo · 12 days ago
  74. b58f6c8 Merge pull request #15463 from [BEAM-12846] Added GroupBy row in Aggregation table. by Pablo · 12 days ago
  75. dc29e88 Bump a throttling counter on BigQueryRead retries due to RESOURCE_EXHAUSTED by Enis Sert · 4 weeks ago
  76. 7e82513 [BEAM-3304] Helper functions for triggers (#15430) by Ritesh Ghorse · 12 days ago
  77. f8ba28a Merge pull request #15353: [BEAM-12740] Remove matching to filter files when renaming gcs files in the same bucket by Chamikara Jayalath · 12 days ago
  78. 4bc8708 Merge pull request #15477 from echauchot/BEAM-5172-ignore-es-flaky-tests by Kyle Weaver · 12 days ago
  79. 390b482 [BEAM-12769] Fix typo in test class name, CLass -> Class by Lukasz Cwik · 12 days ago
  80. a871a49 Merge pull request #15446 from KevinGG/ib-ts-coder by Ning Kang · 12 days ago
  81. 9d3ae05 [BEAM-12740] Remove matching to filter files when renaming gcs files in the same bucket by Sam Whittle · 6 weeks ago
  82. dcdc355 [BEAM-5172] Temporary ignore testSplit and testSizes tests waiting for a fix because they are flaky. by Etienne Chauchot · 3 weeks ago
  83. 7f36b9b [BEAM-12834] Improve Go SDK cross-language documentation and API. (#15452) by Daniel Oliveira · 13 days ago
  84. 1d70ad7 [BEAM-11981] Java Bigtable - Implement IO Request Count metrics (#15342) by MiguelAnzoWizeline · 13 days ago
  85. e76b4db Merge pull request #15480: [BEAM-12356] Make sure DatasetService is always closed by reuvenlax · 13 days ago
  86. f5da9ff [BEAM-12769] Fix typo in test class name, CLass -> Class by Luke Cwik · 13 days ago
  87. a89b12a Add display data for JdbcIO.write (#15460) by Pablo · 13 days ago
  88. 8367b43 [BEAM-11205] Upgrading the Google Cloud Libraries BOM to v22 by Lukasz Cwik · 13 days ago
  89. b3014c4 [BEAM-12708] Bump arrow-memory-netty by Lukasz Cwik · 13 days ago
  90. 9a72560 Merge pull request #15267 from echauchot/BEAM-12153-spark-SS-runner-GBK-with-CPK by Kyle Weaver · 13 days ago
  91. b6c62ca Merge pull request #10546: [BEAM-9008] Add CassandraIO readAll method by Alexey Romanenko · 13 days ago
  92. fb0b6a8 [BEAM-12727] extract Concatenate CombineFn to runner-core module to deduplicate it from many runners by Etienne Chauchot · 7 weeks ago
  93. e12fc33 [BEAM-9008] adds CassandraIO.readAll by Vincent Marquez · 1 year, 9 months ago
  94. 9e929bd Merge pull request #15467: [BEAM-12851] Map output table names by Andrew Pilloud · 14 days ago
  95. 762a619 [BEAM-12802] Define a prefetchable iterator and iterable and utility functions that work over them. by Lukasz Cwik · 14 days ago
  96. e057430 [BEAM-12802] Define a prefetchable iterator and iterable and utility functions that work over them. by Luke Cwik · 4 weeks ago
  97. 91818e5 [BEAM-9482] Disable Kafka perf tests. #15459 by tvalentyn · 14 days ago
  98. 0fc4ffd Merge pull request #15469: [BEAM-12853] VALUES produces a UNION, window can't be set afterwards by Andrew Pilloud · 14 days ago
  99. e141b48 [BEAM-12851] Map output table names by Andrew Pilloud · 3 weeks ago
  100. ce05e32 Merge pull request #15468: [BEAM-12852] Revert change to int, use bigint in BigTable test by Andrew Pilloud · 14 days ago