Thomas Groh created BEAM-796: -------------------------------- Summary: Watermarks should be updated after all other changes have been committed Key: BEAM-796 URL: https://issues.apache.org/jira/browse/BEAM-796 Project: Beam Issue Type: Bug Components: runner-direct Reporter: Thomas Groh Assignee: Thomas Groh
Otherwise, a transform may be executed based on state changes that are not visible to it yet. -- This message was sent by Atlassian JIRA (v6.3.4#6332)