Fix/add experiment refactor#38252

Open

ash6898 wants to merge 490 commits into

apache:masterfrom

ash6898:fix/add-experiment-refactor

This pull request is big! We're only showing the most recent 250 commits

Commits on Jun 29, 2026

Remove redundant HTTP->HTTPS redirect in .htaccess (#38522)

liferoad
authored and
ash6898
committed
Refactor _SharedCache to handle context vs non-context ownership (#38620)

shunping
authored and
ash6898
committed
Enforce binary-only constraints during early requirements cache attempts (#38688)

shunping
authored and
ash6898
committed
Bump docker/setup-qemu-action from 4.0.0 to 4.1.0 (#38718)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38719)

dependabot[bot]
authored and
ash6898
committed
Bump google.golang.org/api from 0.281.0 to 0.282.0 in /sdks (#38720)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/smithy-go from 1.25.1 to 1.26.0 in /sdks (#38721)

authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38722)

authored and
ash6898
committed
Implemented MLTransform generate vocab Dataflow benchmark (#38215)

aIbrahiim
authored and
ash6898
committed
[#38708] Add Flink 2.0 to SDK pipeline options validation lists (#38726)

durgaprasadml
authored and
ash6898
committed
up timeout (#38732)

derrickaw
authored and
ash6898
committed
remove playground annotations from BatchElementsExample until next release (#38733)

aIbrahiim
authored and
ash6898
committed
Update CHANGES.md after release cut (#38608)

Abacn
authored and
ash6898
committed
Support infer types involving dataclass fields (#38548)

Abacn
authored and
ash6898
committed
[Prism] Fix race condition in element manager (#38734)

shunping
authored and
ash6898
committed
Add staged package hashes (#38311)

tarun-google
authored and
ash6898
committed
Updated All Externally Visible Logs/Docs from Runner V2 to Portable Runner (#38532)

TongruiLi
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2 from 1.41.7 to 1.41.8 in /sdks (#38740)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#38737)

dependabot[bot]
authored and
ash6898
committed
fix race condition in sdb-operator (#38698)

aIbrahiim
authored and
ash6898
committed
Disable build isolation for pip by default. (#38700)

shunping
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38741)

authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38738)

authored and
ash6898
committed
Bump setup gradle to allowlisted v6.1.0 (#38745)

aIbrahiim
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38739)

authored and
ash6898
committed
Implement MLTransform One-Hot Encoding benchmark pipeline (#38404)

aIbrahiim
authored and
ash6898
committed
[yaml] - mongodb write normalization (#38376)

authored and
ash6898
committed
Disable gRPC fork support in PortableRunnerTestWithSubprocesses (#38744)

shunping
authored and
ash6898
committed
Fix flaky TestDataSampler/GetSamplesForPCollectionsTooManySamples (#38736)

shunping
authored and
ash6898
committed
Re-enable call-args check in yaml_io.py (#38730)

jrmccluskey
authored and
ash6898
committed
Fix Reshuffle handling in Prism to recursively remove nested sub-transforms (#38735)

shunping
authored and
ash6898
committed
Hugging face model handler #3 (#38696)

derrickaw
authored and
ash6898
committed
Handle empty batches in Python worker counters (#38748)

authored and
ash6898
committed
feat(ml): add qdrant ingestion (#38142)

MichaelGruschke
authored and
ash6898
committed
[Dataflow Streaming] Enable state tag encoding v2 (#38705)

arunpandianp
authored and
ash6898
committed
Bump nanasess/setup-chromedriver from 2 to 3 (#38757)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38758)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/golang-cz/devslog from 0.0.15 to 0.0.16 in /sdks (#38759)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2 from 1.41.8 to 1.41.9 in /sdks (#38761)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/tetratelabs/wazero from 1.11.0 to 1.12.0 in /sdks (#38762)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38760)

authored and
ash6898
committed
Add Worker hashes for Golang (#38754)

tarun-google
authored and
ash6898
committed
Updates Beam master container tags for Dataflow (#38766)

chamikaramj
authored and
ash6898
committed
[Dataflow Streaming] Prepare BoundedQueueExecutor for MultiKey bundles (#38592)

arunpandianp
authored and
ash6898
committed
Fix truncating file handle (#38425)

shunping
authored and
ash6898
committed
js2py to quickjs (#38473)

derrickaw
authored and
ash6898
committed
Migrate to Google Cloud Dataflow Client (#37639)

authored and
ash6898
committed
Adding release-2.74.0-postrelease to protected branches in .asf.yaml

Abacn
authored and
ash6898
committed
Update managed-io.md for release 2.74.0-RC1. (#38527)

authored and
ash6898
committed
Update Beam website to release 2.74.0 (#38536)

authored and
ash6898
committed
Update Python Dependencies (#38775)

authored and
ash6898
committed
Fix internal test configuration for Dataflow client (#38792)

jrmccluskey
authored and
ash6898
committed
Implements the Delta Lake source with support for splitting (#38706)

chamikaramj
authored and
ash6898
committed
Fix offlineRepositoryRoot relative to Beam repo root (#38790)

Abacn
authored and
ash6898
committed
Update republish released docker workflow defaults to 2.74.0 (#38796)

aIbrahiim
authored and
ash6898
committed
Update beam-master container (#38795)

jrmccluskey
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38801)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38804)

authored and
ash6898
committed
[OpenTelemetry] FNHarness, Dataflow Runner v1 - set open telemetry settings. (#38785)

stankiewicz
authored and
ash6898
committed
[OpenTelemetry] Default open telemetry configuration behind experiment (#38784)

stankiewicz
authored and
ash6898
committed
Bump google.golang.org/api from 0.282.0 to 0.283.0 in /sdks (#38809)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38810)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/nats-io/nats-server/v2 from 2.14.1 to 2.14.2 in /sdks (#38811)

dependabot[bot]
authored and
ash6898
committed
Upgrade Google Cloud libraries-bom to 26.83.0 (#38799)

aIbrahiim
authored and
ash6898
committed
feat: Add LogElements transform to Java SDK (#38533)

lalitium
authored and
ash6898
committed
Move google-auth lower bounds to >= 2.0.0 (#38778)

jrmccluskey
authored and
ash6898
committed
Normalize types in dataclass field type resolving (#38797)

Abacn
authored and
ash6898
committed
[Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments (#38749)

authored and
ash6898
committed
[Dataflow] Fix thread safety of HotKey logger (#38816)

arunpandianp
authored and
ash6898
committed
Fix BigQuery Storage Write API stream count for bounded writes (#38776)

Akshatsharma2205
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38825)

dependabot[bot]
authored and
ash6898
committed
Bump cloud.google.com/go/storage from 1.62.2 to 1.62.3 in /sdks (#38826)

authored and
ash6898
committed
[OpenTelemetry] Add gcp otel auth extension (#38773)

stankiewicz
authored and
ash6898
committed
Revert "remove playground annotations from BatchElementsExample until next re…" (#38830)

aIbrahiim
authored and
ash6898
committed
Automate OpenTelemetry license entries in bomupgrader (#38815)

aIbrahiim
authored and
ash6898
committed
support generics in from row and to row conversions (#37347)

tilgalas
authored and
ash6898
committed
[Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor (#38767)

arunpandianp
authored and
ash6898
committed
Update SpannerIO.java - comment documentation (#38492)

authored and
ash6898
committed
Bump github.com/aws/smithy-go from 1.27.1 to 1.27.2 in /sdks (#38841)

dependabot[bot]
authored and
ash6898
committed
[Experimental] Fix Yaml Xlang Test Timeout (#38798)

jrmccluskey
authored and
ash6898
committed
Fix parsing of dataflow api endpoint URLs to remove trailing slash (#38847)

authored and
ash6898
committed
Update Gemini text classification to gemini-2.5-flash (#38839)

aIbrahiim
authored and
ash6898
committed
fix flaky Arm postcommit test collection on Python 3.14 (#38844)

authored and
ash6898
committed
[Dataflow Streaming] Fix nullness supression in StreamingModeExecutionContext (#38842)

arunpandianp
authored and
ash6898
committed
Fix ensurepip bundled pip upgrade for Python 3.12+ (#38765)

aIbrahiim
authored and
ash6898
committed
Fix cloudML TFT install avoiding pip ResolutionTooDeep (#38781)

aIbrahiim
authored and
ash6898
committed
use local variable (#38850)

ahmedabu98
authored and
ash6898
committed
Fix Dataflow cost benchmark after Dataflow client migration (#38788)

aIbrahiim
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38856)

dependabot[bot]
authored and
ash6898
committed
Bump golang.org/x/sys from 0.45.0 to 0.46.0 in /sdks (#38857)

dependabot[bot]
authored and
ash6898
committed
Unpin google-cloud-bigtable version (fixes apache#37637) (#38861)

kellen
authored and
ash6898
committed
Bump distlib from 0.3.9 to 0.4.2 in /sdks/python (#38855)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#38858)

authored and
ash6898
committed
Bump golang.org/x/text from 0.37.0 to 0.38.0 in /sdks (#38860)

authored and
ash6898
committed
Disable public ip for Dataflow Validates Runner test (#38424)

Abacn
authored and
ash6898
committed
increase timeout (#38864)

derrickaw
authored and
ash6898
committed
Adds a Github action for running Delta Lake I/O unit tests (#38869)

chamikaramj
authored and
ash6898
committed
Enable code scanning alerts (#38817)

derrickaw
authored and
ash6898
committed
Side Input improvements (#38363)

reuvenlax
authored and
ash6898
committed
Support global sort and improve UDF overload resolution in Beam SQL (#38832)

authored and
ash6898
committed
Update huggingface model handler info (#38789)

derrickaw
authored and
ash6898
committed
Fix yaml doc generation (#38874)

Abacn
authored and
ash6898
committed
Fix race condition in statesampler_fast.pyx (#38851)

derrickaw
authored and
ash6898
committed
Merge pull request #38878: Fix OnWindowExpirationContext.

reuvenlax
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38884)

dependabot[bot]
authored and
ash6898
committed
Bump google.golang.org/api from 0.283.0 to 0.284.0 in /sdks (#38887)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38886)

dependabot[bot]
authored and
ash6898
committed
Bump actions/checkout from 4 to 6 (#38885)

dependabot[bot]
authored and
ash6898
committed
update iceberg add files parameters (#38879)

derrickaw
authored and
ash6898
committed
add datadog io normalization and yaml (#38362)

derrickaw
authored and
ash6898
committed
Bump torch (#38896)

dependabot[bot]
authored and
ash6898
committed
Revert "[Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments" (#38901)

authored and
ash6898
committed
Bump torch (#38897)

dependabot[bot]
authored and
ash6898
committed
Bump torch (#38903)

dependabot[bot]
authored and
ash6898
committed
Fix Xlang IO Direct installGcpTest uv cache lock (#38862)

aIbrahiim
authored and
ash6898
committed
Turn to manual build for Go for CodeQL (#38907)

derrickaw
authored and
ash6898
committed
Fix Dataflow legacy worker abort loop thread death issue (#38894)

damccorm
authored and
ash6898
committed
Bump cloud.google.com/go/bigtable from 1.48.0 to 1.49.0 in /sdks (#38913)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38916)

dependabot[bot]
authored and
ash6898
committed
Bump golang.org/x/net from 0.55.0 to 0.56.0 in /sdks (#38915)

dependabot[bot]
authored and
ash6898
committed
[IcebergIO] Improve TableCache (#38882)

ahmedabu98
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38912)

authored and
ash6898
committed
Use p310_ml_test (#38890)

aIbrahiim
authored and
ash6898
committed
Replace ClassLoadingStrategy with custom loading strategy (#38906)

cushon
authored and
ash6898
committed
Don't preempt snapshot runs (#38904)

damccorm
authored and
ash6898
committed
Bump @grpc/grpc-js from 1.14.3 to 1.14.4 in /sdks/typescript (#38922)

dependabot[bot]
authored and
ash6898
committed
Adds a new agent SKILL for developing new I/O connectors (#38910)

chamikaramj
authored and
ash6898
committed
Add Delta Lake source to the Java Managed API (#38902)

chamikaramj
authored and
ash6898
committed
Implement Asynchronous wrapper for DoFn in Java SDK (#38609)

tejasiyer-dev
authored and
ash6898
committed
Updates references to the I/O connector skill (#38923)

chamikaramj
authored and
ash6898
committed
Updates CHANGES.md to mention the Delta Lake source (#38924)

chamikaramj
authored and
ash6898
committed
[SQL] Support positional parameters (#38880)

Abacn
authored and
ash6898
committed
Support MAP type in RowJson and fix datetime parsing with spaces (#38865)

damccorm
authored and
ash6898
committed
SQL DDL documentation (#37539)

authored and
ash6898
committed
Add DoFnRunner::finishKey() method (#38454)

arunpandianp
authored and
ash6898
committed
[Dataflow Streaming] Activate SourceState Finalizers before submitting workitem to harness threads (#38921)

arunpandianp
authored and
ash6898
committed
Fix wordcount_rust requirements.txt and documentation (#38877)

jrmccluskey
authored and
ash6898
committed
Exclude testSideInputNotReadyTimer from Spark batch suites (#38939)

aIbrahiim
authored and
ash6898
committed
Add Gemini RunInference example notebook (#38943)

jrmccluskey
authored and
ash6898
committed
update agent skills table (#38818)

derrickaw
authored and
ash6898
committed
[Infra] Add beam_viewer and beam_writer roles for GSoC 2026 participant (#38933)

HansMarcus01
authored and
ash6898
committed
Add instrumentation for memory profiling in Python SDK (#38853)

tvalentyn
authored and
ash6898
committed
[#38059] Fix GCS glob matching to support ** and / in object names (#38099)

authored and
ash6898
committed
SQL Database DDL & Usability Improvements (#38952)

damccorm
authored and
ash6898
committed
Use add_experiment() instead of experiments.append() in Python
ash6898
committed
Use ExperimentalOptions.addExperiment() instead of get/set pattern in Java
ash6898
committed
Fix upload_graph condition regression and formatting issues
ash6898
committed
Copy experiments list to mutable ArrayList before addExperiment() calls
ash6898
committed
[mqtt] Add portable MqttIO Read/Write transforms for batch and streaming (revives #32385) (#38493)

tkaymak
authored and
ash6898
committed
Upgrade expansion jar to java17 (#38931)

derrickaw
authored and
ash6898
committed
Spanner: Extend SpannerIO to support Spanner Omni mTLS setup (#38928)

sagnghos
authored and
ash6898
committed
ClickHouseIO: Add DateTime64 support for sub-second timestamp precision (#38510)

Eliaaazzz
authored and
ash6898
committed
Revert "Upgrade expansion jar to java17 (#38931)" (#38965)

Abacn
authored and
ash6898
committed
Add support for STDDEV_POP and STDDEV_SAMP in VarianceFn (#38871)

damccorm
authored and
ash6898
committed
Update BEAM_DEV_SDK_CONTAINER_TAG version (#38963)

damccorm
authored and
ash6898
committed
Bump protobufjs from 8.4.0 to 8.6.0 in /sdks/typescript (#38968)

dependabot[bot]
authored and
ash6898
committed
Bump form-data from 2.5.5 to 2.5.6 in /sdks/typescript (#38967)

dependabot[bot]
authored and
ash6898
committed
Use Flink 2.0 for load tests (#38279)

Abacn
authored and
ash6898
committed
Bump cloud.google.com/go/spanner from 1.91.0 to 1.92.0 in /sdks (#38976)

dependabot[bot]
authored and
ash6898
committed
Fix AsyncWrapperTest timeout and flakiness issues. (#38970)

tejasiyer-dev
authored and
ash6898
committed
fix failure in opentelemetry-gcp-auth-extension jar (#38938)

aIbrahiim
authored and
ash6898
committed
Bump jsonpickle upper bound. (#38769)

claudevdm
authored and
ash6898
committed
[Dataflow Java] Clarify which portions of DataflowWorkerLoggingOptions are deprecated (#38960)

scwhittle
authored and
ash6898
committed
Fix WriteToPubSub to pass ordering_key to publish() method (#37345)

authored and
ash6898
committed
Add drain support for Dataflow and Flink (#38786)

lalitium
authored and
ash6898
committed
Bump google.golang.org/api from 0.284.0 to 0.285.0 in /sdks (#38997)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#38998)

dependabot[bot]
authored and
ash6898
committed
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#38999)

authored and
ash6898
committed
fix sentence (#38989)

ahmedabu98
authored and
ash6898
committed
address DOM text reinterpreted as HTML alert (#38949)

derrickaw
authored and
ash6898
committed
Align gcpauth extension implementation with ability to turn it off easily while still being added as dependency.

stankiewicz
authored and
ash6898
committed
Disable public IP for Dataflow Python and Go Validate runner tests (#38990)

Abacn
authored and
ash6898
committed
Add support for Apache Flink 2.1.3 (#38961)

ddebowczyk92
authored and
ash6898
committed
Make ModelManager import more robust (#38936)

authored and
ash6898
committed
[Beam SQL Shell] Add Iceberg deps when using icebergio (#38994)

ahmedabu98
authored and
ash6898
committed
Add publish_time_field to ReadFromPubSub YAML transform (#38985)

lalitium
authored and
ash6898
committed
Bump cloud.google.com/go/bigtable from 1.49.0 to 1.50.0 in /sdks (#39012)

dependabot[bot]
authored and
ash6898
committed
Exclude tests for batch-dataset (#39014)

Amar3tto
authored and
ash6898
committed
fix parsing error for typescript (#38898)

derrickaw
authored and
ash6898
committed
Drop Flink 1.17,1.18 support (#39006)

Abacn
authored and
ash6898
committed
cancel user code with interruption after timeout (#39018)

scwhittle
authored and
ash6898
committed
Fix Milvus ML PreCommit xdist, container startup (#39007)

aIbrahiim
authored and
ash6898
committed
Bump nodemailer from 8.0.5 to 9.0.1 in /scripts/ci/issue-report (#39019)

dependabot[bot]
authored and
ash6898
committed
remove shardedKey (#39024)

ahmedabu98
authored and
ash6898
committed
Validate Project of staging bucket (#39008)

tarun-google
authored and
ash6898
committed
Sanitize logging in FanOutStreamingEngineWorkerHarness (#39029)

parveensania
authored and
ash6898
committed
Increase CallTest sleep durations to keep test from being flaky due to timeout not being observed. (#39016)

scwhittle
authored and
ash6898
committed
[Dataflow Java] Fix incorrect warning log when specifying logger override. (#39034)

scwhittle
authored and
ash6898
committed
Bump github.com/moby/moby/api from 1.54.2 to 1.55.0 in /sdks (#39031)

dependabot[bot]
authored and
ash6898
committed
[FnApi Java] Add support for separate named data streams to provide bundle isolation (#38863)

scwhittle
authored and
ash6898
committed
Bump github.com/moby/moby/client from 0.4.1 to 0.5.0 in /sdks (#39032)

authored and
ash6898
committed
[Iceberg AddFiles] Add NameMapping when creating table (#39022)

ahmedabu98
authored and
ash6898
committed
Add Flink 2.2.1 runner support (#38980)

mananmangal
authored and
ash6898
committed
use proper table naming in iceberg sql (#39035)

ahmedabu98
authored and
ash6898
committed
Roll forward io expansion service to Java17 (#38974)

derrickaw
authored and
ash6898
committed
Bump github.com/golang-cz/devslog from 0.0.16 to 0.0.17 in /sdks (#39054)

dependabot[bot]
authored and
ash6898
committed
try to fix forward tests for java 17 (#39058)

derrickaw
authored and
ash6898
committed
Update pandas version upper bound to support python 3.14 (#39056)

shunping
authored and
ash6898
committed
Fix playground precommit test failure (#39062)

shunping
authored and
ash6898
committed
[yaml] - expand jinja method (#38547)

derrickaw
authored and
ash6898
committed
Bump actions/checkout from 6 to 7 (#39033)

dependabot[bot]
authored and
ash6898
committed
Bump google.golang.org/api from 0.285.0 to 0.286.0 in /sdks (#39068)

dependabot[bot]
authored and
ash6898
committed
Fix Flink 2.1+ dependency resolution (#39061)

Abacn
authored and
ash6898
committed
Update Python Dependencies (#39070)

authored and
ash6898
committed
Enable precommit yaml xlang test on code push. (#39071)

shunping
authored and
ash6898
committed
Release Note: Rename Dataflow Runner to Dataflow Portable Runner (#38747)

authored and
ash6898
committed
init (#39025)

claudevdm
authored and
ash6898
committed
[mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests (#38966)

tkaymak
authored and
ash6898
committed
[ReduceFnRunner] Fix Prefetches (#39082)

arunpandianp
authored and
ash6898
committed
[Dataflow Streaming] Increase stuck commit invalidation timeout to 1 hour (#39083)

arunpandianp
authored and
ash6898
committed
Bump actions/cache from 4 to 6 (#39081)

dependabot[bot]
authored and
ash6898
committed
Bump actions/checkout from 6 to 7 (#39080)

dependabot[bot]
authored and
ash6898
committed
Add UnboundedCountingSource::to for bounded reads from an UnboundedCountingSource (#39084)

arunpandianp
authored and
ash6898
committed
[Dataflow Java Streaming] Add a timeout to how long commits will retry to the service. (#39085)

scwhittle
authored and
ash6898
committed
[mqtt] Fix streaming xlang IT failing the Messaging PostCommit (#39088)

tkaymak
authored and
ash6898
committed
Add a github workflow to publish vllm image. (#39089)

shunping
authored and
ash6898
committed
[Python] Optimize BigQuery copy jobs in file loads using multi-source copy (#38983)

stankiewicz
authored and
ash6898
committed
[OpenTelemetry] Turn off gcp otel auth extension by default. (#38940)

stankiewicz
authored and
ash6898
committed
Fix Flink XVR for Flink 2

Abacn
authored and
ash6898
committed
Fix Go Flink VR conf path

Abacn
authored and
ash6898
committed
Update CHANGES.md and website

Abacn
authored and
ash6898
committed
Disable flaky SDF finalization tests

arunpandianp
authored and
ash6898
committed
Fix Install xmllint

Amar3tto
authored and
ash6898
committed
Moving to 2.76.0-SNAPSHOT on master branch.

Amar3tto
authored and
ash6898
committed
Update beam-master (#39095)

claudevdm
authored and
ash6898
committed
[GSOC 2026] Adding logic to validate and generate an error if there are key… (#38992)

HansMarcus01
authored and
ash6898
committed
update changes log for yaml improvements etc (#39093)

derrickaw
authored and
ash6898
committed
Update beam-master container

shunping
authored and
ash6898
committed
Trigger failed postcommit tests.

shunping
authored and
ash6898
committed
Fix race condition in DirectRunner executor shutdown

shunping
authored and
ash6898
committed
Apply suggested fix

shunping
authored and
ash6898
committed
Fix JsonToRow swallowing downstream errors when runners fuse transforms. (#39098)

authored and
ash6898
committed
Enable playground tests triggered on cron schedule (#39069)

shunping
authored and
ash6898
committed
[Iceberg CDC] Import BaseIncrementalChangelogScan (#38823)

ahmedabu98
authored and
ash6898
committed
[Iceberg CDC] Add utils base, delete reader, and serializable files (#38821)

ahmedabu98
authored and
ash6898
committed
Fix pip ResolutionTooDeep (#39017)

aIbrahiim
authored and
ash6898
committed
[Python] Add UnboundedSource SDF wrapper (#19137) (#38724)

Eliaaazzz
authored and
ash6898
committed
remove infra change (#39104)

derrickaw
authored and
ash6898
committed
Revert "[Python] Optimize BigQuery copy jobs in file loads using multi-source copy" (#39106)

shunping
authored and
ash6898
committed
Write append tables can be asynchronous (#39120)

stankiewicz
authored and
ash6898
committed
Fix typo (#39123)

shunping
authored and
ash6898
committed
Bump google-cloud-aiplatform (#39113)

dependabot[bot]
authored and
ash6898
committed
Update cython requirement from <4,>=3.2.5 to >=3.2.6,<4 in /sdks/python (#39099)

dependabot[bot]
authored and
ash6898
committed
[Website] Update Python version compatibility table (#38969)

jrmccluskey
authored and
ash6898
committed
Docs: update Python version support in Python quickstart (#39122)

jayjayakumar
authored and
ash6898
committed
including GitHub Actions to schedule daily audits and Add documentati… (#39116)

HansMarcus01
authored and
ash6898
committed
Fix a flaky test in ApproximateQuantilesTest (#39132)

shunping
authored and
ash6898
committed
Fix flaky ML RunInference tests by disabling reshuffle on beam.Create (#39118)

shunping
authored and
ash6898
committed
Fix addExperiment() to handle immutable lists and remove redundant defensive copies
ash6898
committed
Restore upload_graph hasExperiment guard to prevent duplicate log message
ash6898
committed

Uh oh!

Commits

Commits on Jun 29, 2026