This closes #1450
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3a8b9b52 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3a8b9b52 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3a8b9b52 Branch: refs/heads/master Commit: 3a8b9b5212972f0128099251884473d06758e2aa Parents: 3f16f26 a1a4ac0 Author: Sela <ans...@paypal.com> Authored: Tue Nov 29 11:50:51 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Tue Nov 29 11:50:51 2016 +0200 ---------------------------------------------------------------------- .../beam/runners/spark/io/MicrobatchSource.java | 20 ++++++++++++++------ .../beam/runners/spark/io/SourceDStream.java | 3 ++- .../spark/stateful/StateSpecFunctions.java | 2 +- 3 files changed, 17 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
