Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/6059
Hi @dawidwys! Thanks for the work.
The changes seem really good. As we discussed privately I did a review and
the comments you can find them in the branch I sent you.
The only things I would like to write here as a reminder are:
1) as a future commit, we could in some cases do the cleaning up during
discovering the partial matches, i.e. do the `releaseNode()` from within the
`extractCurrentMatches()` (whenever appropriate). This could be a separate JIRA
actually.
2) when migrating from an old version, we should ignore potential
"dead-end" edges (edges that point to nodes that have been removed) in the
partial match buffer.
---
