You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/08/24 19:52:50 UTC
[12/17] incubator-beam git commit: Allow DoFn Reuse in
ParDoTest.TestDoFnWithContext
Allow DoFn Reuse in ParDoTest.TestDoFnWithContext
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4aba224e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4aba224e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4aba224e
Branch: refs/heads/master
Commit: 4aba224e44f3ef6c96d1836d9434bbc2e3daad0c
Parents: dfbdc6c
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Sat Jul 23 10:48:42 2016 +0200
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 24 12:46:24 2016 -0700
----------------------------------------------------------------------
.../src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4aba224e/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
index c384114..13dec9a 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
@@ -193,7 +193,9 @@ public class ParDoTest implements Serializable {
@StartBundle
public void startBundle(Context c) {
- assertEquals(State.UNSTARTED, state);
+ assertThat(state,
+ anyOf(equalTo(State.UNSTARTED), equalTo(State.FINISHED)));
+
state = State.STARTED;
outputToAll(c, "started");
}