cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "rajesh.bawal@orkash.com" <rajesh.ba...@orkash.com>
Subject Got exception running Sqoop: org.apache.cassandra.db.marshal.MarshalException: 97 is not recognized as a valid type, while importing data from mysql to cassandra using sqoop
Date Fri, 03 Aug 2012 05:51:03 GMT
Hi Everyone,
I am trying to import data into cassandra column family from mysql and i 
am getting the following error.

ERROR sqoop.Sqoop: Got exception running Sqoop: 
org.apache.cassandra.db.marshal.MarshalException: 97 is not recognized 
as a valid type
org.apache.cassandra.db.marshal.MarshalException: 97 is not recognized 
as a valid type
     at 
com.datastax.bdp.util.CompositeUtil.deserialize(CompositeUtil.java:93)
     at 
com.datastax.bdp.hadoop.cfs.CassandraFileSystemThriftStore.retrieveINode(CassandraFileSystemThriftStore.java:585)
     at 
com.datastax.bdp.hadoop.cfs.CassandraFileSystemThriftStore.retrieveINode(CassandraFileSystemThriftStore.java:563)
     at 
com.datastax.bdp.hadoop.cfs.CassandraFileSystem.getFileStatus(CassandraFileSystem.java:520)
     at org.apache.hadoop.fs.FileSystem.exists(FileSystem.java:768)
     at 
org.apache.hadoop.mapreduce.JobSubmissionFiles.getStagingDir(JobSubmissionFiles.java:103)
     at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:856)
     at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:850)
     at java.security.AccessController.doPrivileged(Native Method)
     at javax.security.auth.Subject.doAs(Subject.java:396)
     at 
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1093)
     at 
org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:850)
     at org.apache.hadoop.mapreduce.Job.submit(Job.java:500)
     at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:530)
     at 
org.apache.sqoop.mapreduce.ImportJobBase.runJob(ImportJobBase.java:119)
     at 
org.apache.sqoop.mapreduce.ImportJobBase.runImport(ImportJobBase.java:179)
     at 
org.apache.sqoop.manager.SqlManager.importTable(SqlManager.java:423)
     at 
org.apache.sqoop.manager.MySQLManager.importTable(MySQLManager.java:97)
     at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:380)
     at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:453)
     at org.apache.sqoop.Sqoop.run(Sqoop.java:145)
     at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
     at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:181)
     at org.apache.sqoop.Sqoop.runTool(Sqoop.java:220)
     at org.apache.sqoop.Sqoop.runTool(Sqoop.java:229)
     at org.apache.sqoop.Sqoop.main(Sqoop.java:238)
     at com.cloudera.sqoop.Sqoop.main(Sqoop.java:57)

Could anyone help me solve this issue.

Thanks
Rajesh Kumar


Mime
View raw message