(streampark) branch dev updated: [hotfixed] fixed flink cdc yaml unable use userJars. (#4233)

[chengjie]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new d4bde448f [hotfixed] fixed flink cdc yaml unable use userJars. (#4233)
d4bde448f is described below

commit d4bde448fddaa47f20a74e645adea02fc614df2a
Author: ouyangwulin <mr.art...@gmail.com>
AuthorDate: Thu Apr 24 18:40:03 2025 +0800

    [hotfixed] fixed flink cdc yaml unable use userJars. (#4233)
---
 .../org/apache/streampark/flink/client/impl/YarnApplicationClient.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
index 966325282..0dc6cb813 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
@@ -52,7 +52,7 @@ object YarnApplicationClient extends YarnClientTrait {
         submitRequest.hdfsWorkspace.flinkPlugins,
         submitRequest.hdfsWorkspace.appJars)
       submitRequest.jobType match {
-        case FlinkJobType.FLINK_SQL =>
+        case FlinkJobType.FLINK_SQL | FlinkJobType.FLINK_CDC =>
           array += 
s"${workspace.APP_SHIMS}/flink-${submitRequest.flinkVersion.majorVersion}"
           val jobLib = s"${workspace.APP_WORKSPACE}/${submitRequest.id}/lib"
           if (HdfsUtils.exists(jobLib)) {