Re: java.io.StreamCorruptedException: unexpected block data

2021-04-21 Thread Jingsong Li
createJobMasterService(DefaultJobMasterServiceFactory.java:95) >> at >> org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService(DefaultJobMasterServiceFactory.java:39) >> at >> org.apache.flink.runtime.jobmaster.Jo

Re: java.io.StreamCorruptedException: unexpected block data

2021-04-16 Thread Alokh P
(JobManagerRunnerImpl.java:162) > at > org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) > at > org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:4

java.io.StreamCorruptedException: unexpected block data

2021-04-16 Thread Alokh P
er.JobManagerRunnerImpl.(JobManagerRunnerImpl.java:162) at org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:86) at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5(Dispatcher.java:478) ... 4 more Caused by: