[ https://issues.apache.org/jira/browse/BEAM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chamikara Jayalath resolved BEAM-737. ------------------------------------- Resolution: Fixed Fix Version/s: Not applicable > 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 > Fix For: Not applicable > > > 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)