You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2016/11/29 10:10:19 UTC
[2/2] incubator-beam git commit: This closes #1450
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 <an...@paypal.com>
Authored: Tue Nov 29 11:50:51 2016 +0200
Committer: Sela <an...@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(-)
----------------------------------------------------------------------