flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ShashwatRastogi-Reflektion <...@git.apache.org>
Subject [GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes
Date Tue, 03 Apr 2018 16:22:57 GMT
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) ?


---

Mime
View raw message