Google Git
Sign in
apache/beam/HEAD
  1. 012f825 [Java] Optimize beam pubsub message to serialized pubsub protobuf message (#37896) by scwhittle · 4 hours ago master
  2. 3aad50b [Security] Bump ActiveMQ from 5.14.5 to 5.19.2 (#37944) by Bruno Volpato · 12 hours ago nightly-refs/heads/master
  3. 7187ff6 Handle Flink 2 job server tag in releases and SDK snapshot (#37939) by Yi Hu · 15 hours ago
  4. 4b448b0 Bump Java dev containers (#37931) by Yi Hu · 21 hours ago
  5. cf3d6ed [ErrorProne] Enable UnnecessaryParentheses validation and fix all violations (#37913) by Radosław Stankiewicz · 23 hours ago
  6. 79c52af Updates YAML Database transforms to use managed I/O by default (#37923) by Chamikara Jayalath · 24 hours ago
  7. 7c82e73 [Python][Java] Add support for record headers in WriteToKafka (Fixes #27033) (#37458) by ZIHAN DAI · 24 hours ago
  8. 3316ef9 [Website] Add missing I/O connectors to built-in connectors table (#37903) by Bruno Volpato · 24 hours ago
  9. 90a7db1 Merge pull request #37927 from apache/gcp-actions by Vitaly Terentyev · 33 hours ago
  10. 45c2863 Pin to SHA for GCP GitHub Actions by Yi Hu · 2 days ago
  11. 600b7d9 Pin gcp actions (#37926) by Yi Hu · 2 days ago
  12. 65a896b Fix #37894: Update yaml doc for composite transform changes (#37901) by liferoad · 2 days ago
  13. ca34216 Add Quick Start section to README (#37909) by Subramanya V · 2 days ago
  14. 982c9bd Pin version for setup-qemu-action (#37924) by Vitaly Terentyev · 2 days ago
  15. 0cd35ec Merge pull request #37922 from apache/users/damccorm/shas by Vitaly Terentyev · 2 days ago
  16. d9a6159 Pin docker actions to sha for now by Danny Mccormick · 2 days ago users/damccorm/shas
  17. 866d6f7 Merge pull request #37920 from apache/fix-maven-archetypes by Vitaly Terentyev · 2 days ago
  18. 0e7dd4f Add version to beam-sdks-java-io-components by Vitaly Terentyev · 2 days ago fix-maven-archetypes
  19. 5139ca6 Sync clickhouse resource manager client version with IO (#37918) by Yi Hu · 2 days ago
  20. 181995d Upgrade Docker setup actions to version 4 (#37914) by Danny McCormick · 2 days ago
  21. 7620a93 Fix #37736: Allow composite transforms to use implicit input chaining (#37861) by liferoad · 4 days ago
  22. 0afbdf6 Update Go Version to 1.26.1 (#37897) by Jack McCluskey · 5 days ago
  23. 4221266 [ErrorProne] enable JavaUtilDate, TimeUnitConversionChecker, InvalidThrows checks (#37791) by Radosław Stankiewicz · 5 days ago
  24. 4163dc7 [Error Prone] Fix Slf4j formatting errors and enable Slf4jFormatShouldBeConst check (#37771) by Radosław Stankiewicz · 5 days ago
  25. 48935a8 Resolve Error Prone NonCanonicalType warnings across the codebase (#37772) by Radosław Stankiewicz · 5 days ago
  26. c10028b Fix UnusedVariable warnings across codebase (#37770) by Radosław Stankiewicz · 5 days ago
  27. 7b06555 Fix flakiness in tests by increasing timeout and changing windowing type. (#37887) by Radosław Stankiewicz · 5 days ago
  28. d16f5d1 [ErrorProne] Fix EqualsGetClass warnings and enable Error Prone check (#37758) by Radosław Stankiewicz · 5 days ago
  29. c05733a Handle some cases during infer schema from dataclass (#37855) by Yi Hu · 5 days ago
  30. b3d2b06 [ErrorProne] Fix UnnecessaryMethodReference Check Findings (#37785) by Radosław Stankiewicz · 5 days ago
  31. 2209bd6 Adds bundleFinalizer support to Dataflow non-portable worker. (#37723) by Andrew Crites · 5 days ago
  32. 153875e Fix #37833: Use named logger instead of root logger in transforms/util.py (#37857) by liferoad · 6 days ago
  33. 180f3a6 Attempt to fix flaky GrpcLoggingServiceTest (#37891) by scwhittle · 6 days ago
  34. 2c99a01 Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks (#37889) by dependabot[bot] · 6 days ago
  35. d48108d Merge pull request #37874 from aIbrahiim/fix-30644-inference-python-benchmark by Vitaly Terentyev · 7 days ago
  36. d51177b Add a check to make sure GitHub action workflows are listed in readme (#37883) by Yi Hu · 7 days ago
  37. ae6d624 Add a configuration to wait for session creation (#37625) by Sakthivel Subramanian · 7 days ago
  38. 7b33e1c [Java] Improve GroupIntoBatches display data to show batching parameters (#37865) by scwhittle · 7 days ago
  39. fe29172 Updated URLs in notebooks: Folders changed from `/tour-of-beam/` to (#37876) by Alexander Nieuwenhuijse · 7 days ago
  40. fee107a Fix vLLM Gemma benchmark by updating transformers version by aIbrahiim · 9 days ago
  41. 8c48120 Enable error_prone UnnecessaryLongToIntConversion check (#37783) by Radosław Stankiewicz · 8 days ago
  42. fa9d190 SDF draining in dataflow runner v1 (#37831) by Radosław Stankiewicz · 8 days ago
  43. 1007f73 Update python dev container tag (#37853) by claudevdm · 8 days ago
  44. babf20c Adds validates runner post commit tests for Java streaming worker on streaming engine (#37872) by Andrew Crites · 8 days ago
  45. 0fb490f [ErrorProne] Enable EmptyCatch Error Prone check and document ignored exceptions (#37754) by Radosław Stankiewicz · 8 days ago
  46. 90c2ab2 [Gemini] Fix bad-unpacking pyrefly error (#37828) by Jack McCluskey · 8 days ago
  47. 41b513e Merge pull request #37871 from Abacn/fix-maven-archtype by Vitaly Terentyev · 8 days ago
  48. 4aff88e Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" (#37873) by Arun Pandian · 9 days ago
  49. 6517969 Fix maven archetype dependency for io-components by Yi Hu · 9 days ago
  50. 39c7b46 Regenerate beam container image dependencies to include newer version of grpc. (#37822) by tvalentyn · 9 days ago
  51. 4c95230 [typescript] - fix rest of vulnerabilities (#37852) by Derrick Williams · 9 days ago
  52. e1e2c3b [DebeziumIO] Implement startOffset & offset persistence for Kafka (#28248) (#37750) by Tobias Kaymak · 9 days ago
  53. 487696c [Dataflow Logging handler] Change @LazyInit to AtomicBoolean (#37846) by Arun Pandian · 9 days ago
  54. 9292e1d [Dataflow Streaming] Prevent commit threads from sharing commit streams (#37847) by Arun Pandian · 9 days ago
  55. 85c1b88 [Dataflow Streaming] Create a separate option to control commit threads with direct path. (#37848) by Arun Pandian · 9 days ago
  56. 914e425 Fix #21317: Replace colons with underscores in window filenames for Windows compatibility (#37821) by liferoad · 10 days ago
  57. 3b472aa [ErrorProne] Enable UnsafeReflectiveConstructionCast check (#37784) by Radosław Stankiewicz · 11 days ago
  58. b9a7585 [ErrorProne] Enable StaticAssignmentInConstructor check (#37786) by Radosław Stankiewicz · 11 days ago
  59. 0f6c88e Pin zookeeper in expansion service (#37859) by claudevdm · 11 days ago
  60. 47bab7e [SpannerIO] Add low-latency configuration in Spanner Change Streams (#37718) by Radosław Stankiewicz · 11 days ago
  61. 5c5c710 Revert "upgrade vllm for vuln" (#37856) by tvalentyn · 12 days ago
  62. d6d2433 Fix python postcommit 30513 (#37849) by Abdelrahman Ibrahim · 12 days ago
  63. b92c436 Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds (#37850) by Abdelrahman Ibrahim · 12 days ago
  64. 3b41e8b Remove rolled out Windmill separate heartbeat stream flag (#37845) by Arun Pandian · 12 days ago
  65. 02d8f56 [Dataflow Streaming] Remove rolled out Windmill isolated channels flag (#37844) by Arun Pandian · 12 days ago
  66. ab56619 upgrade vllm for vuln (#37843) by claudevdm · 13 days ago
  67. 0705b43 apt-get upgrade in container images to install security fixes. (#37841) by claudevdm · 13 days ago
  68. e497c1e Partly Revert #37832 (#37837) by Yi Hu · 13 days ago
  69. 892fa0a Fix Run in Colab thumbnails blocked by CSP (#37838) by Abdelrahman Ibrahim · 13 days ago
  70. 87d7bba docs: Clarify JAVA_HOME setup and initial build expectations for all OSes (#37415) by Esmelealem · 13 days ago
  71. 630f32a [Drain] Expose drain to dofn processElement and onTimer (#37825) by Radosław Stankiewicz · 13 days ago
  72. d6bc507 Skip intermediate python wheels on pull request trigger (#37832) by Yi Hu · 14 days ago
  73. a0674a9 [ErrorProne] Fix InvalidParam, InvalidInlineTag, InvalidBlockTag, and InvalidLink checks (#37773) by Radosław Stankiewicz · 14 days ago
  74. cf536ea Fix 36181 cloudml benchmarks job (#37803) by Abdelrahman Ibrahim · 14 days ago
  75. 9d73d76 Only pull license for selected tests and publishing container (#37827) by Yi Hu · 14 days ago
  76. 9f5904b Support inferring schemas from Python dataclasses (#37728) by Yi Hu · 14 days ago
  77. 2ebe33d fix non-breaking vulnerabilities (#37826) by Derrick Williams · 14 days ago
  78. edaeae9 update python container tag (#37812) by Derrick Williams · 14 days ago
  79. 9829d6d Merge pull request #37792: [ErrorProne] Fix AutoValueBoxedValues warnings across the codebase by Radosław Stankiewicz · 14 days ago
  80. 8e0736a Loosen GRPC requirements. (#37817) by tvalentyn · 2 weeks ago
  81. e6fcdd7 [Java][Debezium] Fix NPE in debeziumRecordInstant for DELETE events (#37795) by liferoad · 2 weeks ago
  82. 7d756c2 update container version (#37811) by Derrick Williams · 2 weeks ago
  83. 57ab2b9 [Dataflow Java Runner] Add support for sending logs directly to Cloud Logging (#37662) by scwhittle · 2 weeks ago
  84. 6c67a93 Bump minimatch from 3.1.2 to 3.1.5 in /sdks/typescript (#37729) by dependabot[bot] · 2 weeks ago
  85. 084c4da Revert "fix(python): Register all output pcollections of a transform rather t…" (#37801) by claudevdm · 2 weeks ago
  86. eccfdbc Merge pull request #37800 from apache/fix-python-ml-3-10 by Vitaly Terentyev · 2 weeks ago
  87. d6759cf [Dataflow Streaming] Add a pipeline option to skip input elements that cannot be decoded successfully (#37762) by scwhittle · 2 weeks ago
  88. 5034e40 [Dataflow Streaming] Remove nullness suppression of StreamingDataflowWorker (#37797) by scwhittle · 2 weeks ago
  89. d27dc82 [IcebergIO] Add ITs for RESTCatalog using BLMS (#35360) by Ahmed Abualsaud · 2 weeks ago
  90. d10374b add py313 dep (#37799) by claudevdm · 2 weeks ago
  91. 78b22bc Use p310_ml_test by Vitaly Terentyev · 2 weeks ago fix-python-ml-3-10
  92. 6c42cc1 [ErrorProne] Enable BadImport ErrorProne check and fix violations (#37760) by Radosław Stankiewicz · 2 weeks ago
  93. b203f53 Move FileIO close from RecordWriter to RecordWriterManager (#37782) by Deji Ibrahim · 2 weeks ago
  94. 9b915fd Remove logging in tfrecordio.py (#37794) by tvalentyn · 2 weeks ago
  95. ea473d2 Merge pull request #37725 from aIbrahiim/fix-python-postcommit-dependency-1 by Vitaly Terentyev · 2 weeks ago
  96. 95d8481 Merge pull request #37798: Fix flaky TextIOWriteTest by loosening the shard count by Kenn Knowles · 2 weeks ago
  97. 78061b8 If the partition count or kafka IO size is large, then skip committin… (#37510) by kishorepola · 2 weeks ago
  98. 4d9e7fc Fix flaky TextIOWriteTest by loosening the shard count. Records may end up in the same shard as other records as it is random. Simplify the test to use Iterables instead of arrays. by Sam Whittle · 2 weeks ago
  99. 927ee2c fix: Correct malformed Javadoc tags and update Error Prone configuration. (#37755) by Radosław Stankiewicz · 3 weeks ago
  100. b6bc904 Merge pull request #37715: Disable combiner lifting only for count triggers by reuvenlax · 3 weeks ago