flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From StefanRRichter <...@git.apache.org>
Subject [GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen...
Date Wed, 29 Nov 2017 10:10:44 GMT
Github user StefanRRichter commented on the issue:

    @shixiaogang The changes sound helpful, considering that this PR was implemented before
incremental checkpoints. For a final opinion I would have to review the code. One concern
that I have is a wild grow of more and more reported state types that we introduce. I am currently
working on a feature that introduces recovery from task-local state, which also looks like
it will add to the states that can be produced in a snapshot. So we might need some form of
consolidation in the future to avoid a "wild-grow" of more and more state types that make
everything more complex and harder to maintain. But overall, I think the general idea is very


View raw message