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 <lvhu...@gmail.com> 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/
