You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/05/05 00:19:31 UTC
[1/2] beam git commit: This closes #2906
Repository: beam
Updated Branches:
refs/heads/master 3042d761a -> 5fc3d3359
This closes #2906
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fc3d335
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fc3d335
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fc3d335
Branch: refs/heads/master
Commit: 5fc3d335919207c23bc6fd2047e9e38351754ff1
Parents: 3042d76 040dbd4
Author: Thomas Groh <tg...@google.com>
Authored: Thu May 4 17:14:48 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Thu May 4 17:14:48 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/control/ProcessBundleHandlerTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
[2/2] beam git commit: Update expectation in ProcessBundleHandlerTest
Posted by tg...@apache.org.
Update expectation in ProcessBundleHandlerTest
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/040dbd4f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/040dbd4f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/040dbd4f
Branch: refs/heads/master
Commit: 040dbd4fd21a31dd3eb0f34fb9610ce857111db8
Parents: 3042d76
Author: Thomas Groh <tg...@google.com>
Authored: Thu May 4 17:01:24 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Thu May 4 17:14:48 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/control/ProcessBundleHandlerTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/040dbd4f/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java b/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
index 3e06369..748ffea 100644
--- a/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
+++ b/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
@@ -18,6 +18,7 @@
package org.apache.beam.fn.harness.control;
+import static org.apache.beam.sdk.util.WindowedValue.timestampedValueInGlobalWindow;
import static org.apache.beam.sdk.util.WindowedValue.valueInGlobalWindow;
import static org.hamcrest.Matchers.contains;
import static org.hamcrest.Matchers.empty;
@@ -433,7 +434,10 @@ public class ProcessBundleHandlerTest {
additionalOutputValues.clear();
Iterables.getOnlyElement(finishFunctions).run();
- assertThat(mainOutputValues, contains(valueInGlobalWindow("FinishBundle")));
+ assertThat(
+ mainOutputValues,
+ contains(
+ timestampedValueInGlobalWindow("FinishBundle", GlobalWindow.INSTANCE.maxTimestamp())));
mainOutputValues.clear();
}