Skip to content

Commit d4bde44

Browse files
authored
[hotfixed] fixed flink cdc yaml unable use userJars. (#4233)
1 parent 00d9cf4 commit d4bde44

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ object YarnApplicationClient extends YarnClientTrait {
5252
submitRequest.hdfsWorkspace.flinkPlugins,
5353
submitRequest.hdfsWorkspace.appJars)
5454
submitRequest.jobType match {
55-
case FlinkJobType.FLINK_SQL =>
55+
case FlinkJobType.FLINK_SQL | FlinkJobType.FLINK_CDC =>
5656
array += s"${workspace.APP_SHIMS}/flink-${submitRequest.flinkVersion.majorVersion}"
5757
val jobLib = s"${workspace.APP_WORKSPACE}/${submitRequest.id}/lib"
5858
if (HdfsUtils.exists(jobLib)) {

0 commit comments

Comments
 (0)