No matches were found for subject:"\[jira\] \[Assigned\] \(BEAM\-3087\) Extend lock scope in Flink UnboundedSourceWrapper"