[Bug] Release job not work

[zou-can]

Search before asking

• I had searched in the issues and found no similar issues.

Java Version

17

Scala Version

2.12.x

StreamPark Version

2.1.5

Flink Version

1.20.1

Deploy mode

remote

What happened

StreamPark version: 2.1.7

I modify source code and build project with original branch, then cancel running job and release new version, but job run with old version.

我修改了源代码并提交到原来的分支，然后在project页面构建项目，并在application页面发布（cancel -> release -> start），但job还是使用的原来的jar包启动的，对应的修改没有生效。

Error Exception

The logs keep reporting this error, but it doesn't seem to be related to this problem.

日志中一直报这个错误，但似乎与此问题无关

streampark-1  | 2025-11-27 17:53:30 | ERROR | streampark-flink-app-watching-0 | org.apache.streampark.console.core.task.FlinkAppHttpWatcher:330] get flink jobOverview error: Illegal base64 character 2d
streampark-1  | java.lang.IllegalArgumentException: Illegal base64 character 2d
streampark-1  |  at java.base/java.util.Base64$Decoder.decode0(Base64.java:848)
streampark-1  |  at java.base/java.util.Base64$Decoder.decode(Base64.java:566)
streampark-1  |  at java.base/java.util.Base64$Decoder.decode(Base64.java:589)
streampark-1  |  at org.apache.streampark.common.util.DeflaterUtils$.unzipString(DeflaterUtils.scala:44)
streampark-1  |  at org.apache.streampark.common.util.DeflaterUtils.unzipString(DeflaterUtils.scala)
streampark-1  |  at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl.getFlinkConfig(FlinkEnvServiceImpl.java:176)
streampark-1  |  at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl$$FastClassBySpringCGLIB$$fd9e041d.invoke(<generated>)
streampark-1  |  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
streampark-1  |  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
streampark-1  |  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
streampark-1  |  at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl$$EnhancerBySpringCGLIB$$d4eb3d48.getFlinkConfig(<generated>)
streampark-1  |  at org.apache.streampark.console.core.service.impl.SavepointServiceImpl.clearExpire(SavepointServiceImpl.java:160)
streampark-1  |  at org.apache.streampark.console.core.service.impl.SavepointServiceImpl.saveSavePoint(SavepointServiceImpl.java:322)
streampark-1  |  at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$FastClassBySpringCGLIB$$5fcde58d.invoke(<generated>)
streampark-1  |  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
streampark-1  |  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
streampark-1  |  at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
streampark-1  |  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
streampark-1  |  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
streampark-1  |  at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$EnhancerBySpringCGLIB$$97fb4798.saveSavePoint(<generated>)
streampark-1  |  at org.apache.streampark.console.core.task.CheckpointProcessor.saveSavepoint(CheckpointProcessor.java:184)
streampark-1  |  at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:99)
streampark-1  |  at org.apache.streampark.console.core.task.CheckpointProcessor.lambda$process$0(CheckpointProcessor.java:76)
streampark-1  |  at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
streampark-1  |  at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:76)
streampark-1  |  at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.handleCheckPoints(FlinkAppHttpWatcher.java:390)
streampark-1  |  at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.getFromFlinkRestApi(FlinkAppHttpWatcher.java:328)
streampark-1  |  at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.lambda$watch$2(FlinkAppHttpWatcher.java:220)
streampark-1  |  at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
streampark-1  |  at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
streampark-1  |  at java.base/java.lang.Thread.run(Thread.java:840)

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

• I agree to follow this project's Code of Conduct

[zhjyz2]

I encountered a similar bug that seems to be caused by improper parameter handling. For example, my Flink Home file path contains the character"-" : "/opt/flink/flink-1.16.3", and when I try to view the Flink conf, an exception occurs while parsing the path.

full log:

2025-12-17 11:51:57 | ERROR | streampark-flink-app-watching-79 | org.apache.streampark.console.core.task.FlinkAppHttpWatcher:330] get flink jobOverview error: Illegal base64 character 2d
java.lang.IllegalArgumentException: Illegal base64 character 2d
        at java.base/java.util.Base64$Decoder.decode0(Base64.java:746)
        at java.base/java.util.Base64$Decoder.decode(Base64.java:538)
        at java.base/java.util.Base64$Decoder.decode(Base64.java:561)
        at org.apache.streampark.common.util.DeflaterUtils$.unzipString(DeflaterUtils.scala:44)
        at org.apache.streampark.common.util.DeflaterUtils.unzipString(DeflaterUtils.scala)
        at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl.getFlinkConfig(FlinkEnvServiceImpl.java:176)
        at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl$$FastClassBySpringCGLIB$$fd9e041d.invoke(<generated>)
        at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
        at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
        at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
        at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
        at org.apache.streampark.console.core.service.impl.FlinkEnvServiceImpl$$EnhancerBySpringCGLIB$$b03f35d0.getFlinkConfig(<generated>)
        at org.apache.streampark.console.core.service.impl.SavepointServiceImpl.clearExpire(SavepointServiceImpl.java:160)
        at org.apache.streampark.console.core.service.impl.SavepointServiceImpl.saveSavePoint(SavepointServiceImpl.java:322)
        at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$FastClassBySpringCGLIB$$5fcde58d.invoke(<generated>)
        at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
        at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
        at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
        at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
        at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$EnhancerBySpringCGLIB$$734f4020.saveSavePoint(<generated>)
        at org.apache.streampark.console.core.task.CheckpointProcessor.saveSavepoint(CheckpointProcessor.java:184)
        at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:99)
        at org.apache.streampark.console.core.task.CheckpointProcessor.lambda$process$0(CheckpointProcessor.java:76)
        at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
        at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:76)
        at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.handleCheckPoints(FlinkAppHttpWatcher.java:390)
        at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.getFromFlinkRestApi(FlinkAppHttpWatcher.java:328)
        at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.lambda$watch$2(FlinkAppHttpWatcher.java:220)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:834)

[Shmilyqjj]

same problem

[Shmilyqjj]

After creating Flink env, base64 should be stored here, but the absolute path is actually stored. resulting in this error.
创建Flink env后，这里本该存的是base64，但实际存的是绝对路径。导致这个报错。

[bulolo]

same ,有临时措施能解决吗？