You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2026/02/06 19:32:37 UTC
(beam) 01/01: Exercise Flink PVR tests
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch flink2-pvr
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 9df67132e7ac56f9e287e74ddcd91708f0698439
Author: Yi Hu <ya...@google.com>
AuthorDate: Fri Feb 6 14:31:20 2026 -0500
Exercise Flink PVR tests
---
.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml | 8 +++++---
.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml | 8 +++++---
sdks/java/core/build.gradle | 1 -
3 files changed, 10 insertions(+), 7 deletions(-)
diff --git a/.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml b/.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml
index 0a808f2f861..7688c676b0c 100644
--- a/.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml
+++ b/.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml
@@ -63,11 +63,13 @@ env:
jobs:
beam_PostCommit_Java_PVR_Flink_Batch:
- name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
+ name: ${{ matrix.job_name }} (${{ matrix.flink_version }})
strategy:
matrix:
job_name: ["beam_PostCommit_Java_PVR_Flink_Batch"]
job_phrase: ["Run Java_PVR_Flink_Batch PostCommit"]
+ # every major version
+ flink_version: ['1.20', '2.0']
timeout-minutes: 240
runs-on: [self-hosted, ubuntu-20.04, highmem]
if: |
@@ -83,13 +85,13 @@ jobs:
with:
comment_phrase: ${{ matrix.job_phrase }}
github_token: ${{ secrets.GITHUB_TOKEN }}
- github_job: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
+ github_job: ${{ matrix.job_name }} (${{ matrix.flink_version }})
- name: Setup environment
uses: ./.github/actions/setup-environment-action
- name: run validatesPortableRunnerBatch script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
- gradle-command: :runners:flink:1.20:job-server:validatesPortableRunnerBatchDataSet
+ gradle-command: :runners:flink:${{ matrix.flink_version }}:job-server:validatesPortableRunnerBatchDataSet
env:
CLOUDSDK_CONFIG: ${{ env.KUBELET_GCLOUD_CONFIG_PATH }}
- name: Archive JUnit Test Results
diff --git a/.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml b/.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml
index 3d40c300db0..7bb170b277e 100644
--- a/.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml
+++ b/.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml
@@ -52,13 +52,15 @@ env:
jobs:
beam_PostCommit_Java_PVR_Flink_Streaming:
- name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
+ name: ${{ matrix.job_name }} (${{ matrix.flink_version }})
runs-on: [self-hosted, ubuntu-20.04, main]
timeout-minutes: 120
strategy:
matrix:
job_name: [beam_PostCommit_Java_PVR_Flink_Streaming]
job_phrase: [Run Java Flink PortableValidatesRunner Streaming]
+ # every major version
+ flink_version: [ '1.20', '2.0' ]
if: |
github.event_name == 'workflow_dispatch' ||
github.event_name == 'pull_request_target' ||
@@ -71,13 +73,13 @@ jobs:
with:
comment_phrase: ${{ matrix.job_phrase }}
github_token: ${{ secrets.GITHUB_TOKEN }}
- github_job: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
+ github_job: ${{ matrix.job_name }} (${{ matrix.flink_version }})
- name: Setup environment
uses: ./.github/actions/setup-environment-action
- name: run PostCommit Java Flink PortableValidatesRunner Streaming script
uses: ./.github/actions/gradle-command-self-hosted-action
with:
- gradle-command: runners:flink:1.20:job-server:validatesPortableRunnerStreaming
+ gradle-command: runners:flink:${{ matrix.flink_version }}:job-server:validatesPortableRunnerStreaming
- name: Archive JUnit Test Results
uses: actions/upload-artifact@v4
if: ${{ !success() }}
diff --git a/sdks/java/core/build.gradle b/sdks/java/core/build.gradle
index d51c338f189..7f33d237149 100644
--- a/sdks/java/core/build.gradle
+++ b/sdks/java/core/build.gradle
@@ -125,7 +125,6 @@ dependencies {
shadowTest library.java.guava_testlib
shadowTest library.java.mockito_core
shadowTest library.java.hamcrest
- shadowTest "com.esotericsoftware.kryo:kryo:2.21"
shadowTest library.java.quickcheck_core
shadowTest library.java.quickcheck_generators
shadowTest library.java.zstd_jni