git.net

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

Cheers,
Kostas

> 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/