Revert "[FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID"
This reverts commit f1b2b83d because it makes the OperatorSubtaskState unserializable due to the usage of guava.Multimap.get. This effectively breaks the master.
Showing
想要评论请 注册 或 登录