Chamikara Jayalath created BEAM-737: ---------------------------------------
Summary: Update TextSource to not maintain local state Key: BEAM-737 URL: https://issues.apache.org/jira/browse/BEAM-737 Project: Beam Issue Type: Bug Components: sdk-py Reporter: Chamikara Jayalath Assignee: Chamikara Jayalath Currently, TextSource [1] maintains a temporary buffer as local state. This could be problematic if a runner implementation tries to pickle the source. We could update TextSource to not maintain any temporary state. [1] https://github.com/apache/incubator-beam/blob/python-sdk/sdks/python/apache_beam/io/textio.py#L32 -- This message was sent by Atlassian JIRA (v6.3.4#6332)