Thank you Stefan, I'll try to follow your guide to debug. And sorry for being confusing in the previous email. When I said "different builds", I meant different versions of my application, not different builds of Flink.
Between versions of my application, I do add/remove some operators. However, as I mentioned from the 1st email, I got errors when restoring savepoint created by the same version of my application. Thanks and best regards, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/