sqoop-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jarek Jarcec Cecho <jar...@apache.org>
Subject Re: Error importing data from mysql to cassandra using sqoop
Date Fri, 03 Aug 2012 17:09:54 GMT
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, rajesh.bawal@orkash.com 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

Mime
View raw message