Aljoscha Krettek created BEAM-3087: -------------------------------------- Summary: Extend lock scope in Flink UnboundedSourceWrapper Key: BEAM-3087 URL: https://issues.apache.org/jira/browse/BEAM-3087 Project: Beam Issue Type: Bug Components: runner-flink Reporter: Aljoscha Krettek Assignee: Aljoscha Krettek Fix For: 2.3.0
In {{UnboundedSourceWrapper}} the lock scope is not big enough: we synchronise in {{emitElement()}} but should instead synchronise inside the reader loop in {{run()}} because the {{Source}} interface does not allow concurrent calls. -- This message was sent by Atlassian JIRA (v6.4.14#64029)