[BEAM-737] Update TextSource to not maintain local state

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: sdk-py-core
• Assignee: Chamikara Madhusanka Jayalath
• Reporter: Chamikara Madhusanka Jayalath
• Created: 10/Oct/16 19:23
• Updated: 16/May/20 13:34
• Resolved: 18/Oct/16 19:49

Description

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

Issue Links

• links to: GitHub Pull Request #1090