spring集成flinkclient提交jar文件的问题

[教主 <84...@qq.com.INVALID>]

您好！     基于spring搭建了可视化的管理平台，其中可上传jar包，然后提交jar包到flink集群并启动任务，功能已实现遇到个问题，但偶尔会报错，贴了点日志，分析感觉是flinkclient提交jar的时候spring会执行jar包代码，特别说明下重启web应用后的第一次是可以正常提交jar到flink集群，之后再提交jar启动任务就如下报错，所以每次更新任务都得先重启web。没头绪，是否有人遇到过此类问题。


java.util.zip.ZipException: invalid distance too far back
	at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:164)
	at org.springframework.boot.loader.jar.ZipInflaterInputStream.read(ZipInflaterInputStream.java:52)
	at java.io.FilterInputStream.read(FilterInputStream.java:107)
	at java.util.Properties$LineReader.readLine(Properties.java:435)
	at java.util.Properties.load0(Properties.java:353)
	at java.util.Properties.load(Properties.java:341)
	at org.apache.flink.api.java.utils.ParameterTool.fromPropertiesFile(ParameterTool.java:137)
	at com.chinaunicom.streamjob.job.HawkeyeTask.main(HawkeyeTask.java:52)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:349)
	at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:219)
	at org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:158)
	at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:82)
	at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:117)
	at com.chinaunicom.dataengine.graph.JobManager.submitJarJob(JobManager.java:422)
	at org.springblade.modules.dstream.service.impl.JobServiceImpl.submit(JobServiceImpl.java:295)





java.util.zip.ZipException: invalid block type
	at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:164)
	at org.springframework.boot.loader.jar.ZipInflaterInputStream.read(ZipInflaterInputStream.java:52)
	at java.io.FilterInputStream.read(FilterInputStream.java:107)
	at java.util.Properties$LineReader.readLine(Properties.java:435)
	at java.util.Properties.load0(Properties.java:353)
	at java.util.Properties.load(Properties.java:341)
	at org.apache.flink.api.java.utils.ParameterTool.fromPropertiesFile(ParameterTool.java:137)
	at com.chinaunicom.streamjob.job.CbssCdrCheatTask.main(CbssCdrCheatTask.java:54)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:349)
	at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:219)
	org.apache.flink.client.program.ProgramInvocationException: The program plan could not be fetched - the program aborted pre-maturely.
System.out: (none)