tomma

It seems like we could not restore a seatunnel job from a flink checkpoint/savepoint.

@yzeng1618 First ,Really appreciate your input! here is my above test settings: seatunnel job setting, it's a streaming job ` env { parallelism = 1 job.mode = "STREAMING" checkpoint.interval=60000 flink.execution.checkpointing.mode...

Append some exception log that could be helpful for figuring out the problem: ` at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.0.jar:1.18.0] at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.0.jar:1.18.0] at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.0.jar:1.18.0] at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:356) ~[flink-dist-1.18.0.jar:1.18.0] at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.0.jar:1.18.0] at...

Another info: for flink , i used rockdb statebackend and OSS as the savepoint/checkpoint

Thanks @yzeng1618 for your input on this. I will have a try of Zate. but I think should be some official docs about if Seatunnel supports to restore from flink(supported...