(flink) branch master updated: [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 04f3047d614 [FLINK-38396][tests] Make 
`DefaultKubernetesArtifactUploaderTest` more stable
04f3047d614 is described below

commit 04f3047d614931f3c7a4c235a58e3eff44cc34d7
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Mon Sep 22 15:42:25 2025 +0200

    [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more 
stable
---
 .../DefaultKubernetesArtifactUploaderTest.java     | 27 +++++++++++++++-------
 1 file changed, 19 insertions(+), 8 deletions(-)

diff --git 
a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploaderTest.java
 
b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploaderTest.java
index 77bddf7937d..6f3a5eb5364 100644
--- 
a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploaderTest.java
+++ 
b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploaderTest.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.kubernetes.artifact;
 
+import org.apache.flink.FlinkVersion;
 import org.apache.flink.client.cli.ArtifactFetchOptions;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.PipelineOptions;
@@ -80,7 +81,9 @@ class DefaultKubernetesArtifactUploaderTest {
 
     @Test
     void testUploadAllWithOneJobJar() throws Exception {
-        File jar = getFlinkKubernetesJar();
+        // flink-kubernetes depends on flink-annotations
+        // that means flink-annotations jar should be present before test 
execution
+        File jar = getFlinkAnnotationsJar();
         String localUri = "local://" + jar.getAbsolutePath();
 
         config.set(PipelineOptions.JARS, Collections.singletonList(localUri));
@@ -91,7 +94,9 @@ class DefaultKubernetesArtifactUploaderTest {
 
     @Test
     void testUploadAllWithAdditionalArtifacts() throws Exception {
-        File jobJar = getFlinkKubernetesJar();
+        // flink-kubernetes depends on flink-annotations
+        // that means flink-annotations jar should be present before test 
execution
+        File jobJar = getFlinkAnnotationsJar();
         File addArtifact1 = 
TestingUtils.getClassFile(DefaultKubernetesArtifactUploader.class);
         File addArtifact2 = TestingUtils.getClassFile(KubernetesUtils.class);
         String localJobUri = "local://" + jobJar.getAbsolutePath();
@@ -135,7 +140,9 @@ class DefaultKubernetesArtifactUploaderTest {
 
     @Test
     void testUpload() throws Exception {
-        File jar = getFlinkKubernetesJar();
+        // flink-kubernetes depends on flink-annotations
+        // that means flink-annotations jar should be present before test 
execution
+        File jar = getFlinkAnnotationsJar();
         String localUri = "local://" + jar.getAbsolutePath();
 
         String expectedUri = "dummyfs:" + tmpDir.resolve(jar.getName());
@@ -146,7 +153,9 @@ class DefaultKubernetesArtifactUploaderTest {
 
     @Test
     void testUploadNoOverwrite() throws Exception {
-        File jar = getFlinkKubernetesJar();
+        // flink-kubernetes depends on flink-annotations
+        // that means flink-annotations jar should be present before test 
execution
+        File jar = getFlinkAnnotationsJar();
         String localUri = "local://" + jar.getAbsolutePath();
         Files.createFile(tmpDir.resolve(jar.getName()));
 
@@ -158,7 +167,9 @@ class DefaultKubernetesArtifactUploaderTest {
 
     @Test
     void testUploadOverwrite() throws Exception {
-        File jar = getFlinkKubernetesJar();
+        // flink-kubernetes depends on flink-annotations
+        // that means flink-annotations jar should be present before test 
execution
+        File jar = getFlinkAnnotationsJar();
         String localUri = "local://" + jar.getAbsolutePath();
         Files.createFile(tmpDir.resolve(jar.getName()));
 
@@ -199,12 +210,12 @@ class DefaultKubernetesArtifactUploaderTest {
         return "dummyfs://" + tmpDir;
     }
 
-    private File getFlinkKubernetesJar() throws IOException {
+    private File getFlinkAnnotationsJar() throws IOException {
         return TestingUtils.getFileFromTargetDir(
-                DefaultKubernetesArtifactUploader.class,
+                FlinkVersion.class,
                 p ->
                         org.apache.flink.util.FileUtils.isJarFile(p)
-                                && 
p.toFile().getName().startsWith("flink-kubernetes"));
+                                && 
p.toFile().getName().contains("flink-annotations"));
     }
 
     private void assertJobJarUri(String filename) {