[incubator-streampark] branch dev updated: Fix the bugs in the test cases of flink-kubernetes-v2

[li...@apache.org]

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

linying pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 73d153c28 Fix the bugs in the test cases of flink-kubernetes-v2
73d153c28 is described below

commit 73d153c28c40c6adafb38ff8d46607a6bb2508e4
Author: HangC <77...@users.noreply.github.com>
AuthorDate: Fri Aug 11 11:34:57 2023 +0800

    Fix the bugs in the test cases of flink-kubernetes-v2
---
 .../streampark/flink/kubernetes/v2/example/UsingOperator.scala    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/test/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingOperator.scala b/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/test/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingOperator.scala
index 2d110e6a3..76245cc71 100644
--- a/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/test/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingOperator.scala
+++ b/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/test/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingOperator.scala
@@ -104,11 +104,11 @@ class UsingOperator extends AnyWordSpecLike with BeforeAndAfterAll {
       jobManager = JobManagerDef(cpu = 1, memory = "1024m"),
       taskManager = TaskManagerDef(cpu = 1, memory = "1024m"),
       job = JobDef(
-        jarURI = "assets/quick-sql-1.0.jar",
+        jarURI = s"$assetPath/quick-sql-1.0.jar",
         parallelism = 1,
         entryClass = "demo.flink.SqlFakerDataJob"
       ),
-      extJarPaths = Array("assets/flink-faker-0.5.3.jar")
+      extJarPaths = Array(s"$assetPath/flink-faker-0.5.3.jar")
     )
     for {
       _ <- FlinkK8sOperator.deployApplicationJob(114514, spec)
@@ -124,14 +124,14 @@ class UsingOperator extends AnyWordSpecLike with BeforeAndAfterAll {
       flinkVersion = FlinkVersion.V1_16,
       jobManager = JobManagerDef(cpu = 1, memory = "1024m"),
       taskManager = TaskManagerDef(cpu = 1, memory = "1024m"),
-      extJarPaths = Array("assets/flink-faker-0.5.3.jar")
+      extJarPaths = Array(s"$assetPath/flink-faker-0.5.3.jar")
     )
     val jobSpec     = FlinkSessionJobDef(
       namespace = "fdev",
       name = "sessionjob-with-extra-jar",
       deploymentName = "session-with-extra-jar",
       job = JobDef(
-        jarURI = "assets/quick-sql-1.0.jar",
+        jarURI = s"$assetPath/quick-sql-1.0.jar",
         parallelism = 1,
         entryClass = "demo.flink.SqlFakerDataJob"
       )