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 <[email protected]> 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
