http://www.datastax.com/support-forums/topic/importing-data-into-cassandra-from-mysql-when-column-family-already-exist Software, Support, and Training for Apache Cassandra en-US Wed, 19 Jun 2013 14:38:35 +0000 http://bbpress.org/?v=1.0.3 q http://www.datastax.com/support-forums/search.php http://www.datastax.com/support-forums/topic/importing-data-into-cassandra-from-mysql-when-column-family-already-exist#post-8364 Fri, 11 Jan 2013 16:18:56 +0000 khahn 8364@http://www.datastax.com/support-forums/ <p>I hope this helps you: <a href="http://www.datastax.com/docs/1.2/cql_cli/cql/COPY#cqlsh-copy-to-from" rel="nofollow">http://www.datastax.com/docs/1.2/cql_cli/cql/COPY#cqlsh-copy-to-from</a>. Also a feature of Cassandra 1.1. </p> http://www.datastax.com/support-forums/topic/importing-data-into-cassandra-from-mysql-when-column-family-already-exist#post-8194 Fri, 28 Dec 2012 10:36:37 +0000 Anonymous 8194@http://www.datastax.com/support-forums/ <p>Hi,</p> <p>I am trying to append to a column family in Cassandra by importing data from my sql using sqoop. But looks like I need to change data type of all column in column family to Text\varchar . Is there any other way through which I can import data to an existing column family in Cassandra. Appreciate you help. please find err I am getting below:</p> <p>1.) Sqoop statement:<br /> bin/dse sqoop import --connect jdbc:mysql://mysqlURL/sqoopCassandraTest --username root --password root --outdir /home/user/workDir/sqoopTest/ --table sqoopDataTypeTest --cassandra-keyspace sqooptest --cassandra-column-family dataTypeTest --cassandra-thrift-host localhost --split-by id --append<br /> 2.) Mapper error:</p> <p>12/12/28 16:07:57 INFO mapred.JobClient: Task Id : attempt_201212261607_0061_m_000000_1, Status : FAILED<br /> java.io.IOException: InvalidRequestException(why:Expected 4 or 0 byte int (1))<br /> at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:316)<br /> Caused by: InvalidRequestException(why:Expected 4 or 0 byte int (1))<br /> at org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20253)<br /> at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)<br /> at org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:922)<br /> at org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:908)<br /> at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter$RangeClient.run(ColumnFamilyRecordWriter.java:308) </p>