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/gearpump-runner Commit: 6d9d8bc6fc2795fa25a9120324e652b9bec20ca8 Parents: a9a41eb e43228c Author: Dan Halperin <[email protected]> Authored: Mon Oct 24 07:07:44 2016 -0700 Committer: Dan Halperin <[email protected]> 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(-) ----------------------------------------------------------------------
