This is an automated email from the ASF dual-hosted git repository. apilloud pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new 3405b05 add missing bytes new c783c45 Merge pull request #7961 from amaliujia/rw-add_missing_bytes 3405b05 is described below commit 3405b058651f60653acb3a1afb58f2f4f0904f20 Author: amaliujia <amaliu...@gmail.com> AuthorDate: Wed Feb 27 15:22:11 2019 -0800 add missing bytes --- .../apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java index e3971f5..3fb9a67 100644 --- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java +++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java @@ -293,6 +293,7 @@ public class BeamEnumerableConverter extends ConverterImpl implements Enumerable case DOUBLE: case STRING: case BOOLEAN: + case BYTES: return beamValue; case ARRAY: return ((List<?>) beamValue)