Added messages to exceptions
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c0623c10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c0623c10 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c0623c10 Branch: refs/heads/python-sdk Commit: c0623c10318f95984747bd94fd5d733be5e5de11 Parents: a23ae20 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Thu Nov 17 15:36:12 2016 -0800 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Thu Nov 17 15:36:12 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c0623c10/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java index a5bb214..b946e4d 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java @@ -182,12 +182,14 @@ class GroupAlsoByWindowEvaluatorFactory implements TransformEvaluatorFactory { @Override public <T> boolean contains(PCollectionView<T> view) { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException( + "GroupAlsoByWindow must not have side inputs"); } @Override public boolean isEmpty() { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException( + "GroupAlsoByWindow must not have side inputs"); } }, droppedDueToClosedWindow,