This closes #2356
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a40534e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2a40534e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2a40534e Branch: refs/heads/master Commit: 2a40534e80fb84d969ac16bd0d62618109ee04b4 Parents: 769398e 3876f83 Author: Stas Levin <stasle...@apache.org> Authored: Thu Mar 30 14:53:57 2017 +0300 Committer: Stas Levin <stasle...@apache.org> Committed: Thu Mar 30 14:53:57 2017 +0300 ---------------------------------------------------------------------- .../runners/spark/io/SparkUnboundedSource.java | 37 ++++++++++++-------- .../spark/stateful/StateSpecFunctions.java | 17 +++++---- 2 files changed, 31 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
