Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
89 commits
Select commit Hold shift + click to select a range
52b380f
Support directory separator for Python local filesystem
liferoad Mar 17, 2025
d2eac7a
fixed the tests
liferoad Mar 17, 2025
f671d1b
Merge branch 'master' into directory-separator
liferoad Mar 22, 2025
54b60de
ignore TypeError
liferoad Mar 22, 2025
ddbb675
fix lint
liferoad Mar 23, 2025
6599655
minor fix
liferoad Mar 29, 2025
3b14a15
Enforce ordering to avoid svn conflicts (#34405)
damccorm Mar 24, 2025
d2e06a1
Update build.gradle (#34401)
liferoad Mar 24, 2025
65807ca
Create a varint32 coder and used it for RowCoder (#34354)
Abacn Mar 24, 2025
2a58f05
Factor out a get_default_sql_provider() function.
zilin Mar 24, 2025
3005046
Add warning comment so that folks don't change this
damccorm Mar 24, 2025
10a7b58
Add to CHANGES.md follow up negative int32 fix (#34408)
Abacn Mar 24, 2025
1310864
[Dataflow Streaming] Improve exception handling in PubsubSink to rese…
scwhittle Mar 25, 2025
b140b6c
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#34416)
dependabot[bot] Mar 25, 2025
aec38c8
Add docs for yaml dependencies. (#34345)
robertwb Mar 25, 2025
b622914
track GetWork from WindmillWorker to UserWorker in proxyless path (#3…
m-trieu Mar 26, 2025
13421c6
fix: python ref in guide for combining pcol single value (#34282)
jbandoro Mar 26, 2025
5e7af20
Update dataflow_cost_benchmark. Update website: add ML pipelines perf…
Amar3tto Mar 26, 2025
68f5936
Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#34430)
dependabot[bot] Mar 26, 2025
dc20ad4
SnowflakeIO: be consistent with backslash escape char
turb Feb 11, 2025
87cdb31
tolerate integer overflow when encoding varint32 (#34439)
Abacn Mar 26, 2025
4213a02
remove dependency of core-runners in kafka:io (#34442)
Naireen Mar 26, 2025
6afe60e
Use list instead of set to make type hint serialization deterministic
AdrS Mar 24, 2025
0dc6d37
Bump serialize-javascript and mocha in /scripts/ci/pr-bot (#34425)
dependabot[bot] Mar 27, 2025
cb1e9ad
Update build.gradle (#34412)
liferoad Mar 27, 2025
3aecc59
[Java] Improve Java FnStatus page to include bundle start time, oldes…
scwhittle Mar 27, 2025
9a33a50
Move ExecutionStateTracker.nextBundleLullDurationReportMs reset attem…
Abacn Mar 27, 2025
0cf90c0
correcting array truncation logic (resolves #34276) (#34421)
TanuSharma2511 Mar 27, 2025
f60af63
adding google-crc32c (#34374)
TanuSharma2511 Mar 27, 2025
181c6f6
Bump dataflow java container version to beam-master-20250326 (#34447)
Amar3tto Mar 27, 2025
0606995
upgraded gcp-bom to 26.57.0 (#34399)
sarthakbhutani Mar 27, 2025
cc5e9c8
Add known protobuf issue (#34449)
damccorm Mar 27, 2025
ce6e25e
Update run_rc_validation.yml (#34453)
liferoad Mar 27, 2025
2b8ea8a
extend timeout (#34448)
stankiewicz Mar 27, 2025
ee57aad
Fix typo in BigQuery Python Documentation (#34317)
AaronTrelstad Mar 27, 2025
d9326c2
#34009 avro generic record to beam row conversion added support for a…
wollowizard Mar 27, 2025
15bfb38
Remove legacy setup.py clean command (#34443)
tvalentyn Mar 27, 2025
110baa0
Bump @babel/runtime (#34263)
dependabot[bot] Mar 27, 2025
ce36bbd
Avoid hard dependency on clonevirtualenv. (#34458)
robertwb Mar 28, 2025
c6b455e
Expose drain_mode in windmill proto
kennknowles Mar 28, 2025
1e17e7a
added "Run Java Mobile Gaming RC Validation" (#34456)
liferoad Mar 28, 2025
85c23a5
Bump google.golang.org/api from 0.227.0 to 0.228.0 in /sdks (#34432)
dependabot[bot] Mar 28, 2025
c3d7ab4
Bump cloud.google.com/go/pubsub from 1.47.0 to 1.48.0 in /sdks (#34372)
dependabot[bot] Mar 28, 2025
47d1921
Bump github.com/aws/smithy-go from 1.22.2 to 1.22.3 in /sdks (#34445)
dependabot[bot] Mar 28, 2025
05079c7
Update run_rc_validation_java_mobile_gaming.yml (#34466)
liferoad Mar 28, 2025
367f76a
added run_rc_validation_python_mobile_gaming.yml (#34472)
liferoad Mar 28, 2025
6e29667
Adding release-2.64.0-postrelease to protected branches in .asf.yaml
Mar 31, 2025
d99eac9
Update run_rc_validation_python_mobile_gaming.yml (#34473)
liferoad Mar 31, 2025
e63b2e9
Added blog post for 2.64.0 (#34422)
liferoad Mar 31, 2025
d22fd4f
Added a new RC validation workflow for Java quickstart (#34478)
liferoad Mar 31, 2025
4bb0ccc
Add Documentation Hint for Template Job Creation in DataflowRunner (…
gayatrikate04 Mar 31, 2025
66b5051
Feature: Yaml JdbcIO partitioning for ReadRows (#34417)
shubham-j-sde Mar 31, 2025
686dd26
warning for copy_tests_from_docs (#34477)
liferoad Mar 31, 2025
dbc8f05
Fix looker metrics (#34487)
Amar3tto Mar 31, 2025
7fa0456
Fix Spanner NPE when withHost called with null or empty host (#34489)
damccorm Mar 31, 2025
d86eb32
Adds instructions regarding building the Go SDK harness container for…
chamikaramj Mar 31, 2025
f762166
[Dataflow] Remove unused PhysicalElementCount Counter (#34461)
arunpandianp Apr 1, 2025
a5e3ecb
Support Time Partitioned Test Tables in BigqueryResourceManager (#34471)
joy91227 Apr 1, 2025
03f40d4
Update reviewers to more accurately match current state of repo (#34493)
damccorm Apr 1, 2025
7c058c5
Add vendored cloudpickle (#34424)
claudevdm Apr 1, 2025
6545b51
Updated the discussion doc up to Beam 2.64.0 (#34496)
liferoad Apr 1, 2025
fe30679
minor doc updates (#34494)
liferoad Apr 1, 2025
a40ac14
Updated the republished workflow to 2.64.0 (#34499)
liferoad Apr 1, 2025
162a53c
[Go] Fix reshuffle implementation to use the global window for gbk ou…
scwhittle Apr 1, 2025
6e935e9
Bump golang.org/x/net from 0.37.0 to 0.38.0 in /sdks (#34482)
dependabot[bot] Apr 1, 2025
565df67
Skip TestOomParDo for Dataflow (#34502)
akashorabek Apr 1, 2025
b7f1079
Update the python deps (#34501)
liferoad Apr 1, 2025
7d8e942
plumb grpc flow control settings via UserWorkerRunnerV1Settings (#34500)
m-trieu Apr 2, 2025
fa8be97
Bump github.com/go-sql-driver/mysql from 1.9.0 to 1.9.1 in /sdks (#34…
dependabot[bot] Apr 2, 2025
abf50b4
Add support for collections.abc.Mapping (#34001)
msuozzo Apr 2, 2025
16580bb
Remove social media pieces from release guide (#34509)
damccorm Apr 2, 2025
df948d7
fix CVE-2025-25193 (#34508)
ahmedabu98 Apr 2, 2025
336057a
JDBCIO - handle empty driverjars argument (#34514)
stankiewicz Apr 2, 2025
b0c52f3
Bump GoogleAdsIO to v19 (#34497)
Abacn Apr 2, 2025
ab5eeda
Add rc00 tag (#34518)
Abacn Apr 2, 2025
acbf943
Revert "Add rc00 tag (#34518)" (#34519)
Abacn Apr 2, 2025
ca790c4
Add STRING format to ReadFromKafka schema transform.
robertwb Mar 14, 2025
e252011
Update beam-master image. (#34517)
shunping Apr 2, 2025
af06235
Remove build label exclusion and just use workflows (#34524)
damccorm Apr 2, 2025
8fbbdf0
Bump version for setup-k8s-action. Increase workflow timeout (#34523)
Amar3tto Apr 2, 2025
d9e47e5
Add an v-2.XX.0-RC00 when release branch is cut (#34522)
Abacn Apr 2, 2025
712f68e
upgrade BQMS version (#34521)
ahmedabu98 Apr 2, 2025
0218711
[Dataflow Streaming] do not block other streams from health checking …
m-trieu Apr 3, 2025
c5c126c
Avoid calling getStackTrace when results are cached in RowCoderGenera…
arunpandianp Apr 3, 2025
9b4019f
Add native Beam schematransform autogen snippet (#34515)
ahmedabu98 Apr 3, 2025
ef19ff0
Introduce RemoteModelHandler abstract base class (#34379)
jrmccluskey Apr 3, 2025
9a48a67
Add reducers for threading.Lock and EnumDescriptor. (#34537)
claudevdm Apr 3, 2025
4ba53f5
Auto-enable allowDuplicates for Redistribute with ALO streaming mode …
celeste-zeng Apr 4, 2025
0011e96
removed the mock for the test
liferoad Apr 4, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,7 @@ github:

protected_branches:
master: {}
release-2.64.0-postrelease: {}
release-2.64: {}
release-2.63.0-postrelease: {}
release-2.63: {}
Expand Down
24 changes: 8 additions & 16 deletions .github/REVIEWERS.yml
Original file line number Diff line number Diff line change
Expand Up @@ -20,12 +20,12 @@
labels:
- name: Go
reviewers:
- lostluck
- jrmccluskey
exclusionList:
- youngoli
- lostluck
exclusionList: []
- name: Python
reviewers:
- claudevdm
- damccorm
- jrmccluskey
- tvalentyn
Expand All @@ -34,20 +34,13 @@ labels:
exclusionList: []
- name: Java
reviewers:
- Abacn
- kennknowles
- robertwb
- m-trieu
- damondouglas
exclusionList: []
- name: IO
reviewers:
- chamikaramj
- johnjcasey
- Abacn
- ahmedabu98
- damondouglas
- chamikaramj
- m-trieu
- kennknowles
- shunping
- robertwb
exclusionList: []
- name: spanner
reviewers:
Expand All @@ -68,8 +61,8 @@ labels:
- sjvanrossum
- name: Build
reviewers:
- damccorm
- Abacn
- damccorm
exclusionList: []
- name: website
reviewers:
Expand All @@ -83,7 +76,6 @@ fallbackReviewers:
- Abacn
- chamikaramj
- damccorm
- damondouglas
- johnjcasey
- jrmccluskey
- kennknowles
Expand Down
12 changes: 6 additions & 6 deletions .github/actions/common-rc-validation/action.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -36,19 +36,19 @@ runs:
shell: bash
run: |
echo "---------------------Downloading Python Staging RC----------------------------"
wget ${PYTHON_RC_DOWNLOAD_URL}/${RELEASE_VER}/python/apache-beam-${RELEASE_VER}.tar.gz
wget ${PYTHON_RC_DOWNLOAD_URL}/${RELEASE_VER}/python/apache-beam-${RELEASE_VER}.tar.gz.sha512
if [[ ! -f apache-beam-$RELEASE_VER.tar.gz ]]; then
wget ${PYTHON_RC_DOWNLOAD_URL}/${RELEASE_VER}/python/apache_beam-${RELEASE_VER}.tar.gz
wget ${PYTHON_RC_DOWNLOAD_URL}/${RELEASE_VER}/python/apache_beam-${RELEASE_VER}.tar.gz.sha512
if [[ ! -f apache_beam-$RELEASE_VER.tar.gz ]]; then
{ echo "Fail to download Python Staging RC files." ;exit 1; }
fi

echo "--------------------------Verifying Hashes------------------------------------"
sha512sum -c apache-beam-${RELEASE_VER}.tar.gz.sha512
sha512sum -c apache_beam-${RELEASE_VER}.tar.gz.sha512

`which pip` install --upgrade pip
`which pip` install --upgrade setuptools

- name: Installing python SDK
shell: bash
run: pip install apache-beam-${RELEASE_VER}.tar.gz[gcp]

run: pip install apache_beam-${RELEASE_VER}.tar.gz[gcp]

2 changes: 1 addition & 1 deletion .github/actions/setup-k8s-access/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ runs:
run: |
kubectl config set-context --current --namespace=${{ steps.replace_namespace.outputs.TEST_NAMESPACE }}
- name: Post cleanup
uses: pyTooling/Actions/with-post-step@v0.4.6
uses: pyTooling/Actions/with-post-step@v4.2.2
with:
main: echo "Post Cleanup"
post: |
Expand Down
2 changes: 1 addition & 1 deletion .github/autolabeler.yml
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
# Please keep the entries sorted lexicographically in each category.

# General
build: ["assembly.xml", "build.gradle.kts", "buildSrc/**/*", ".gitattributes", ".github/**/*", ".gitignore", "gradle/**/*", ".mailmap", "ownership/**/*", "release/**/*", "sdks/java/build-tools/**/*", "settings.gradle.kts"]
build: ["assembly.xml", "buildSrc/**/*", ".gitattributes", ".github/workflows/*", ".gitignore", "gradle/**/*", ".mailmap", "release/**/*", "sdks/java/build-tools/**/*"]
docker: ["runners/flink/job-server-container/**/*", "runners/spark/job-server/container/**/*", "sdks/go/container/**/*", "sdks/java/container/**/*", "sdks/python/container/**/*"]
examples: ["examples/**/*", "sdks/go/examples/**/*", "sdks/python/apache_beam/examples/**/*"]
go: ["sdks/go/**/*", "sdks/go.mod", "sdks/go.sum", "learning/katas/go/**/*"]
Expand Down
2 changes: 1 addition & 1 deletion .github/trigger_files/IO_Iceberg_Integration_Tests.json
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
{
"comment": "Modify this file in a trivial way to cause this test suite to run.",
"modification": 4
"modification": 3
}
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
{
"comment": "Modify this file in a trivial way to cause this test suite to run",
"modification": 5
"modification": 4
}
3 changes: 2 additions & 1 deletion .github/trigger_files/beam_PostCommit_XVR_Direct.json
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
{
"https://github.com/apache/beam/pull/32648": "testing Flink 1.19 support"
"https://github.com/apache/beam/pull/32648": "testing Flink 1.19 support",
"modification": 1
}
Original file line number Diff line number Diff line change
@@ -1 +1,3 @@
{}
{
"modification": 1
}
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ jobs:
-PpythonVersion=3.10 \
-PloadTest.requirementsTxtFile=apache_beam/ml/inference/torch_tests_requirements.txt \
'-PloadTest.args=${{ env.beam_Inference_Python_Benchmarks_Dataflow_test_arguments_2 }} --job_name=benchmark-tests-pytorch-imagenet-python-152-${{env.NOW_UTC}} --output=gs://temp-storage-for-end-to-end-tests/torch/result_resnet152-${{env.NOW_UTC}}.txt' \
- name: run Pytorch Language Modeling using Hugging face bert-base-uncased model
- name: run Pytorch Language Modeling using Hugging Face bert-base-uncased model
uses: ./.github/actions/gradle-command-self-hosted-action
timeout-minutes: 180
with:
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/beam_PostCommit_Java_SingleStoreIO_IT.yml
Original file line number Diff line number Diff line change
Expand Up @@ -87,13 +87,13 @@ jobs:
kubectl apply -f ${{github.workspace}}/.test-infra/kubernetes/singlestore/sdb-rbac.yaml
kubectl apply -f ${{github.workspace}}/.test-infra/kubernetes/singlestore/sdb-cluster-crd.yaml
kubectl apply -f ${{github.workspace}}/.test-infra/kubernetes/singlestore/sdb-operator.yaml
kubectl wait --for=condition=Ready pod -l name=sdb-operator --timeout=120s
kubectl wait --for=condition=Ready pod -l name=sdb-operator --timeout=300s
- name: Install SingleStore cluster
id: install_singlestore
run: |
kubectl apply -f ${{github.workspace}}/.test-infra/kubernetes/singlestore/sdb-cluster.yaml
kubectl wait --for=jsonpath='{.status.phase}'=Running memsqlclusters.memsql.com --all --timeout=120s
kubectl wait svc/svc-sdb-cluster-ddl --for=jsonpath='{.status.loadBalancer.ingress[0].ip}' --timeout=120s
kubectl wait --for=jsonpath='{.status.phase}'=Running memsqlclusters.memsql.com --all --timeout=300s
kubectl wait svc/svc-sdb-cluster-ddl --for=jsonpath='{.status.loadBalancer.ingress[0].ip}' --timeout=300s
loadbalancer_IP=$(kubectl get svc svc-sdb-cluster-ddl -o jsonpath='{.status.loadBalancer.ingress[0].ip}')
echo lb_ip=$loadbalancer_IP >> $GITHUB_OUTPUT
- name: Run Java SingleStore IO IT
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/beam_PreCommit_Java.yml
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ jobs:
matrix:
job_name: [beam_PreCommit_Java]
job_phrase: [Run Java PreCommit]
timeout-minutes: 120
timeout-minutes: 180
if: |
github.event_name == 'push' ||
github.event_name == 'pull_request_target' ||
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/beam_PreCommit_Java_GCP_IO_Direct.yml
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ jobs:
matrix:
job_name: ["beam_PreCommit_Java_GCP_IO_Direct"]
job_phrase: ["Run Java_GCP_IO_Direct PreCommit"]
timeout-minutes: 120
timeout-minutes: 180
if: |
github.event_name == 'push' ||
github.event_name == 'pull_request_target' ||
Expand Down
1 change: 1 addition & 0 deletions .github/workflows/beam_Python_CostBenchmarks_Dataflow.yml
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,7 @@ jobs:
-PloadTest.mainClass=apache_beam.testing.benchmarks.wordcount.wordcount \
-Prunner=DataflowRunner \
-PpythonVersion=3.10 \
-PloadTest.requirementsTxtFile=apache_beam/testing/benchmarks/wordcount/requirements.txt \
'-PloadTest.args=${{ env.beam_Python_Cost_Benchmarks_Dataflow_test_arguments_1 }} --job_name=benchmark-tests-wordcount-python-${{env.NOW_UTC}} --output_file=gs://temp-storage-for-end-to-end-tests/wordcount/result_wordcount-${{env.NOW_UTC}}.txt' \
- name: Run Tensorflow MNIST Image Classification on Dataflow
uses: ./.github/actions/gradle-command-self-hosted-action
Expand Down
2 changes: 2 additions & 0 deletions .github/workflows/build_release_candidate.yml
Original file line number Diff line number Diff line change
Expand Up @@ -161,6 +161,7 @@ jobs:

stage_python_artifacts:
if: ${{ fromJson(github.event.inputs.STAGE).python_artifacts == 'yes'}}
needs: [publish_java_artifacts, build_and_stage_prism] # Enforce ordering to avoid svn conflicts
runs-on: ubuntu-22.04
steps:
- name: Checkout
Expand Down Expand Up @@ -417,6 +418,7 @@ jobs:

build_and_stage_prism:
if: ${{ fromJson(github.event.inputs.STAGE).prism == 'yes'}}
needs: [publish_java_artifacts] # Enforce ordering to avoid svn conflicts
runs-on: ubuntu-22.04
steps:
- name: Checkout
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
--input_options={}
--staging_location=gs://temp-storage-for-perf-tests/loadtests
--temp_location=gs://temp-storage-for-perf-tests/loadtests
--requirements_file=apache_beam/testing/benchmarks/wordcount/requirements.txt
--publish_to_big_query=true
--metrics_dataset=beam_run_inference
--metrics_table=python_wordcount
Expand Down
10 changes: 9 additions & 1 deletion .github/workflows/cut_release_branch.yml
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,12 @@ jobs:
steps:
- name: Validate Next Version
run: |
if [[ ${RELEASE} =~ ([0-9]+\.[0-9]+) ]]; then
echo "RELEASE_CUT_TAG=v${RELEASE}.0-RC00" >> $GITHUB_ENV
else
echo "The input for RELEASE does not match a valid format [0-9]+\.[0-9]+"
exit 1
fi
if [[ $NEXT_RELEASE =~ ([0-9]+\.[0-9]+) ]]; then
echo "NEXT_VERSION_IN_BASE_BRANCH=${BASH_REMATCH[1]}.0" >> $GITHUB_ENV
else
Expand All @@ -116,7 +122,9 @@ jobs:
sed -i -e "s/master: {}/master: {}\n release-${RELEASE}: {}/g" .asf.yaml
- name: Update master branch
run: |
bash "${SCRIPT_DIR}/set_version.sh" "${NEXT_VERSION_IN_BASE_BRANCH}"
bash "${SCRIPT_DIR}/set_version.sh" "${NEXT_VERSION_IN_BASE_BRANCH}" "--add-tag" "${RELEASE_CUT_TAG}"
echo "==============tag RC00 to current master branch================"
git push origin tag "${RELEASE_CUT_TAG}"
echo "==============Update master branch as following================"
git diff
echo "==============================================================="
Expand Down
2 changes: 0 additions & 2 deletions .github/workflows/refresh_looker_metrics.yml
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,6 @@
name: Refresh Looker Performance Metrics

on:
schedule:
- cron: '10 10 * * 1'
workflow_dispatch:
inputs:
READ_ONLY:
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/republish_released_docker_containers.yml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ on:
- cron: "0 6 * * 1"
env:
docker_registry: gcr.io
release: "${{ github.event.inputs.RELEASE || '2.63.0' }}"
release: "${{ github.event.inputs.RELEASE || '2.64.0' }}"
rc: "${{ github.event.inputs.RC || '2' }}"

jobs:
Expand Down
32 changes: 23 additions & 9 deletions .github/workflows/run_rc_validation.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
# under the License.

# To learn more about GitHub Actions in Apache Beam check the CI.m
# DO NOT USE THIS WORKFLOW AND WILL BE REMOVED SOON

name: Run RC Validation
on:
Expand Down Expand Up @@ -74,9 +75,22 @@ jobs:
contents: write
env:
GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
RELEASE_BRANCH: "release-${{github.event.inputs.RELEASE_VER}}"
RAW_RELEASE_VER: ${{ github.event.inputs.RELEASE_VER }}
WORKING_BRANCH: "v${{github.event.inputs.RELEASE_VER}}-RC${{github.event.inputs.RC_NUM}}_validations"
steps:
- name: Set Release Branch Name (Major.Minor)
id: set_branch_name # Optional: Give the step an ID
run: |
VERSION="${{ env.RAW_RELEASE_VER }}" # Use the full version from input/env
# Use shell parameter expansion to remove the last dot and everything after it
MAJOR_MINOR_VERSION="${VERSION%.*}"
# Construct the branch name
BRANCH_NAME="release-$MAJOR_MINOR_VERSION"
echo "Original Version: $VERSION"
echo "Calculated Major.Minor Version: $MAJOR_MINOR_VERSION"
echo "Setting RELEASE_BRANCH Env Var to: $BRANCH_NAME"
# Export the calculated name to the environment for subsequent steps
echo "RELEASE_BRANCH=$BRANCH_NAME" >> $GITHUB_ENV
- name: Check out code
uses: actions/checkout@v4
with:
Expand Down Expand Up @@ -117,7 +131,7 @@ jobs:
uses: actions/setup-python@v5
with:
python-version: ${{matrix.py_version}}


- name: Setup Java JDK
uses: actions/setup-java@v4
Expand All @@ -130,7 +144,7 @@ jobs:
with:
RELEASE_VER: ${{env.RELEASE_VER}}
PYTHON_RC_DOWNLOAD_URL: ${{env.PYTHON_RC_DOWNLOAD_URL}}



- name: Setting Taxi Variables
Expand All @@ -154,7 +168,7 @@ jobs:
--num_workers 5 \
--output_topic projects/${USER_GCP_PROJECT}/topics/${SQL_TAXI_TOPIC} \
--beam_services="{\":sdks:java:extensions:sql:expansion-service:shadowJar\": \"${SQL_EXPANSION_SERVICE_JAR}\"}" \
--sdk_location apache-beam-${RELEASE_VER}.tar.gz || true
--sdk_location apache_beam-${RELEASE_VER}.tar.gz || true
- name: Checking Results
run: |
gcloud pubsub subscriptions pull --project=${USER_GCP_PROJECT} --limit=5 ${SQL_TAXI_SUBSCRIPTION}
Expand Down Expand Up @@ -243,7 +257,7 @@ jobs:
--temp_location=${USER_GCS_BUCKET}/temp/ \
--with_metadata \
--beam_services="{\"sdks:java:io:expansion-service:shadowJar\": \"${KAFKA_EXPANSION_SERVICE_JAR}\"}" \
--sdk_location apache-beam-${RELEASE_VER}.tar.gz || true
--sdk_location apache_beam-${RELEASE_VER}.tar.gz || true
- name: Checking executions results
run: |
bq head -n 10 ${KAFKA_TAXI_DF_DATASET}.xlang_kafka_taxi
Expand Down Expand Up @@ -294,8 +308,8 @@ jobs:
RELEASE_VER: ${{env.RELEASE_VER}}
PYTHON_RC_DOWNLOAD_URL: ${{env.PYTHON_RC_DOWNLOAD_URL}}

- name: Setup Maven Action
uses: s4u/setup-maven-action@v1.2.1
- name: Setup Java and Maven Action
uses: actions/setup-java@v4
with:
java-version: 11
- name: Updating Settings
Expand Down Expand Up @@ -434,7 +448,7 @@ jobs:
--dataset ${LEADERBOARD_DF_DATASET} \
--runner DataflowRunner \
--temp_location=${USER_GCS_BUCKET}/temp/ \
--sdk_location apache-beam-${RELEASE_VER}.tar.gz || true
--sdk_location apache_beam-${RELEASE_VER}.tar.gz || true
- name: Checking results
run: |
bq head -n 10 ${LEADERBOARD_DF_DATASET}.leader_board_users
Expand Down Expand Up @@ -535,7 +549,7 @@ jobs:
--dataset ${GAMESTATS_DF_DATASET} \
--runner DataflowRunner \
--temp_location=${USER_GCS_BUCKET}/temp/ \
--sdk_location apache-beam-${RELEASE_VER}.tar.gz \
--sdk_location apache_beam-${RELEASE_VER}.tar.gz \
--fixed_window_duration ${FIXED_WINDOW_DURATION} || true
- name: Checking Results
run: |
Expand Down
Loading
Loading