spring????flinkclient????jar??????????

Fri, 20 Aug 2021 00:29:59 -0700 

??????    
 ????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)

回复