This closes #2046
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4e5a762e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4e5a762e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4e5a762e Branch: refs/heads/master Commit: 4e5a762ef36336eeecb568f12c9f3b41fa683a97 Parents: aa45ccb a2f0615 Author: Sela <ans...@paypal.com> Authored: Mon Feb 20 12:08:23 2017 +0200 Committer: Sela <ans...@paypal.com> Committed: Mon Feb 20 12:08:23 2017 +0200 ---------------------------------------------------------------------- .../beam/runners/spark/translation/BoundedDataset.java | 10 +++++++++- .../spark/translation/streaming/UnboundedDataset.java | 9 ++------- 2 files changed, 11 insertions(+), 8 deletions(-) ----------------------------------------------------------------------