Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -80,24 +80,13 @@ jobs:
java-version: |
${{ matrix.java_version }}
11
- name: run jar Java${{ matrix.java_version }} script
run: |
./gradlew runners:google-cloud-dataflow-java:testJar :runners:google-cloud-dataflow-java:worker:shadowJar \
-Dorg.gradle.java.home=$JAVA_HOME_${{ matrix.java_version }}_X64
- name: run validatesRunner Java${{ matrix.java_version }} script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
gradle-command: :runners:google-cloud-dataflow-java:validatesRunner
arguments: |
-x shadowJar \
-x shadowTestJar \
-x compileJava \
-x compileTestJava \
-x jar \
-x testJar \
-x classes \
-x testClasses \
-Dorg.gradle.java.home=$JAVA_HOME_${{ matrix.java_version }}_X64 \
-PtestJavaVersion=${{ matrix.java_version }} \
-Pjava${{ matrix.java_version }}Home=$JAVA_HOME_${{ matrix.java_version }}_X64 \
max-workers: 12
- name: Archive JUnit Test Results
uses: actions/upload-artifact@v4
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,20 +80,13 @@ jobs:
java-version: |
${{ matrix.java_version }}
11
- name: run jar Java${{ matrix.java_version }} script
run: |
./gradlew :runners:direct-java:shadowJar :runners:direct-java:shadowTestJar \
-Dorg.gradle.java.home=$JAVA_HOME_${{ matrix.java_version }}_X64
- name: run validatesRunner Java${{ matrix.java_version }} script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
gradle-command: :runners:direct-java:validatesRunner
arguments: |
-x shadowJar \
-x shadowTestJar \
-x compileJava \
-x compileTestJava \
-Dorg.gradle.java.home=$JAVA_HOME_${{ matrix.java_version }}_X64 \
-PtestJavaVersion=${{ matrix.java_version }} \
-Pjava${{ matrix.java_version }}Home=$JAVA_HOME_${{ matrix.java_version }}_X64 \
- name: Archive JUnit Test Results
uses: actions/upload-artifact@v4
if: ${{ !success() }}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,23 +78,13 @@ jobs:
java-version: |
8
11
- name: run jar Java8 script
run: |
./gradlew :runners:flink:1.19:jar :runners:flink:1.19:testJar
- name: run validatesRunner Java8 script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
gradle-command: :runners:flink:1.19:validatesRunner
arguments: |
-x shadowJar \
-x shadowTestJar \
-x compileJava \
-x compileTestJava \
-x jar \
-x testJar \
-x classes \
-x testClasses \
-Dorg.gradle.java.home=$JAVA_HOME_8_X64 \
-PtestJavaVersion=8 \
-Pjava8Home=$JAVA_HOME_8_X64 \
max-workers: 12
- name: Archive JUnit Test Results
uses: actions/upload-artifact@v4
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,23 +78,13 @@ jobs:
java-version: |
8
11
- name: run jar Java8 script
run: |
./gradlew :runners:spark:3:jar :runners:spark:3:testJar
- name: run validatesRunner Java8 script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
gradle-command: :runners:spark:3:validatesRunner
arguments: |
-x shadowJar \
-x shadowTestJar \
-x compileJava \
-x compileTestJava \
-x jar \
-x testJar \
-x classes \
-x testClasses \
-Dorg.gradle.java.home=$JAVA_HOME_8_X64 \
-PtestJavaVersion=8 \
-Pjava8Home=$JAVA_HOME_8_X64 \
max-workers: 12
- name: Archive JUnit Test Results
uses: actions/upload-artifact@v4
Expand Down
4 changes: 0 additions & 4 deletions buildSrc/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -92,9 +92,5 @@ gradlePlugin {
id = "org.apache.beam.vendor-java"
implementationClass = "org.apache.beam.gradle.VendorJavaPlugin"
}
create("beamJenkins") {
id = "org.apache.beam.jenkins"
implementationClass = "org.apache.beam.gradle.BeamJenkinsPlugin"
}
}
}
16 changes: 8 additions & 8 deletions sdks/go/test/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ task dataflowValidatesRunner() {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand All @@ -66,7 +66,7 @@ task dataflowValidatesRunnerARM64() {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down Expand Up @@ -95,7 +95,7 @@ task flinkValidatesRunner {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down Expand Up @@ -123,7 +123,7 @@ task samzaValidatesRunner {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down Expand Up @@ -151,7 +151,7 @@ task sparkValidatesRunner {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down Expand Up @@ -190,7 +190,7 @@ tasks.register("ulrValidatesRunner") {
}
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", ". ${envdir}/bin/activate && ./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand All @@ -217,7 +217,7 @@ task prismValidatesRunner {
]
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down Expand Up @@ -262,7 +262,7 @@ ext.goIoValidatesRunnerTask = { proj, name, scriptOpts, pipelineOpts ->
logger.info("Running the command: sh -c ./run_validatesrunner_tests.sh ${options.join(' ')}")
exec {
if (fork_java_home) {
environment "JAVA_HOME", fork_java_home
environment "JAVA_HOME_JOB_SERVER", fork_java_home
}
executable "sh"
args "-c", "./run_validatesrunner_tests.sh ${options.join(' ')}"
Expand Down
22 changes: 4 additions & 18 deletions sdks/go/test/run_validatesrunner_tests.sh
Original file line number Diff line number Diff line change
Expand Up @@ -259,8 +259,8 @@ s.close()

TMPDIR=$(mktemp -d)

if [[ -n "$JAVA_HOME" ]]; then
JAVA_CMD="$JAVA_HOME/bin/java"
if [[ -n "$JAVA_HOME_JOB_SERVER" ]]; then
JAVA_CMD="$JAVA_HOME_JOB_SERVER/bin/java"
else
JAVA_CMD="java"
fi
Expand Down Expand Up @@ -374,18 +374,7 @@ if [[ "$RUNNER" == "dataflow" ]]; then
CONTAINER=us.gcr.io/$PROJECT/$USER/beam_go_sdk
echo "Using container $CONTAINER"

# TODO(https://github.com/apache/beam/issues/27674): remove this branch once the jenkins VM can build multiarch, or jenkins is deprecated.
if [[ "$USER" == "jenkins" ]]; then
./gradlew :sdks:go:container:docker -Pdocker-repository-root=us.gcr.io/$PROJECT/$USER -Pdocker-tag=$TAG

# Verify it exists
docker images | grep $TAG

# Push the container
gcloud docker -- push $CONTAINER:$TAG
else
./gradlew :sdks:go:container:docker -Pdocker-repository-root=us.gcr.io/$PROJECT/$USER -Pdocker-tag=$TAG -Pcontainer-architecture-list=arm64,amd64 -Ppush-containers
fi
./gradlew :sdks:go:container:docker -Pdocker-repository-root=us.gcr.io/$PROJECT/$USER -Pdocker-tag=$TAG -Pcontainer-architecture-list=arm64,amd64 -Ppush-containers

if [[ -n "$TEST_EXPANSION_ADDR" || -n "$IO_EXPANSION_ADDR" || -n "$SCHEMAIO_EXPANSION_ADDR" || -n "$DEBEZIUMIO_EXPANSION_ADDR" ]]; then
ARGS="$ARGS --experiments=use_portable_job_submission"
Expand All @@ -395,7 +384,7 @@ if [[ "$RUNNER" == "dataflow" ]]; then
JAVA_TAG=$(date +%Y%m%d-%H%M%S)
JAVA_CONTAINER=us.gcr.io/$PROJECT/$USER/beam_java11_sdk
echo "Using container $JAVA_CONTAINER for cross-language java transforms"
./gradlew :sdks:java:container:java11:docker -Pdocker-repository-root=us.gcr.io/$PROJECT/$USER -Pdocker-tag=$JAVA_TAG -Pjava11Home=$JAVA11_HOME
./gradlew :sdks:java:container:java11:docker -Pdocker-repository-root=us.gcr.io/$PROJECT/$USER -Pdocker-tag=$JAVA_TAG

# Verify it exists
docker images | grep $JAVA_TAG
Expand Down Expand Up @@ -457,9 +446,6 @@ if [[ "$RUNNER" == "dataflow" ]]; then
# Note: we don't delete the multi-arch containers here because this command only deletes the manifest list with the tag,
# the associated container images can't be deleted because they are not tagged. However, multi-arch containers that are
# older than 6 weeks old are deleted by stale_dataflow_prebuilt_image_cleaner.sh that runs daily.
if [[ "$USER" == "jenkins" ]]; then
gcloud --quiet container images delete $CONTAINER:$TAG || echo "Failed to delete container"
fi
if [[ -n "$TEST_EXPANSION_ADDR" || -n "$IO_EXPANSION_ADDR" || -n "$SCHEMAIO_EXPANSION_ADDR" || -n "$DEBEZIUMIO_EXPANSION_ADDR" ]]; then
# Delete the java cross-language container locally and remotely
docker rmi $JAVA_CONTAINER:$JAVA_TAG || echo "Failed to remove container"
Expand Down
Loading