Stas Levin created BEAM-1828: -------------------------------- Summary: GlobalWatermarkHolder uses unpersist instead of destory Key: BEAM-1828 URL: https://issues.apache.org/jira/browse/BEAM-1828 Project: Beam Issue Type: Bug Components: runner-spark Reporter: Stas Levin Assignee: Amit Sela Priority: Minor
{{GlobalWatermarkHolder}} uses {{unpersist}} when it's done with the broadcast, however, this leaves a copy of the broadcast in the driver's memory so {{destroy}} may be more appropriate for this. -- This message was sent by Atlassian JIRA (v6.3.15#6346)