Hadoop Connector Fails with invalid Stream Header 7B222474

connections

#1

Sqoop Job fails with the following message. It is able to authenticate and get the VBucket information. Could not figure out the root cause of the issue. Any help would be appreciated.

2017-11-14 13:44:26.083 WARN net.spy.memcached.transcoders.SerializingTranscoder: Caught IOException decoding 1062 bytes of data
java.io.StreamCorruptedException: invalid stream header: 7B222474
at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:857)
at java.io.ObjectInputStream.(ObjectInputStream.java:349)
at net.spy.memcached.transcoders.BaseSerializingTranscoder.deserialize(BaseSerializingTranscoder.java:128)
at net.spy.memcached.transcoders.SerializingTranscoder.decode(SerializingTranscoder.java:88)
at com.couchbase.sqoop.lib.CouchbaseRecordUtil.deserialize(CouchbaseRecordUtil.java:37)
at com.couchbase.sqoop.mapreduce.db.CouchbaseRecordReader.nextKeyValue(CouchbaseRecordReader.java:197)
at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:562)
at org.apache.hadoop.mapreduce.task.MapContextImpl.nextKeyValue(MapContextImpl.java:80)
at org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.nextKeyValue(WrappedMapper.java:91)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
at org.apache.sqoop.mapreduce.AutoProgressMapper.run(AutoProgressMapper.java:64)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:793)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:164)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1917)
at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:158)