[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Error restoring from savepoint while there's no modification to the job

Hi Averell,

In the logs there are some “Split Reader: Custom File Source:” 
This is a custom source you implemented?
Also is your keySelector deterministic with proper equals and hashcode methods? 


> On Oct 10, 2018, at 10:50 AM, Averell <lvhuyen@xxxxxxxxx> wrote:
> Hi Stefan, Dawid,
> I hadn't changed anything in the configuration. Env's parallelism stayed at
> 64. Some source/sink operators have parallelism of 1 to 8. I'm using Flink
> 1.7-SNAPSHOT, with the code pulled from the master branch about 5 days back.
> Savepoint was saved to either S3 or HDFS (I tried multiple times), and had
> not been moved.
> Is there any kind of improper user code can cause such error?
> Thanks for your support.
> Best regards,
> Averell
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/