Hi Rajesh, could you please specify Sqoop version you're using, entire command line you've used (please feel free to substitute sensitive information with asterisks) and entire log that sqoop generated with --verbose flag?
Jarcec On Fri, Aug 03, 2012 at 10:07:50AM +0530, [email protected] wrote: > 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
signature.asc
Description: Digital signature
