1. 1386b94 Merge pull request #10124: [BEAM-8670] Manage environment parallelism in DefaultJobBundleFactory by Thomas Weise · 45 minutes ago master
  2. 7beb9ee Merge pull request #10117 [BEAM-8335] Add service and tagged output capabilities to TestStream by Sam sam · 2 hours ago
  3. ec3515a Merge pull request #10069 Separate pydocs generation from py2 precommit tests. by Robert Bradshaw · 2 hours ago
  4. 76b9bdd [BEAM-8575] Test a customized window fn work as expected by Lukasz Cwik · 3 hours ago
  5. 97093f4 Merge pull request #10131 from Ardagan/LowerExamplesTimeout by Pablo · 4 hours ago
  6. 1bb581f Merge pull request #10062 from [BEAM-8379] Cache Eviction for Interactive Beam by Pablo · 4 hours ago
  7. 9a9f045 Reduce Java Examples Dataflow Precommit timeout by Mikhail Gryzykhin · 4 hours ago
  8. a2b0df9 Merge pull request #10030: [BEAM-8583] [SQL] Big query filter push down by Andrew Pilloud · 5 hours ago
  9. c6c8fbd Merge branch 'master' into addTest by liumomo315 · 8 hours ago
  10. 5de27d5 [BEAM-8151] Swap to create SdkWorkers on demand when processing jobs by Lukasz Cwik · 8 hours ago
  11. d16f2a9 Bump python precommit timeout by Lukasz Cwik · 8 hours ago
  12. 85248f3 [BEAM-8557] Add log for the dropped unknown response by Lukasz Cwik · 8 hours ago
  13. 45dc280 [BEAM-8670] Manage environment parallelism in DefaultJobBundleFactory by Thomas Weise · 21 hours ago
  14. 8f54d07 Merge pull request #10052 from robertwb/no-gauge by Robert Bradshaw · 9 hours ago
  15. 2271fa0 Merge pull request #10096 [BEAM-8655] Strengthen trigger transcript tests. by Robert Bradshaw · 9 hours ago
  16. 780ef7a Merge pull request #10013: [BEAM-8554] Use WorkItemCommitRequest protobuf fields to signal that … by reuvenlax · 18 hours ago
  17. 33cc30e [BEAM-8151] Swap to create SdkWorkers on demand when processing jobs by Luke Cwik · 28 hours ago
  18. 63d8020 [BEAM-8655] Run the subset of trigger tests that make sense in batch mode. by Robert Bradshaw · 2 days ago
  19. 2efca75 [BEAM-8655] Run trigger transcript tests with combiner as well as GroupByKey. by Robert Bradshaw · 2 days ago
  20. cea8d03 [BEAM-8655] Strengthen trigger transcript test to use multiple keys. by Robert Bradshaw · 2 days ago
  21. 4ee06ce Merge pull request #10109 [BEAM-8657] Combiner lifting fix for bundle-based direct runner. by Robert Bradshaw · 20 hours ago
  22. 3358b37 fixup by Wenjia Liu · 23 hours ago
  23. 2f00613 Merge pull request #10122: Fixes a failing check. by Chamikara Jayalath · 24 hours ago
  24. b653c29 Merge pull request #10106 [BEAM-8663] Respect PaneInfo in bundle based direct runner. by Robert Bradshaw · 24 hours ago
  25. 3a1a27f Merge pull request #10098 [BEAM-8657] Avoid lifting combiners for incompatible triggers. by Robert Bradshaw · 25 hours ago
  26. 8c3af8a Merge pull request #10114 Cleanup: move direct runner test to correct location. by Robert Bradshaw · 25 hours ago
  27. b41fe1a fixup by Wenjia Liu · 25 hours ago
  28. bda8f62 [BEAM-8575] Test a customized window fn work as expected by Wenjia Liu · 25 hours ago
  29. e35e6b8 [BEAM-8667] Bound elements buffered off the data channel. by Lukasz Cwik · 25 hours ago
  30. db11e06 [BEAM-8661] Moving other modules to have per-module loggers by Lukasz Cwik · 26 hours ago
  31. 8bf9468 [BEAM-8661] Moving io module to have per-module logger by Lukasz Cwik · 26 hours ago
  32. 7588387 Merge pull request #10108 from ibzib/artifact-endpoint by Kyle Weaver · 26 hours ago
  33. 310f289 Fixes a failing check. by Chamikara Jayalath · 26 hours ago
  34. de9cd0b Bump python precommit timeout by Mikhail Gryzykhin · 27 hours ago
  35. dd605e5 Merge pull request #10112: [BEAM-8666] Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811 by Chamikara Jayalath · 27 hours ago
  36. 9009dd1 Merge pull request #10111 from liumomo315/fix_window_idempotency by Alan Myrvold · 27 hours ago
  37. c9e2699 Removing extra space between constants by pabloem · 28 hours ago
  38. ccb6af2 Removing extra line between constants by pabloem · 28 hours ago
  39. d4818ec Fix lint by pabloem · 2 days ago
  40. fab9e3e [BEAM-8661] Moving other modules to have per-module loggers by pabloem · 2 days ago
  41. 8f86340 Cleanup: move direct runner test to correct location. by Robert Bradshaw · 29 hours ago
  42. 308f4ca [BEAM-8667] Bound the number of element bundles buffered off the data channel. by Robert Bradshaw · 29 hours ago
  43. edf01c4 Merge pull request #10093 Avoid Wimplicitly-unsigned-literal caused by -2**63. by Robert Bradshaw · 29 hours ago
  44. e1c0970 [BEAM-8666] Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811 by Viola Lyu · 30 hours ago
  45. 07077f1 Merge pull request #10103: [BEAM-8598] Exclude UsesTestStreamWithMultipleStages from Flink PVR tests by Maximilian Michels · 30 hours ago
  46. 312535e [BEAM-8575] Fix window assignment idempotency tests non-deterministic elements order by Wenjia Liu · 30 hours ago
  47. e265826 Merge pull request #9477 from lukecwik/python by Lukasz Cwik · 30 hours ago
  48. 0b78d91 [BEAM-8612] Convert []beam.T to the underlying type []T when passed to a universal type. (#10066) by Tianyang Hu · 31 hours ago
  49. 55b4839 Merge pull request #10104 Do not override test_metrics in PortableRunner test cases. by Robert Bradshaw · 31 hours ago
  50. d3f8192 [BEAM-8657] Combiner lifting fix for bundle-based direct runner. by Robert Bradshaw · 31 hours ago
  51. 3deca14 Comment on compatibility. by Robert Bradshaw · 31 hours ago
  52. 5ff4f95 [BEAM-8660] Override returned artifact staging endpoint by Kyle Weaver · 31 hours ago
  53. 5089c39 [BEAM-8554] Use WorkItemCommitRequest protobuf fields to signal that a WorkItem needs to be broken up by Steve Koonce · 9 days ago
  54. 29cb612 Merge pull request #10088 from ibzib/process-logs by Kyle Weaver · 32 hours ago
  55. 1b62310 [BEAM-8151, BEAM-7848] Swap to using a thread pool which is unbounded and shrinks when threads are idle. by Luke Cwik · 6 weeks ago
  56. e9f766f [BEAM-8151, BEAM-7848] Add an UnboundedThreadPoolExecutor implementation. by Luke Cwik · 3 days ago
  57. 96957c6 [BEAM-8663] Respect PaneInfo in bundle based direct runner. by Robert Bradshaw · 32 hours ago
  58. 5e2ff14 [BEAM-8657] Avoid lifting combiners for incompatible triggers. by Robert Bradshaw · 2 days ago
  59. ee3f951 [BEAM-3419] Explicitly model iterable side inputs as part of the Beam portability APIs. (#10092) by Lukasz Cwik · 33 hours ago
  60. bff9a1a Merge pull request #10086: [BEAM-7078] Update amazon-kinesis-client to 1.13.0 by Ismaël Mejía · 35 hours ago
  61. 5d91fbf Do not override test_metrics in PortableRunner test cases. by Kamil Wasilewski · 2 days ago
  62. 529b085 [BEAM-8598] Exclude UsesTestStreamWithMultipleStages also from Flink PVR tests by Maximilian Michels · 2 days ago
  63. f96b109 Merge pull request #10026: Make key type parameter in Flink's state request handler explicit by Maximilian Michels · 2 days ago
  64. c049586 Merge pull request #10085: [BEAM-8157] Adjust comment and improve ProcessBundleDescriptorsTest by Maximilian Michels · 2 days ago
  65. 38d0f5d Fix lint by pabloem · 2 days ago
  66. a1e0daa [BEAM-8661] Moving io module to have per-module logger by pabloem · 2 days ago
  67. 7b482e4 [BEAM-7233, BEAM-6868] Create an implementation for a bundle finalizer that stores bundle finalization requests in memory. (#10074) by Lukasz Cwik · 2 days ago
  68. a27acf3 Merge pull request #9892: [BEAM-8427] [SQL] buildIOWrite for MongoDb Table by Andrew Pilloud · 2 days ago
  69. 846369d Avoid Wimplicitly-unsigned-literal caused by -2**63. by Robert Bradshaw · 2 days ago
  70. 15e80d2 Can't use subprocess.DEVNULL in py2 by Kyle Weaver · 2 days ago
  71. 802e7cd Merge pull request #10090 Update container image tags used by Dataflow runner for Beam master by tvalentyn · 2 days ago
  72. 14f3d58 review comments by kirillkozlov · 2 days ago
  73. 7f8b1af Merge pull request #10087: Revert "Merge pull request #10072: [BEAM-8616] Make hadoop-client a p… by Ismaël Mejía · 2 days ago
  74. c5e3253 [BEAM-8575] Windows idempotency: Applying the same window fn (or wind… (#10071) by liumomo315 · 2 days ago
  75. de2cfae Beam changes to bypass recording timing for first N times seeing a new batch size. (#10063) by Ahmet Altay · 2 days ago
  76. 8de55cc [BEAM-8379] Cache Eviction by Ning Kang · 2 days ago
  77. 41b6716 [BEAM-8649] Eat stderr from subprocess in _get_default_gcp_region by Kyle Weaver · 2 days ago
  78. 47eac13 Remove Interactive Test Suite (#10068) by Ning Kang · 2 days ago
  79. 3160584 Make key type parameter in Flink's state request handler explicit by Maximilian Michels · 8 days ago
  80. da9efcd Merge pull request #10083 from mxm/BEAM-8622 by Kyle Weaver · 2 days ago
  81. c3fd801 Merge pull request #10076 from ibzib/java-default-region by Kyle Weaver · 2 days ago
  82. 54762d9 Revert "Merge pull request #10072: [BEAM-8616] Make hadoop-client a provided dependency on ParquetIO" by Łukasz Gajowy · 2 days ago
  83. 352ecf3 Merge pull request #9794 from boyuanzz/watermark by Boyuan Zhang · 2 days ago
  84. 80e8fb5 Merge pull request #10072: [BEAM-8616] Make hadoop-client a provided dependency on ParquetIO by Ismaël Mejía · 2 days ago
  85. d0274dc [BEAM-7078] Update amazon-kinesis-client to 1.13.0 by Alexey Romanenko · 2 days ago
  86. ba8d4b6 [BEAM-8157] Follow-up to adjust comment and improve ProcessBundleDescriptorsTest by Maximilian Michels · 3 days ago
  87. 9783072 [BEAM-8622] Exclude UsesStrictTimerOrdering PVR tests for Spark by Maximilian Michels · 3 days ago
  88. 4f48690 Update container image tags used by Dataflow runner for Beam master by Valentyn Tymofieiev · 3 days ago
  89. 808cb35 Merge pull request #10079 [BEAM-8621] Fix dependency checking job. by yifanzou · 3 days ago
  90. 14b7934 [BEAM-8621] Fix dependency checking job. by Yifan Zou · 3 days ago
  91. 126e5c2 [BEAM-8628] use mock GcsUtil in testDefaultGcpTempLocationDoesNotExist by Kyle Weaver · 3 days ago
  92. add1927 Merge pull request #9997: [BEAM-8157] Fix key encoding issues for state requests with unknown coders by Maximilian Michels · 3 days ago
  93. 3f7625a Merge pull request #10043 [BEAM-8597] Allow TestStream trigger tests to run on other runners. by Robert Bradshaw · 3 days ago
  94. 0b210c9 [BEAM-8598] Test triggering BEAM-8598 on FlinkRunner. (#10049) by Robert Bradshaw · 3 days ago
  95. b94dca2 Update SDF APIs by Boyuan Zhang · 5 weeks ago
  96. a8b8f64 [BEAM-8157] Add integration test for non standard key coders by Maximilian Michels · 10 days ago
  97. ee28c6e [BEAM-8157] Add LengthPrefixCoder around unknown key coder for stateful ProcessBundleDescriptor by Maximilian Michels · 7 days ago
  98. d02e42f Work around for BEAM-8598. by Robert Bradshaw · 3 days ago
  99. fc77c31 Merge pull request #10044 6x speedup for metrics. by Robert Bradshaw · 3 days ago
  100. b834e53 [BEAM-8594] Remove unnecessary error check in DataFlow Runner by Lukasz Cwik · 3 days ago