Stas Levin created BEAM-1713:
--------------------------------
Summary: {{SparkRuntimeContext}} instances are leaking via
{{StateSpecFunctions#mapSourceFunction}}
Key: BEAM-1713
URL: https://issues.apache.org/jira/browse/BEAM-1713
Project: Beam
Issue Type: Bug
Components: runner-spark
Reporter: Stas Levin
Assignee: Amit Sela
Priority: Minor
When creating an anonymous class like so:
{code:java}new Iterable<byte[]>() {...}{code} it is capturing the enclosing
scope's {{SparkRuntimeContext}} instance in
{{StateSpecFunctions#mapSourceFunction}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
