You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/10/25 16:28:50 UTC
[32/50] incubator-beam git commit: Closes #1161
Closes #1161
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6d9d8bc6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6d9d8bc6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6d9d8bc6
Branch: refs/heads/apex-runner
Commit: 6d9d8bc6fc2795fa25a9120324e652b9bec20ca8
Parents: a9a41eb e43228c
Author: Dan Halperin <dh...@google.com>
Authored: Mon Oct 24 07:07:44 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Oct 24 07:07:44 2016 -0700
----------------------------------------------------------------------
.../streaming/StreamingEvaluationContext.java | 11 ++++++++---
.../translation/streaming/EmptyStreamAssertionTest.java | 10 +++++++---
.../streaming/ResumeFromCheckpointStreamingTest.java | 2 +-
.../streaming/SimpleStreamingWordCountTest.java | 1 -
.../translation/streaming/utils/PAssertStreaming.java | 6 +++---
5 files changed, 19 insertions(+), 11 deletions(-)
----------------------------------------------------------------------