I take it this is done so that the shutdown doesn't block indefinitely, since it snapshots the current set of operations? Please add a comment for this if that is the case.
Do we log anywhere that this result has expired? [ Full content available at: https://github.com/apache/flink/pull/6785 ] This message was relayed via gitbox.apache.org for [email protected]
