Google Git Google Git
Sign in
apache/beam/HEAD
  1. aa1a1e0 Propagate inner ImportError in get_code_from_identifier. (#41314) by Praneet Nadella · 43 minutes ago master
  2. 2c1a389 Bump pillow (#41230) by dependabot[bot] · 82 minutes ago
  3. e875703 Retry catalogCleanup on ForbiddenException in IcebergCatalogBaseIT (#41235) by Danny McCormick · 4 hours ago
  4. de8e16a Retry Pub/Sub topic and subscription creation in TestPubsub and TestPubsubSignal (#41064) by Danny McCormick · 4 hours ago
  5. f42ba75 DeltaIO CDC read ensures that CDF is enabled (#41253) by Chamikara Jayalath · 5 hours ago
  6. 6a0158c Port ReadSpannerSchemaTest off DoFnTester (#41138) by Rishavbhattarai · 5 hours ago
  7. 2301213 [#40949] Spark 4 streaming: stateless ParDo with additional outputs (#41220) by Tobias Kaymak · 6 hours ago
  8. 3514ee8 [#41297] Spark 4 streaming: disable exchange reuse for streaming queries (#41307) by Tobias Kaymak · 6 hours ago
  9. 4d97ba6 Bump github.com/aws/smithy-go from 1.28.8 to 1.28.9 in /sdks (#41263) by dependabot[bot] · 8 hours ago
  10. f3c0ca6 [Python] Optimize AvroRowWriter.tell and _split_table_spec (#41060) by Danny McCormick · 9 hours ago
  11. 2ca118b Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#41264) by dependabot[bot] · 9 hours ago
  12. 4aaf17b Update ML Orchestration TFX Example (#41181) by Jack McCluskey · 9 hours ago
  13. d84ac4d Bump golang.org/x/text from 0.43.0 to 0.44.0 in /sdks (#41266) by dependabot[bot] · 9 hours ago
  14. d2fee5a Scope shared TestDataflowRunner staging directory by UTC date (#41258) by Danny McCormick · 9 hours ago
  15. 37ae539 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#41262) by dependabot[bot] · 9 hours ago
  16. 2a7c56b Sleep between create_stream retry attempts when waiting for LocalStack in Kinesis ITs (#41204) by Danny McCormick · 10 hours ago
  17. 29adb3b Fix Flatten schema unification ordering and type degradation (#41239) by Vishal More · 10 hours ago
  18. 1f7709a Make Default Bucket Check Strict (#41252) by Tarun Annapareddy · 11 hours ago
  19. 057c337 Point drain doc links to the programming guide and update capability matrix drain row (#41237) by Maksym Tymoshyk · 11 hours ago
  20. ed6b89b Clone TransformWithState stateful processors across sibling streaming queries (#41137) by Danny McCormick · 11 hours ago
  21. 46b2794 Validate the SlidingWindows period in the Python SDK (#40925) by Jay Choukikar · 13 hours ago
  22. d7d31e9 Apply Spotless formatting to BeamSqlLine.java (#41261) by Danny McCormick · 20 hours ago
  23. 9fdd73d [Spark] Default storage level to MEMORY_ONLY when no Java runner is set (#41080) (#41236) by Divyansh Yadav · 20 hours ago
  24. fa1d467 Retry docker run on TimeoutException in DockerCommand (#41167) by Danny McCormick · 21 hours ago
  25. 382ff70 Add `summarize-failures` action to use on PRs (#41208) by Derrick Williams · 21 hours ago
  26. 8b79910 use ctrl+c to stop a shell query (#41257) by Ahmed Abualsaud · 23 hours ago nightly-refs/heads/master
  27. b73fea3 Pin pyarrow<26 in run_perf_alert_tool.yml for NumPy 1 compatibility (#41229) by Danny McCormick · 24 hours ago
  28. 4fc7887 Adds Delta Lake CDC support to Beam SQL (#41249) by Chamikara Jayalath · 24 hours ago
  29. 3b8d886 Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT (#41063) by Danny McCormick · 26 hours ago
  30. 268f76a Increase Postgres LoadBalancer IP wait timeout in JDBC and HadoopFormat PerformanceTests (#41205) by Danny McCormick · 27 hours ago
  31. 45f8983 [IcebergIO] Sort CDC sink windows with the native sorter (#40980) by Ahmed Abualsaud · 28 hours ago
  32. f88ae16 [Python] Interpolate ValueError messages in ml anomaly detectors and Vertex AI handler (#41088) by Mohammad Sohail Shaikh · 28 hours ago
  33. 164cc57 Use current timestamp for streaming ReadFromIcebergCDC to_timestamp in YAML ITs (#41145) by Danny McCormick · 28 hours ago
  34. 12c3823 remove hadoop dep from orc-core (#41001) by Ahmed Abualsaud · 29 hours ago
  35. 8bac585 Remove GPU container requirements generation infrastructure (#41242) by Danny McCormick · 31 hours ago
  36. 1cabbd7 [yaml] add pubsub to splunk e2e and example tests (#40885) by Derrick Williams · 32 hours ago
  37. bc9e036 Bump beartype upper bound (#41221) by Ali Ebrahim · 32 hours ago
  38. e8dc331 Fix forward references that do not resolve to types (#41184) by Jack McCluskey · 32 hours ago
  39. b8329d6 [YAML] Fix SQL-backed Join generating invalid syntax when joining 3+ inputs (#41068) by Vishal More · 33 hours ago
  40. 2024db9 Wait for Flink mini cluster REST server before submitting uber jar (#41046) by Danny McCormick · 33 hours ago
  41. bfb59af Wait for datanode SSH readiness before starting HDFS in hdfs-multi-datanode-cluster.yml (#41119) by Danny McCormick · 33 hours ago
  42. 1878a5b Inline and remove _OutputHandler._handle_tagged_output (#41209) by Danny McCormick · 2 days ago
  43. 3a84bd5 [Python] Default WriteToJson double_precision to 15 to avoid silently rounding floats (#41154) by Kumar Abhinandan · 2 days ago
  44. 2e5d84e [Dataflow Streaming] [MultiKey] Handle work cancellation exceptions in WorkFailureProcessor. (#40955) by Arun Pandian · 2 days ago
  45. 73b1202 [Python] Handle a missing initial watermark in MonotonicWatermarkEstimator (#41195) by Mohammad Sohail Shaikh · 2 days ago
  46. f22ba80 Pass reshuffle=False to beam.Create in TestBigQueryFileLoads waiting job tests (#41206) by Danny McCormick · 2 days ago
  47. 2ac5664 [Python] Optimize _OutputHandler.handle_process_outputs and handle_process_batch_outputs (#41162) by Danny McCormick · 2 days ago
  48. a01bffe Check holdTimestamp on overwritten event-time timers in Prism (#41146) by Danny McCormick · 2 days ago
  49. 3c5dc31 [Python] Only give an unknown option a value that directly follows it (#40647) by Yashvardhan Thanvi · 2 days ago
  50. e128f4f Check BackgroundCachingJob.is_done_or_running atomically under _result_lock (#41144) by Danny McCormick · 2 days ago
  51. af806f5 Republish released docker containers daily (#41218) by Yi Hu · 2 days ago
  52. e62a1de Assert at-least-once record count for STREAMING_INSERTS in BigQueryIOIT (#41166) by Danny McCormick · 2 days ago
  53. b9931c3 Port BigQueryIOWriteTest off DoFnTester (#40871) by Rishavbhattarai · 2 days ago
  54. 519a74e Update go version to 1.26.10 (#41056) (#41187) by Divyansh Yadav · 2 days ago
  55. 6b54230 Optimize DataInputOperation.process_encoded and cache coders in FnApiUserStateContext (#41173) by Danny McCormick · 2 days ago
  56. c3bcccf Port BatchViewOverridesTest off DoFnTester (#41202) by Harshil Valecha · 2 days ago
  57. 36f84cd Upgrade Tour of Beam Backend Dependencies (#41211) by Jack McCluskey · 2 days ago
  58. 4f876b4 Upgrade GCP Libraries BOM to 26.93.0 (#41178) by github-actions[bot] · 2 days ago
  59. efc23d0 [RunInference] Pass the device to a custom inference_fn in HuggingFaceModelHandlerTensor (#41086) by Mohammad Sohail Shaikh · 2 days ago
  60. aae0697 Configure failed stream connects before unblocking handover in Windmill gRPC stream tests (#41128) by Danny McCormick · 2 days ago
  61. 2b40b63 Bump cloud.google.com/go/pubsub/v2 from 2.8.0 to 2.8.1 in /sdks (#41192) by dependabot[bot] · 2 days ago
  62. 79a3598 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#41191) by dependabot[bot] · 2 days ago
  63. 9fbb85a Bump golang.org/x/sys from 0.49.0 to 0.50.0 in /sdks (#41188) by dependabot[bot] · 2 days ago
  64. 0a963fc Cache opcode dispatch tables in trivial_inference and atomic types in SchemaTranslation (#41061) by Danny McCormick · 3 days ago
  65. d9eccaa [Python] Cythonize PerWindowInvoker._invoke_process_per_window and avoid non-SDF allocations (#41159) by Danny McCormick · 3 days ago
  66. a496b2c Support PyArrow 26 in the Python SDK (#40927) by Anurag-S1ngh · 3 days ago
  67. 6545f98 [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing (#41059) by Danny McCormick · 3 days ago
  68. 420c838 Bump node-forge from 1.4.2 to 1.4.3 in /sdks/typescript (#41185) by dependabot[bot] · 3 days ago
  69. 46cb65f Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) (#40822) by Danny McCormick · 3 days ago
  70. 52bdecb Delete chicago_taxi benchmark (#41180) by Jack McCluskey · 3 days ago
  71. d5b16f10 [Python] Accept int tags on Partition results applied to a list (#40681) by raams95 · 3 days ago
  72. fa9c1eb [Prism] Honor clear requests for processing-time timers (#41073) by pablo rodriguez defino · 3 days ago
  73. e9705e2 [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic (#41135) by Danny McCormick · 3 days ago
  74. 5047974 Avoid shaded sql:jdbc fat jar on sql:iceberg testRuntimeClasspath (#41141) by Danny McCormick · 3 days ago
  75. 2d1ac62 [Dataflow] Reduce ShuffleSinkWriter memory retention and eagerly free native ApplianceShuffleWriter (#41028) by Yi Hu · 3 days ago
  76. 2598ba5 Enable uniform retry strategy and batch fallback retries in GcsUtilV2 (#41120) by Danny McCormick · 3 days ago
  77. 4d264c9 [#36841] Announce Spark 4 Structured Streaming runner streaming support in CHANGES.md (#40990) by Tobias Kaymak · 3 days ago
  78. f9cb995 [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output (#40785) by ilyas ahsan · 3 days ago
  79. 431981b Optimize Timestamp and Duration comparison and epoch helpers (#41110) by Danny McCormick · 3 days ago
  80. f6b1545 [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields (#41136) by Danny McCormick · 3 days ago
  81. e9d32f0 Run Python PostCommit vllmTests and tensorRTtests in us-west1 to avoid us-central1 T4 GPU quota exhaustion (#41147) by Danny McCormick · 3 days ago
  82. db147bb Retry Pub/Sub topic and subscription creation in StreamingWordCountIT.setUp (#41122) by Danny McCormick · 3 days ago
  83. baef698 [RunInference] Raise when a model handler returns fewer predictions than inputs (#40929) by Tanmay Singh · 3 days ago
  84. 0af1934 Bump golang.org/x/sync from 0.24.0 to 0.25.0 in /sdks (#41153) by dependabot[bot] · 3 days ago
  85. 0fa1aca Bump google.golang.org/api from 0.310.0 to 0.311.0 in /sdks (#41151) by dependabot[bot] · 3 days ago
  86. bc942aa Bump cloud.google.com/go/bigquery from 1.86.1 to 1.86.2 in /sdks (#41152) by dependabot[bot] · 3 days ago
  87. d70827f Bump golang.org/x/oauth2 from 0.37.0 to 0.38.0 in /sdks (#41150) by dependabot[bot] · 3 days ago
  88. a674b00 Bump github.com/aws/aws-sdk-go-v2 from 1.47.7 to 1.47.8 in /sdks (#41149) by dependabot[bot] · 3 days ago
  89. 544001a Batch amqsput messages and increase subscriber timeout in xlang_jmsio_it_test (#41121) by Danny McCormick · 3 days ago
  90. 9820e84 Harden Python testcontainers startup retry cleanup with cleanup_testcontainer_on_retry (#41129) by Danny McCormick · 3 days ago
  91. 94f7043 Increase default readTimeout to 60s in JmsIOIT (#41116) by Danny McCormick · 3 days ago
  92. b7496e4 Optimize WindowedValue.__hash__ and HomogeneousWindowedBatch.from_windowed_values (#41111) by Danny McCormick · 3 days ago
  93. ffc8c67 [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns (#41062) by Danny McCormick · 3 days ago
  94. 1f52d36 Move BundleLifter from Iceberg to sdk/util (#40978) by Tejas Iyer · 4 days ago
  95. e729f61 Retry transient 5xx GitHub API errors in pr-bot getGitHubClient (#41124) by Danny McCormick · 4 days ago
  96. fa40983 Configure mavenCentralMirrorUrl in buildSrc/settings.gradle.kts pluginManagement (#41118) by Danny McCormick · 4 days ago
  97. 663df87 Use curl -fsSL --retry 5 when installing docker-compose in workflows (#41113) by Danny McCormick · 4 days ago
  98. 9777788 [#40950] Spark Structured Streaming runner: translate Redistribute like Reshuffle (#41106) by Tobias Kaymak · 4 days ago
  99. 74f141d Add CHANGES function to Beam SQL (#40982) by Ahmed Abualsaud · 4 days ago
  100. a537a4c Increase Gradle wrapper networkTimeout and retry wrapper bootstrap on cache miss (#41065) by Danny McCormick · 4 days ago