This closes #3322
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdfc70ee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdfc70ee Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdfc70ee Branch: refs/heads/gearpump-runner Commit: fdfc70eecb8a3833c155e8bb7b6e128d956a61de Parents: d81ed21 3e04902 Author: Ahmet Altay <al...@google.com> Authored: Thu Jun 8 10:55:47 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Thu Jun 8 10:55:47 2017 -0700 ---------------------------------------------------------------------- .../runners/direct/watermark_manager.py | 20 +++++++++++++++++--- sdks/python/apache_beam/utils/timestamp.py | 5 +++++ 2 files changed, 22 insertions(+), 3 deletions(-) ----------------------------------------------------------------------