Fix/add experiment refactor#38252

Open

ash6898 wants to merge 106 commits into

apache:masterfrom

ash6898:fix/add-experiment-refactor

Commits on Jun 28, 2026

[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)

lalitx17
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)

lalitx17
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 12, 2026

Commits on Jun 28, 2026