You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/11/10 18:11:40 UTC
[2/4] beam git commit: Set OnTimeBehavior in windowing strategy to
FIRE_ALWAYS.
Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS.
This fixes python side of https://issues.apache.org/jira/browse/BEAM-2961.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bddb8699
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bddb8699
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bddb8699
Branch: refs/heads/release-2.2.0
Commit: bddb86996b5083134ff87abcac1a8db49ef6ba09
Parents: 22dcd73
Author: tvalentyn <tv...@users.noreply.github.com>
Authored: Thu Nov 9 13:16:24 2017 -0800
Committer: Valentyn Tymofieiev <va...@google.com>
Committed: Thu Nov 9 13:55:00 2017 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/transforms/core.py | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/bddb8699/sdks/python/apache_beam/transforms/core.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py
index 41e20ba..ba60ced 100644
--- a/sdks/python/apache_beam/transforms/core.py
+++ b/sdks/python/apache_beam/transforms/core.py
@@ -1528,6 +1528,7 @@ class Windowing(object):
output_time=self.timestamp_combiner,
# TODO(robertwb): Support EMIT_IF_NONEMPTY
closing_behavior=beam_runner_api_pb2.ClosingBehavior.EMIT_ALWAYS,
+ OnTimeBehavior=beam_runner_api_pb2.OnTimeBehavior.FIRE_ALWAYS,
allowed_lateness=0)
@staticmethod