Something's a bit annoying with flink's state and operator UID is that even if you set human readable uid, flink will hash those again and use this hash in error messages, like

Cannot map checkpoint/savepoint state for operator 1569c05272b3ada0036c5425ae58508a to the new program

. The only solution I found to make sure that the missing operator is the one that I expect is to compute the hash manually on my side with something like:

Hashing.murmur3_128(0).newHasher().putString("a-uid-for-human", StandardCharsets.UTF_8).hash().toString()

.