Fix typo in UnboundedSource deserialization error message
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11368e08 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11368e08 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/11368e08 Branch: refs/heads/master Commit: 11368e08b2afdb7835eeaef7d868f819f44e631e Parents: c0cb28c Author: Kenneth Knowles <[email protected]> Authored: Mon Oct 9 20:00:46 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Oct 17 12:45:11 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/runners/core/construction/ReadTranslation.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/11368e08/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java ---------------------------------------------------------------------- diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java index 4b14c51..ee89562 100644 --- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java +++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java @@ -134,7 +134,7 @@ public class ReadTranslation { checkArgument(payload.getIsBounded().equals(IsBounded.Enum.UNBOUNDED)); return (UnboundedSource<?, ?>) SerializableUtils.deserializeFromByteArray( - payload.getSource().getSpec().getPayload().toByteArray(), "BoundedSource"); + payload.getSource().getSpec().getPayload().toByteArray(), "UnboundedSource"); } public static PCollection.IsBounded sourceIsBounded(AppliedPTransform<?, ?, ?> transform) {
