From 02f45c4161dffeca5253e21967628ec27562b796 Mon Sep 17 00:00:00 2001 From: Jarek Jarcec Cecho Date: Fri, 3 Aug 2012 20:20:01 +0000 Subject: [PATCH] SQOOP-536. Blob import doesn't work with avro 1.7.1. (Cheolsoo Park via Jarek Jarcec Cecho) git-svn-id: https://svn.apache.org/repos/asf/sqoop/trunk@1369193 13f79535-47bb-0310-9956-ffa450edef68 --- src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java b/src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java index 2c5abd8e..30db288b 100644 --- a/src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java +++ b/src/java/org/apache/sqoop/mapreduce/AvroImportMapper.java @@ -113,7 +113,8 @@ private Object toAvro(Object o) { BlobRef br = (BlobRef) o; // If blob data is stored in an external .lob file, save the ref file // as Avro bytes. If materialized inline, save blob data as Avro bytes. - return br.isExternal() ? br.toString().getBytes() : br.getData(); + byte[] bytes = br.isExternal() ? br.toString().getBytes() : br.getData(); + return ByteBuffer.wrap(bytes); } else if (o instanceof ClobRef) { throw new UnsupportedOperationException("ClobRef not suported"); }