Repository: beam Updated Branches: refs/heads/master feb165c07 -> c6bd668cf
Fix checkArgument error message args Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8eafd0d9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8eafd0d9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8eafd0d9 Branch: refs/heads/master Commit: 8eafd0d9c409d34b159ee9fc2303be7a248d337d Parents: feb165c Author: Kenneth Knowles <[email protected]> Authored: Mon Mar 27 09:24:25 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Mon Mar 27 09:52:50 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/8eafd0d9/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java index 59ef8de..86bf425 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategies.java @@ -242,6 +242,7 @@ public class WindowingStrategies implements Serializable { windowFnSpec.getSpec().getUrn().equals(CUSTOM_WINDOWFN_URN), "Only Java-serialized %s instances are supported, with URN %s. But found URN %s", WindowFn.class.getSimpleName(), + CUSTOM_WINDOWFN_URN, windowFnSpec.getSpec().getUrn()); Object deserializedWindowFn =
