Ok, thanks for the explanation now it makes sense. Previously I haven’t noticed that those snapshot state calls visible in your stack trace come from State Processor API. We will try to reproduce it, so we might have more questions later, but those information might be enough.
One more question for now, have you tried using Presto for the bootstrapping/batch job as well? Piotrek > On 31 Oct 2019, at 23:49, spoganshev <s.pogans...@slice.com> wrote: > > The problem happens in batch jobs (the ones that use ExecutionEnvironment) > that use state processor api for bootstrapping initial savepoint for > streaming job. > > We are building a single docker image for streaming and batch versions of > the job. In that image we put both presto (which we use for checkpoints in > streaming job) and hadoop to separate plugin folders. When we run a batch > job using this image the aforementioned exception happens. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
