Github user ShashwatRastogi-Reflektion commented on the issue:
https://github.com/apache/flink/pull/3117
@zentol I am using flink 1.3.2.
Normally, I don't use `--allowNonRestoredState` and I get an error while
restarting the job. After using this `allowNonRestoredState` the job starts up
fine but there is a data loss because of lost state, which is what I want to
avoid.
I think, the problem with my implementation is that I am wrongly assigning
some ids to the operators. Is there sure-shot way of finding out uid or
uid-hash generated by flink for each operator(with/without chaining) ?
---
