Skip to content
/ beam Public
forked from apache/beam
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8192 commits
Select commit Hold shift + click to select a range
b59f3d9
Bump github.com/spf13/cobra from 1.10.1 to 1.10.2 in /sdks (#36987)
dependabot[bot] Dec 4, 2025
ece2beb
Java Native Remote Inference (#36623)
Ganeshsivakumar Dec 4, 2025
1831cba
Fix data race in test. (#36992)
claudevdm Dec 4, 2025
9bcae0d
Use HashMap.computeIfAbsent instead of get/put (#36990)
scwhittle Dec 4, 2025
fc31402
Attempt to fix flaky test by not requiring advance to succeed immedia…
scwhittle Dec 4, 2025
7b4a4c9
Update Python Dependencies (#36994)
github-actions[bot] Dec 4, 2025
3ce2abd
Bump jws from 4.0.0 to 4.0.1 in /sdks/typescript (#36996)
dependabot[bot] Dec 4, 2025
84684ae
Reduce weighing overhead for caching blocks (#36897)
scwhittle Dec 5, 2025
b65ec28
Temporary disable a few unit tests in SpannerChangeStreamErrorTest (#…
jiangzzhu Dec 5, 2025
72e84ef
Support Vertex Flex API in GeminiModelHandler (#36982)
dannikay Dec 5, 2025
4266ce0
Update BEAM_DEV_SDK_CONTAINER_TAG. (#37011)
claudevdm Dec 5, 2025
a6932b6
[OpenTelemetry] Add traceparent and tracestate to extended element me…
stankiewicz Dec 5, 2025
242e9c3
Free disk space
Amar3tto Dec 5, 2025
e5a9338
Fix too-many-pings on FnAPI runner under grpc mode (#37013)
shunping Dec 5, 2025
8ff2c94
Update spanner client version. (#36995)
shunping Dec 5, 2025
63177cb
Revert "Reduce weighing overhead for caching blocks (#36897)"
claudevdm Dec 5, 2025
f22d2bc
Save Logical Type and Coder Registry on cloudpickle save main session…
Abacn Dec 5, 2025
e927f2d
Merge pull request #37019 from apache/revert-36897-optimize_weigh
claudevdm Dec 7, 2025
643282b
Skip spannerio tests that depend on emulator on dataflowrunner
Dec 5, 2025
186e6ac
Fix skips.
Dec 5, 2025
1d7283e
Fix indent.
Dec 5, 2025
cbda69b
Format.
claudevdm Dec 7, 2025
c6fc698
Format.
claudevdm Dec 7, 2025
99548bd
Merge branch 'master' into skip-spannertests
claudevdm Dec 7, 2025
32345e7
Merge pull request #37018 from claudevdm/skip-spannertests
claudevdm Dec 8, 2025
acc8f74
Bumpy numpy bounds to include 2.3.X (#36898)
jrmccluskey Dec 8, 2025
118de48
Bump cloud.google.com/go/storage from 1.57.2 to 1.58.0 in /sdks (#37040)
dependabot[bot] Dec 8, 2025
e73b24c
Install redis dependencies for enrichment tests
damccorm Dec 8, 2025
d8c5032
Merge pull request #37041 from apache/free-disk-space-arm
Amar3tto Dec 8, 2025
9a0a343
Bump js-yaml from 3.14.1 to 3.14.2 in /website/www (#36869)
dependabot[bot] Dec 8, 2025
99100aa
Improve linkage check script documentation for git references (#36925)
zhan7236 Dec 8, 2025
7eb6215
Fix nullness in some of Beam SQL (#36890)
kennknowles Dec 8, 2025
1e62187
SolaceIO data loss - remove message ack from close and advance as it …
stankiewicz Dec 8, 2025
2628a38
Merge pull request #37043 from apache/users/damccorm/testDeps
Amar3tto Dec 8, 2025
3ea5e1f
Set keepalive policy for prism grpc server. (#37021)
shunping Dec 8, 2025
2cf0930
Support specifying database in FirestoreV1ReadFn (resolves #36904) (#…
pacoavila808 Dec 8, 2025
973d83f
Update managed-io.md for release 2.70.0-RC2.
Dec 8, 2025
585ad41
Revert "Support Vertex Flex API in GeminiModelHandler (#36982)" (#37051)
dannikay Dec 8, 2025
0275086
[Python] Fix race condition in requirements cache creation (#37042)
NayanMathur411 Dec 9, 2025
c65c198
Bump github.com/aws/aws-sdk-go-v2/config from 1.32.3 to 1.32.4 in /sd…
dependabot[bot] Dec 9, 2025
4be931a
Update Beam website to release 2.70.0
Amar3tto Dec 9, 2025
4f97ad9
Use internal DEFAULT_PICKLE_LIB (#37052)
Abacn Dec 9, 2025
40a32d6
Bump Beartype bounds (#36792)
jrmccluskey Dec 9, 2025
cae5347
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/ml/py310 (…
dependabot[bot] Dec 9, 2025
8afde96
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#37059)
dependabot[bot] Dec 9, 2025
9e8041a
Bump golang.org/x/oauth2 from 0.33.0 to 0.34.0 in /sdks (#37056)
dependabot[bot] Dec 9, 2025
917cb2c
Adds more SchemaFieldNumbers to classes used by Iceberg (#37055)
chamikaramj Dec 9, 2025
a3890c6
Bump golang.org/x/net from 0.47.0 to 0.48.0 in /sdks (#37060)
dependabot[bot] Dec 9, 2025
d119b29
[SQL] add SHOW command (#36509)
ahmedabu98 Dec 9, 2025
0274331
Unpin the pip version in setupVirtualenv (#36745)
jrmccluskey Dec 9, 2025
7f47191
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37068)
dependabot[bot] Dec 10, 2025
314d040
[Go SDK] Add WithNoOutputTimestamp matching Java SDK. (#37063)
scwhittle Dec 10, 2025
fc243b7
Handle cancelled workflow runs in flaky test detection tool (#37072)
Amar3tto Dec 10, 2025
625625b
Bump nodemailer from 7.0.7 to 7.0.11 in /scripts/ci/issue-report (#36…
dependabot[bot] Dec 10, 2025
48869d2
Bump node-forge from 1.3.1 to 1.3.2 in /sdks/typescript (#36920)
dependabot[bot] Dec 10, 2025
f967bde
Bq timestamp schema conversion (#36986)
claudevdm Dec 10, 2025
72026d3
Bump js-yaml from 4.1.0 to 4.1.1 in /scripts/ci/pr-bot (#36850)
dependabot[bot] Dec 10, 2025
8d6cf28
Bump glob from 10.4.5 to 10.5.0 in /scripts/ci/pr-bot (#36851)
dependabot[bot] Dec 10, 2025
d569788
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/py310 (#37…
dependabot[bot] Dec 10, 2025
0a83ce4
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/ml/py312 (…
dependabot[bot] Dec 10, 2025
f7da723
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/py313 (#37…
dependabot[bot] Dec 10, 2025
fe5b3ca
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/py312 (#37…
dependabot[bot] Dec 10, 2025
ce88469
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/ml/py313 (…
dependabot[bot] Dec 10, 2025
f0595a9
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/ml/py311 (…
dependabot[bot] Dec 10, 2025
e22f332
Bump urllib3 from 2.5.0 to 2.6.0 in /sdks/python/container/py311 (#37…
dependabot[bot] Dec 10, 2025
af42a1c
Bump commons-cli:commons-cli from 1.9.0 to 1.11.0 (#36802)
dependabot[bot] Dec 10, 2025
a6bfe01
Add yaml to requirements (#37073)
damccorm Dec 10, 2025
cbcdf1b
Bump transformers (#36250)
dependabot[bot] Dec 10, 2025
c8f5147
updated tox (#37047)
derrickaw Dec 10, 2025
dd3de10
Update Python Dependencies (#37074)
github-actions[bot] Dec 11, 2025
15b50e2
Fix clean up image skipped images if there are child path (#36899)
Abacn Dec 11, 2025
576a802
Updates Beam Fn API container used by Dataflow at HEAD (#37088)
chamikaramj Dec 11, 2025
a4b3dff
Allow using trigger file to trigger yaml xlang workflow. (#37095)
shunping Dec 12, 2025
f9bccb8
Warn against DebeziumIO not resilient to worker crash or restart (#37…
Abacn Dec 12, 2025
8a4a69e
Repin pip to 2.50.1 to fix hanging yaml xlang workflow (#37092)
shunping Dec 12, 2025
8ef7249
convert to playground example
derrickaw Dec 12, 2025
31a96b6
Sort the results before assertion (#37097)
shunping Dec 12, 2025
468f7d5
Bump google.golang.org/protobuf from 1.36.10 to 1.36.11 in /sdks (#37…
dependabot[bot] Dec 15, 2025
722dc6d
Allow inference args to be passed in for most cases (#37094)
damccorm Dec 15, 2025
a13af81
[GH Actions] tackle unmaintained Gradle GH actions (#37064)
snazy Dec 15, 2025
ccad976
Merge pull request #37098: Convert cogroupbykey static example to a p…
kennknowles Dec 15, 2025
8e70cba
Pass options in DaskOptions inheritance hierarchy only for Dask runne…
Abacn Dec 15, 2025
d7cd81a
Ignore a few options in doc for jdbc managed ios. (#37111)
shunping Dec 15, 2025
7e5e3b8
[Dataflow Streaming] Move timer tag logic to WindmillStateTagUtil (#3…
arunpandianp Dec 16, 2025
3516b5d
[Dataflow Streaming] Fix race in StreamingEngineWorkComitter during s…
arunpandianp Dec 16, 2025
65f1ade
Update release date
Amar3tto Dec 16, 2025
5089191
Adding release-2.70.0-postrelease to protected branches in .asf.yaml
Dec 16, 2025
ef24543
Merge pull request #37053 from apache/updates_managed_io_docs_2.70.0_rc2
Amar3tto Dec 16, 2025
1543007
Merge pull request #37062 from apache/release-270-website
Amar3tto Dec 16, 2025
6415a4b
Bump cloud.google.com/go/spanner from 1.86.1 to 1.87.0 in /sdks (#37119)
dependabot[bot] Dec 16, 2025
547ab60
Update github action runner image (#37116)
shunping Dec 16, 2025
f807533
Refresh Iceberg Table metadata every 2 minutes instead of before each…
JayajP Dec 16, 2025
d71deb6
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37118)
dependabot[bot] Dec 16, 2025
471ebc4
fix: Adapt write() example of KinesisIO to AWS SDK V2 interface (#37122)
yuwtennis Dec 17, 2025
afbbf53
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37128)
dependabot[bot] Dec 17, 2025
1b4e0c2
Modernize terraform config for self-hosted runners (#37127)
shunping Dec 17, 2025
7a2a5bf
Bump filelock from 3.20.0 to 3.20.1 in /sdks/python/container/ml/py31…
dependabot[bot] Dec 17, 2025
8cc26a4
fix circular PipelineGraph import (#37134)
derrickaw Dec 17, 2025
ddc4976
Bump github.com/nats-io/nats.go from 1.47.0 to 1.48.0 in /sdks (#37138)
dependabot[bot] Dec 18, 2025
c111c8b
[KafkaIO] Make ReadFromKafkaDoFn restriction trackers unsplittable (#…
sjvanrossum Dec 18, 2025
7487401
Update Beam version for republish released docker containers workflow…
Amar3tto Dec 18, 2025
96d195b
Bump github.com/nats-io/nats-server/v2 from 2.12.2 to 2.12.3 in /sdks…
dependabot[bot] Dec 18, 2025
405d2db
Clean up unused Jenkins files (#37148)
jrmccluskey Dec 18, 2025
fe9c78a
fix interactive environment circular import (#37147)
derrickaw Dec 18, 2025
c0fe932
Update BOM to 26.73.0 (#37142)
Amar3tto Dec 19, 2025
5d658c1
[Dataflow Streaming] Improve logs (#37152)
arunpandianp Dec 19, 2025
dfe01c0
Add WindmillTagEncoding Interface (#37150)
arunpandianp Dec 19, 2025
423a3c3
update py container tag (#37144)
ahmedabu98 Dec 19, 2025
cc8dc2f
Add timestamp precision option to bigquery storage read for TIMESTAMP…
claudevdm Dec 22, 2025
39652cf
Address the warning in a DoFn from periodicsequence.py (#37153)
tvalentyn Dec 22, 2025
ff01a52
Bump org.javacc.javacc from 3.0.3 to 4.0.3 (#37158)
dependabot[bot] Dec 22, 2025
87de10f
Add support for kw_only dataclasses (addresses #36978) (#36979)
assaf127 Dec 22, 2025
b987d37
Add table information to BigQueryStorageApiInsertError (#36832)
hekk-kaori-maeda Dec 22, 2025
3464da5
Check that billing project is not null in BigQuerySourceBase (#36788)
clairemcginty Dec 22, 2025
92913b7
fix: Add limit to stream partitions query to avoid loading old cell v…
jackdingilian Dec 22, 2025
e655f5c
Support log level override for direct runner (#37100)
Abacn Dec 22, 2025
c511260
make pulsar getters public (#37169)
ahmedabu98 Dec 22, 2025
ca27526
Iceberg fileio close (#37168)
ahmedabu98 Dec 22, 2025
c883631
[yaml] - fix windowing link (#37167)
derrickaw Dec 24, 2025
358e007
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37179)
dependabot[bot] Dec 24, 2025
71b1e83
fix provider testing issue (#37183)
derrickaw Dec 26, 2025
9067220
Wanting to try out and develop ML examples. Working with pabloem. (#3…
yalah5084 Dec 26, 2025
dad0287
fix: handle ResponseException correctly, honor throwWriteExceptions w…
EgbertW Dec 26, 2025
9c4dc4d
Bump google.golang.org/grpc from 1.77.0 to 1.78.0 in /sdks (#37185)
dependabot[bot] Dec 28, 2025
f7a9b26
Allow yield and return in the same 'process' if return doesn't have a…
tvalentyn Dec 29, 2025
7b13d42
Deduplicate MonitoringInfo in PortableMetrics (#37066)
Suvrat1629 Dec 29, 2025
63f42c2
Make TypeScript test reporter optional (#37182)
junaiddshaukat Dec 30, 2025
6e4bad2
Add Envoy Data Plane dependency (#37196)
tarun-google Dec 30, 2025
9e3dd1a
fix CVE-2024-57699 by pinning version (#37200)
stankiewicz Dec 30, 2025
0eb3626
Add Albertsons case study (#37201)
damccorm Dec 31, 2025
cf8c102
Update link URL for Albertsons case study (#37203)
utkarshparekh Dec 31, 2025
1a7205f
Fix publish date (should be published immediately)
damccorm Dec 31, 2025
1cadc5f
Fix publish year
damccorm Dec 31, 2025
0676463
fix variable names (#37206)
dermasmid Jan 3, 2026
a3af5d5
feat(BigQueryWriteSchemaTransformProvider): add output collection nam…
liferoad Jan 3, 2026
f7a5bbd
Revert "SolaceIO data loss - remove message ack from close and advanc…
stankiewicz Jan 5, 2026
78eb4a2
fix: Enable `create_test` to correctly parse and apply external provi…
liferoad Jan 5, 2026
ab14c43
Support for EnvoyRateLimiter in Beam Python SDK (#37135)
tarun-google Jan 5, 2026
44ed498
Add Picosecond timestamp support to storage API WriteTableRows (#37091)
claudevdm Jan 5, 2026
19f9eb0
[yaml] - add multi-line windowing json support (#37174)
derrickaw Jan 5, 2026
207f9d0
Update names.py (#37222)
apanich Jan 6, 2026
16996bb
docs: fix typo and clarify BigQuery error handling method requirement…
liferoad Jan 6, 2026
716ce6a
Bump aiohttp from 3.13.2 to 3.13.3 in /sdks/python/container/py312 (#…
dependabot[bot] Jan 6, 2026
34b8eea
Introduce Python Wordcount with Rust Wrapped Functions (#37234)
jrmccluskey Jan 6, 2026
bf5c0db
Bump github.com/tetratelabs/wazero from 1.10.1 to 1.11.0 in /sdks (#3…
dependabot[bot] Jan 6, 2026
3319517
Fix CHANGES.md format (#37236)
Abacn Jan 6, 2026
d55cf58
Flink 2 support prerequisites (#37133)
Abacn Jan 7, 2026
9d2abcf
Bump numpy versions (#37238)
damccorm Jan 7, 2026
4777bef
Add nanosecond timestamp support for Storage write when writing Gener…
claudevdm Jan 7, 2026
8a90113
Moving to 2.72.0-SNAPSHOT on master branch.
Jan 7, 2026
3c3e202
add some debug checks in test case and remove an extra line (#37237)
derrickaw Jan 7, 2026
98999f5
Update CONTRIBUTING.md (#37187)
exploratoryprorammer Jan 7, 2026
881bbaa
DynamicDestinationsHelper.ConstantTimePartitioningClusteringDestinati…
stankiewicz Jan 7, 2026
511036a
Revise CHANGES.md for upcoming release (#37243)
damccorm Jan 7, 2026
bfff80b
[Dataflow Streaming] Add WindmillTagEncodingV2. (#37151)
arunpandianp Jan 8, 2026
be924b7
Update BeamModulePlugin.groovy (#37233)
apanich Jan 8, 2026
6bedec3
Bump cloud.google.com/go/bigtable from 1.40.1 to 1.41.0 in /sdks (#37…
dependabot[bot] Jan 8, 2026
7694450
Fix CONNECTION_STRING format in tox.ini (#37250)
damccorm Jan 8, 2026
d7fa511
[yaml] : add more error handling tests and website example (#37245)
derrickaw Jan 8, 2026
21c0842
Add note about providers to yaml jinja section.
robertwb Jan 8, 2026
ef0a03c
Flink 2.0 support (#37175)
Abacn Jan 8, 2026
139724d
Map TIMSETAMP(12) BQ type -> timestamp-nanos Avro type in default sch…
claudevdm Jan 9, 2026
815041e
Support for RateLimiter in Beam Remote Model Handler (#37218)
tarun-google Jan 9, 2026
38c88a8
Merge pull request #37263 Add note about providers to yaml jinja sect…
robertwb Jan 9, 2026
8801afd
Update to upstream caller (#37270)
derrickaw Jan 9, 2026
1575b29
[Docs] Fix grammar: 'should triggered' -> 'should be triggered' (#37278)
Eliaaazzz Jan 12, 2026
c481b90
Update Python Dependencies (#37280)
github-actions[bot] Jan 12, 2026
990276f
Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#37282)
dependabot[bot] Jan 12, 2026
335e96b
[yaml] : Add final expand pipeline ut (#37260)
derrickaw Jan 12, 2026
072dd82
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#37283)
dependabot[bot] Jan 12, 2026
94ce718
Fix link due to trailing slashes.
robertwb Jan 12, 2026
d022338
update RateLimiter execution function name (#37287)
tarun-google Jan 12, 2026
be8dfed
Bump github.com/aws/aws-sdk-go-v2/config from 1.32.6 to 1.32.7 in /sd…
dependabot[bot] Jan 13, 2026
697d299
feat: Add support for custom prediction routes in Vertex AI inference…
liferoad Jan 13, 2026
e5cac6c
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37291)
dependabot[bot] Jan 13, 2026
3783f58
Add step to free disk space in workflow (#37246)
damccorm Jan 13, 2026
fdd25a4
Update trivial inference for Python 3.14 (#37248)
jrmccluskey Jan 13, 2026
1330346
Bump Python dev container version (#37293)
Abacn Jan 13, 2026
752da38
Catch breaking import error (#37295)
tarun-google Jan 13, 2026
4dcc27d
Update users.yml - fix bad role label (#37192)
pabloem Jan 13, 2026
aad5864
Support picosecond tiemstamps when writing GenericRecord and Beam Row…
claudevdm Jan 14, 2026
331b08e
Add new features to changes.md (#37308)
tarun-google Jan 14, 2026
daa0f15
Bump golang.org/x/text from 0.32.0 to 0.33.0 in /sdks (#37301)
dependabot[bot] Jan 14, 2026
fc39ee6
Update neo4j resource manager (#37310)
Abacn Jan 14, 2026
097e90a
Revert spanner version (#37305)
damccorm Jan 14, 2026
9d751d1
Bump golang.org/x/sys from 0.39.0 to 0.40.0 in /sdks (#37269)
dependabot[bot] Jan 14, 2026
674763d
Fix java versions in release guide (#37314)
damccorm Jan 14, 2026
ebcf5ab
Bump golang.org/x/net from 0.48.0 to 0.49.0 in /sdks (#37302)
dependabot[bot] Jan 15, 2026
68e0d66
[Python] Fix AttributeError in ExternalTransform.expand by using get_…
Eliaaazzz Jan 15, 2026
a15de20
Remove standalone uses of the apitools HttpError class (#37296)
jrmccluskey Jan 15, 2026
3aaf839
add back ticks to highlight command to be used (#37321)
derrickaw Jan 15, 2026
60f1981
Increase timeout for Python YAML RC validation job (#37322)
damccorm Jan 15, 2026
c489cb7
[Do Not Merge] Test bumping httplib2 upper bound to modern version (#…
jrmccluskey Jan 15, 2026
17198be
fix: prevent NoSuchElementException in AppendFilesToTables (#37217)
liferoad Jan 16, 2026
5f5fc1f
Add LRU cache eviction to CachingStateProvider (#37214)
junaiddshaukat Jan 16, 2026
337bb6d
Bump keras from 3.12.0 to 3.13.1 in /sdks/python/container/ml/py310 (…
dependabot[bot] Jan 16, 2026
cc53097
Fix spanner io hang by closing connections (#37327)
damccorm Jan 16, 2026
82ebcb2
Pin spanner to old version in gcp bom (#37329)
damccorm Jan 16, 2026
34f7d87
Revert "Use requirements.txt instead of setup.py for juliaset example"
damccorm Jan 16, 2026
f26f136
Change setup.py to use setuptools
damccorm Jan 16, 2026
9fba823
Add Terraform files to deploy Envoy RateLimiter (#37285)
tarun-google Jan 16, 2026
600bd61
[Dataflow Streaming] Remove GetWorkBudgetRefresher which is unused an…
scwhittle Jan 19, 2026
fb06f1b
Update Python Dependencies (#37361)
github-actions[bot] Jan 20, 2026
e4f48ad
Fix typo in workflow name for updating dependencies (#37362)
damccorm Jan 20, 2026
8a43f5e
Merge pull request #37286 Fix link due to trailing slashes.
robertwb Jan 20, 2026
52e2847
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#37367)
dependabot[bot] Jan 21, 2026
e7c80cd
Add more info to CHANGES on logical type issue (#37368)
damccorm Jan 21, 2026
84b467b
Add Datadog IO (#37319)
derrickaw Jan 21, 2026
e4a5eea
Adds a new SchemaCoderPayload proto to use for portable SchemaCoders.
acrites Jan 21, 2026
f1e4b74
Bump github.com/linkedin/goavro/v2 from 2.14.1 to 2.15.0 in /sdks (#3…
dependabot[bot] Jan 21, 2026
204d3a5
Update Dataflow dev python containers (#37358)
tvalentyn Jan 22, 2026
7eaf66c
Update managed-io.md for release 2.71.0-RC3. (#37333)
damccorm Jan 22, 2026
4bac878
Migrate Cloud Build usage to Python client (#37309)
jrmccluskey Jan 22, 2026
1e6b675
Adding release-2.71.0-postrelease to protected branches in .asf.yaml
damccorm Jan 22, 2026
966762c
Update website for 2.71.0 release (#37256)
damccorm Jan 22, 2026
86abab2
[#37209] Enhance serialization error messages (#37298)
PDGGK Jan 22, 2026
94de2a1
Update BEAM_DEV_SDK_CONTAINER_TAG to latest version (#37373)
damccorm Jan 22, 2026
99d09d4
Update default release and RC versions in republish workflow (#37385)
damccorm Jan 22, 2026
ce6a4e5
Merge pull request #37337 from apache/users/damccorm/setup_file
damccorm Jan 22, 2026
27ae93b
notebook (#37393)
claudevdm Jan 22, 2026
4b24045
GCS client library migration in Java SDK - part 1 (#36876)
shunping Jan 22, 2026
b50a099
Remove Read and Write PubsubLite for Yaml (#37383)
derrickaw Jan 22, 2026
16993ac
Update Go version from 1.25.2 to 1.25.6 (#37395)
damccorm Jan 23, 2026
59b5f3a
Bump lodash from 4.17.21 to 4.17.23 in /sdks/typescript (#37380)
dependabot[bot] Jan 23, 2026
b61995d
Bump sentencepiece from 0.1.97 to 0.2.1 in /sdks/python/apache_beam/e…
dependabot[bot] Jan 23, 2026
9b3aa12
remove pubsublite from python sdk (#37401)
derrickaw Jan 24, 2026
7a278e2
remove pubsublite tests - as depreciated (#37396)
derrickaw Jan 24, 2026
f819f2e
Update bom to 26.74.0 (excluding spanner) (#37384)
damccorm Jan 24, 2026
07e580a
Bump cloud.google.com/go/storage from 1.58.0 to 1.59.1 in /sdks (#37315)
dependabot[bot] Jan 26, 2026
f14f1ce
docs: expand About section with website architecture details (#37242)
franzonia137 Jan 26, 2026
1b60ce6
Add YAML SQL example using calcite_connection_properties (#37303)
pirzada-ahmadfaraz Jan 26, 2026
7cb1a05
disabled beam metrics report job (#37420)
aIbrahiim Jan 26, 2026
d090aab
Update BEAM_DEV_SDK_CONTAINER_TAG version (#37400)
damccorm Jan 26, 2026
f5af98b
Fix website workflows (#37421)
Amar3tto Jan 26, 2026
911ec6a
Add filter() method to PCollection in TypeScript SDK (#37408)
junaiddshaukat Jan 26, 2026
adc04ca
Fix gRPC failures in Python PreCommit tests (#37350)
aIbrahiim Jan 26, 2026
d0014ff
Simplify encoding kw_only args and test init=False args. (#37231)
benfei Jan 26, 2026
6a399df
Update ChangeStreamDao to query different TVF for postgresSQL based o…
chenxuesdu Jan 26, 2026
f8013e6
Fix str(WindowedValueCoder) crash when underlying coder isn't KV code…
Abacn Jan 26, 2026
e12436a
Merge pull request #37376: Adds a new SchemaCoderPayload proto to use…
kennknowles Jan 26, 2026
1222ae5
Bump python-multipart in /sdks/python/container/ml/py312 (#37426)
dependabot[bot] Jan 27, 2026
52b9910
fix key error for huggingface notebook (#37435)
ahmedabu98 Jan 27, 2026
672b888
Enable some more tests in runner v2 batch mode. (#37363)
shunping Jan 27, 2026
47df6ae
[Spanner Change Streams] Fix potential data loss issue by ensuring to…
scwhittle Jan 28, 2026
0b32d24
Update yaml notebook (#37369)
derrickaw Jan 28, 2026
f7784d8
Disable Beam Metrics Report workflow (#37440)
aIbrahiim Jan 28, 2026
928ad7e
Bump github.com/nats-io/nats-server/v2 from 2.12.3 to 2.12.4 in /sdks…
dependabot[bot] Jan 28, 2026
e26b76b
better formatting output (#37441)
ahmedabu98 Jan 28, 2026
61fe950
Bump cloud.google.com/go/storage from 1.59.1 to 1.59.2 in /sdks (#37443)
dependabot[bot] Jan 29, 2026
98c980a
Bump go.mongodb.org/mongo-driver from 1.17.6 to 1.17.7 in /sdks (#37381)
dependabot[bot] Jan 29, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
103 changes: 100 additions & 3 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -35,16 +35,113 @@ github:
projects: true

# Give some users issue triage permissions
# Cannot have >10 at any given time per https://github.com/apache/infrastructure-asfyaml?tab=readme-ov-file#triage
collaborators:
- pcoet
- olehborysevych
- rshamunov
- Amar3tto
- mrshakirov
- akashorabek
- derrickaw
- claudevdm
- shunping

enabled_merge_buttons:
squash: true
merge: true
rebase: false

protected_branches:
master: {}
release-2.71.0-postrelease: {}
release-2.71: {}
release-2.70.0-postrelease: {}
release-2.70: {}
release-2.69.0-postrelease: {}
release-2.69: {}
release-2.68.0-postrelease: {}
release-2.68: {}
release-2.67.0-postrelease: {}
release-2.67: {}
release-2.66.0-postrelease: {}
release-2.66: {}
release-2.65.0-postrelease: {}
release-2.65: {}
release-2.64.0-postrelease: {}
release-2.64: {}
release-2.63.0-postrelease: {}
release-2.63: {}
release-2.62.0: {}
release-2.61.0: {}
release-2.60.0: {}
release-2.59.0: {}
release-2.58.1: {}
release-2.58.0: {}
release-2.57.0: {}
release-2.56.0: {}
release-2.55.1: {}
release-2.55.0: {}
release-2.54.0: {}
release-2.53.0: {}
release-2.52.0: {}
release-2.51.0: {}
release-2.50.0: {}
release-2.49.0: {}
release-2.48.0: {}
release-2.47.0: {}
release-2.46.0: {}
release-2.45.0: {}
release-2.44.0: {}
release-2.43.0: {}
release-2.42.0: {}
release-2.41.0: {}
release-2.40.0: {}
release-2.39.0: {}
release-2.38.0: {}
release-2.37.0: {}
release-2.36.0: {}
release-2.35.0: {}
release-2.34.0: {}
release-2.33.0: {}
release-2.32.0: {}
release-2.31.0: {}
release-2.30.0: {}
release-2.29.0: {}
release-2.28.0: {}
release-2.27.0: {}
release-2.26.0: {}
release-2.25.0: {}
release-2.24.0: {}
release-2.23.0: {}
release-2.22.0: {}
release-2.21.0: {}
release-2.20.0: {}
release-2.19.0: {}
release-2.18.0: {}
release-2.17.0: {}
release-2.16.0: {}
release-2.15.0: {}
release-2.14.0: {}
release-2.13.0: {}
release-2.12.0: {}
release-2.11.0: {}
release-2.10.0: {}
release-2.8.0: {}
release-2.8.0: {}
release-2.7.0: {}
release-2.6.0: {}
release-2.5.0: {}
release-2.4.0: {}
release-2.3.0: {}
release-2.2.0: {}
release-2.1.1: {}
release-2.1.0: {}
release-0.6.0: {}
release-0.5.0: {}
release-0.4.0: {}
release-0.4.0-incubating: {}
release-0.3.0-incubating: {}
release-0.2.0-incubating: {}
release-0.1.0-incubating: {}

notifications:
commits: commits@beam.apache.org
issues: github@beam.apache.org
Expand Down
30 changes: 30 additions & 0 deletions .editorconfig
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# EditorConfig is awesome: https://EditorConfig.org

# top-most EditorConfig file
root = true

[*]
indent_style = space
indent_size = 2
end_of_line = lf
charset = utf-8
trim_trailing_whitespace = true
insert_final_newline = true

[*.{go,mod,sum}]
indent_style = tab
indent_size = unset

[Dockerfile]
indent_size = 4
53 changes: 53 additions & 0 deletions .gemini/config.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,53 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

# Config for the Gemini Pull Request Review Bot.
# https://github.com/marketplace/gemini-code-assist

# Enables fun features such as a poem in the initial pull request summary.
# Type: boolean, default: false.
have_fun: false

code_review:
# Disables Gemini from acting on PRs.
# Type: boolean, default: false.
disable: false

# Minimum severity of comments to post (LOW, MEDIUM, HIGH, CRITICAL).
# Type: string, default: MEDIUM.
comment_severity_threshold: MEDIUM

# Max number of review comments (-1 for unlimited).
# Type: integer, default: -1.
max_review_comments: -1

pull_request_opened:
# Post helpful instructions when PR is opened.
# Type: boolean, default: false.
help: false

# Post PR summary when opened.
# Type boolean, default: true.
summary: true

# Post code review on PR open.
# Type boolean, default: true.
code_review: false

# List of glob patterns to ignore (files and directories).
# Type: array of string, default: [].
ignore_patterns: []
7 changes: 6 additions & 1 deletion .github/ACTIONS.md
Original file line number Diff line number Diff line change
Expand Up @@ -86,15 +86,20 @@ jobs:
* **DO NOT** Approve and Run changes in the workflows in the PR Conversation tab, under "Workflow(s) awaiting approval".
* For approving the updates in the workflows, you should go to the Repository Actions and filter All Workflows by `action_required`. The search will display the workflows that need to be reviewed before running. **Please make sure reviewing the file that is referenced by the workflow.**
* Seed job will be emulated using the `Approve and Run` built-in feature of GitHub Actions, since the workflows will use the `pull_request_target` directive; no modifications would be allowed either for new or existent jobs unless a committer explicitly approves the job from GitHub Actions UI.
### Issue Management

#### Issue Management
Phrases self-assign, close, or manage labels on an issue:
| Phrase | Effect |
|--------|--------|
| `.take-issue` | Self-assign the issue |
| `.free-issue` | Self-unassign the issue |
| `.close-issue` | Close the issue as completed |
| `.close-issue not_planned` | Close the issue as not-planned |
| `.reopen-issue` | Reopen a closed issue |
| `.add-labels` | Add comma separated labels to the issue (e.g. `add-labels l1, 'l2 with spaces'`) |
| `.remove-labels` | Remove comma separated labels to the issue (e.g. `remove-labels l1, 'l2 with spaces'`) |
| `.set-labels` | Sets comma separated labels to the issue and removes any other labels (e.g. `set-labels l1, 'l2 with spaces'`) |

## Security Model

For information on the Beam CI security model, see https://cwiki.apache.org/confluence/display/BEAM/CI+Security+Model
5 changes: 4 additions & 1 deletion .github/ISSUE_TEMPLATE/bug.yml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this bug report! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Thanks for taking the time to fill out this bug report! Once you've created an issue, you can self-assign by commenting `.take-issue`, self-unassign by commenting `.free-issue`, and close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
Expand All @@ -50,6 +50,7 @@ body:
- "Priority: 2 (default / most bugs should be filed as P2)"
- "Priority: 1 (data loss / total loss of function)"
- "Priority: 0 (outage / urgent vulnerability)"
default: 1
validations:
required: true
- type: checkboxes
Expand All @@ -63,10 +64,12 @@ body:
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam YAML"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Infrastructure"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
Expand Down
5 changes: 4 additions & 1 deletion .github/ISSUE_TEMPLATE/failing_test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this feature request! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Thanks for taking the time to fill out this failing test report! Once you've created an issue, you can self-assign by commenting `.take-issue`, self-unassign by commenting `.free-issue`, and close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
Expand Down Expand Up @@ -56,6 +56,7 @@ body:
- "Priority: 2 (backlog / disabled test but we think the product is healthy)"
- "Priority: 1 (unhealthy code / failing or flaky postcommit so we cannot be sure the product is healthy)"
- "Priority: 0 (outage / failing precommit test impacting development)"
default: 1
validations:
required: true
- type: checkboxes
Expand All @@ -69,10 +70,12 @@ body:
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam YAML"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Infrastructure"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
Expand Down
5 changes: 4 additions & 1 deletion .github/ISSUE_TEMPLATE/feature.yml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this feature request! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Thanks for taking the time to fill out this feature request! Once you've created an issue, you can self-assign by commenting `.take-issue`, self-unassign by commenting `.free-issue`, and close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
Expand All @@ -44,6 +44,7 @@ body:
options:
- "Priority: 3 (nice-to-have improvement)"
- "Priority: 2 (default / most feature requests should be filed as P2)"
default: 1
validations:
required: true
- type: checkboxes
Expand All @@ -57,10 +58,12 @@ body:
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam YAML"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Infrastructure"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
Expand Down
5 changes: 4 additions & 1 deletion .github/ISSUE_TEMPLATE/task.yml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this task! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Thanks for taking the time to fill out this task! Once you've created an issue, you can self-assign by commenting `.take-issue`, self-unassign by commenting `.free-issue`, and close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
Expand All @@ -45,6 +45,7 @@ body:
- "Priority: 3 (nice-to-have improvement)"
- "Priority: 2 (default / most normal work should be filed as P2)"
- "Priority: 1 (urgent / mostly reserved for critical bugs)"
default: 1
validations:
required: true
- type: checkboxes
Expand All @@ -58,10 +59,12 @@ body:
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam YAML"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Infrastructure"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
Expand Down
12 changes: 6 additions & 6 deletions .github/PULL_REQUEST_TEMPLATE.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,15 +8,15 @@ Thank you for your contribution! Follow this checklist to help us incorporate yo
- [ ] Update `CHANGES.md` with noteworthy changes.
- [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).

See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/get-started-contributing/#make-the-reviewers-job-easier).
See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://github.com/apache/beam/blob/master/CONTRIBUTING.md#make-the-reviewers-job-easier).

To check the build health, please visit [https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md](https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md)

GitHub Actions Tests Status (on master branch)
------------------------------------------------------------------------------------------------
[![Build python source distribution and wheels](https://github.com/apache/beam/workflows/Build%20python%20source%20distribution%20and%20wheels/badge.svg?branch=master&event=schedule)](https://github.com/apache/beam/actions?query=workflow%3A%22Build+python+source+distribution+and+wheels%22+branch%3Amaster+event%3Aschedule)
[![Python tests](https://github.com/apache/beam/workflows/Python%20tests/badge.svg?branch=master&event=schedule)](https://github.com/apache/beam/actions?query=workflow%3A%22Python+Tests%22+branch%3Amaster+event%3Aschedule)
[![Java tests](https://github.com/apache/beam/workflows/Java%20Tests/badge.svg?branch=master&event=schedule)](https://github.com/apache/beam/actions?query=workflow%3A%22Java+Tests%22+branch%3Amaster+event%3Aschedule)
[![Go tests](https://github.com/apache/beam/workflows/Go%20tests/badge.svg?branch=master&event=schedule)](https://github.com/apache/beam/actions?query=workflow%3A%22Go+tests%22+branch%3Amaster+event%3Aschedule)
[![Build python source distribution and wheels](https://github.com/apache/beam/actions/workflows/build_wheels.yml/badge.svg?event=schedule&&?branch=master)](https://github.com/apache/beam/actions?query=workflow%3A%22Build+python+source+distribution+and+wheels%22+branch%3Amaster+event%3Aschedule)
[![Python tests](https://github.com/apache/beam/actions/workflows/python_tests.yml/badge.svg?event=schedule&&?branch=master)](https://github.com/apache/beam/actions?query=workflow%3A%22Python+Tests%22+branch%3Amaster+event%3Aschedule)
[![Java tests](https://github.com/apache/beam/actions/workflows/java_tests.yml/badge.svg?event=schedule&&?branch=master)](https://github.com/apache/beam/actions?query=workflow%3A%22Java+Tests%22+branch%3Amaster+event%3Aschedule)
[![Go tests](https://github.com/apache/beam/actions/workflows/go_tests.yml/badge.svg?event=schedule&&?branch=master)](https://github.com/apache/beam/actions?query=workflow%3A%22Go+tests%22+branch%3Amaster+event%3Aschedule)

See [CI.md](https://github.com/apache/beam/blob/master/CI.md) for more information about GitHub Actions CI.
See [CI.md](https://github.com/apache/beam/blob/master/CI.md) for more information about GitHub Actions CI or the [workflows README](https://github.com/apache/beam/blob/master/.github/workflows/README.md) to see a list of phrases to trigger workflows.
Loading